Skip to content

Commit

Permalink
Fix replication issue.
Browse files Browse the repository at this point in the history
Replication for both images and snapins was broken during the switch to methodized calls for looping.
In regards to snapins and images, we have to iterate the snapins and images iteratively twice.
Forgetting this, the issue occurred because the secondary variable did not exist.  Reset to use
the variable method (which limits sql calls.)
  • Loading branch information
mastacontrola committed Jan 5, 2017
1 parent 7289b88 commit a03f451
Show file tree
Hide file tree
Showing 13 changed files with 739 additions and 743 deletions.
2 changes: 1 addition & 1 deletion packages/web/lib/fog/system.class.php
Expand Up @@ -53,7 +53,7 @@ private static function _versionCompare()
public function __construct()
{
self::_versionCompare();
define('FOG_VERSION', '8');
define('FOG_VERSION', '9');
define('FOG_SCHEMA', 245);
define('FOG_BCACHE_VER', 111);
define('FOG_SVN_REVISION', 6052);
Expand Down
8 changes: 4 additions & 4 deletions packages/web/lib/service/imagereplicator.class.php
Expand Up @@ -91,8 +91,7 @@ public function __construct()
private function _commonOutput()
{
try {
$StorageNodes = $this->checkIfNodeMaster();
foreach ((array)$StorageNodes as &$StorageNode) {
foreach ((array)$this->checkIfNodeMaster() as &$StorageNode) {
self::wlog(
sprintf(
'* %s',
Expand Down Expand Up @@ -208,8 +207,9 @@ private function _commonOutput()
),
'imageID'
);
foreach ((array)self::getClass('ImageManager')
->find(array('id' => $imageIDs)) as &$Image
$Images = (array)self::getClass('ImageManager')
->find(array('id' => $imageIDs));
foreach ($Images as &$Image
) {
if (!$Image->getPrimaryGroup($myStorageGroupID)) {
self::outall(
Expand Down
5 changes: 1 addition & 4 deletions packages/web/lib/service/multicastmanager.class.php
Expand Up @@ -169,10 +169,7 @@ private function _serviceLoop()
);
try {
$StorageNodes = $this->checkIfNodeMaster();
foreach ((array)$StorageNodes as &$StorageNode) {
if (!$StorageNode->isValid()) {
continue;
}
foreach ((array)$this->checkIfNodeMaster() as &$StorageNode) {
$myroot = $StorageNode->get('path');
$RMTasks = array();
foreach ((array)$KnownTasks as &$mcTask) {
Expand Down
3 changes: 1 addition & 2 deletions packages/web/lib/service/snapinhash.class.php
Expand Up @@ -91,8 +91,7 @@ public function __construct()
private function _commonOutput()
{
try {
$StorageNodes = $this->checkIfNodeMaster();
foreach ((array)$StorageNodes as &$StorageNode) {
foreach ((array)$this->checkIfNodeMaster() as &$StorageNode) {
$myStorageGroupID = $StorageNode->get('storagegroupID');
$myStorageNodeID = $StorageNode->get('id');
$StorageGroup = $StorageNode->getStorageGroup();
Expand Down
8 changes: 4 additions & 4 deletions packages/web/lib/service/snapinreplicator.class.php
Expand Up @@ -91,8 +91,7 @@ public function __construct()
private function _commonOutput()
{
try {
$StorageNodes = $this->checkIfNodeMaster();
foreach ((array)$StorageNodes as &$StorageNode) {
foreach ((array)$this->checkIfNodeMaster() as &$StorageNode) {
self::wlog(
sprintf(
' * %s',
Expand Down Expand Up @@ -208,8 +207,9 @@ private function _commonOutput()
),
'snapinID'
);
foreach ((array)self::getClass('SnapinManager')
->find(array('id' => $snapinIDs)) as &$Snapin
$Snapins = (array)self::getClass('SnapinManager')
->find(array('id' => $snapinIDs));
foreach ($Snapins as &$Snapin
) {
if (!$Snapin->getPrimaryGroup($myStorageGroupID)) {
self::outall(
Expand Down

0 comments on commit a03f451

Please sign in to comment.