When jobs change, sync all data to master peers right away (don't wait for next tick).

Author: jhuckaby

lib/action.js

@@ -472,6 +472,7 @@ class Actions {
 			activeJobs: this.getActiveJobs(),
 			jobsChanged: true
 		} );
+		this.masterSync();
 
 		if (!action.details) action.details = "";
 

lib/api/jobs.js

@@ -835,6 +835,7 @@ class Jobs {
 				activeJobs: self.getActiveJobs(),
 				jobsChanged: true
 			} );
+			self.masterSync();
 		}); // loadSession
 	}
 
@@ -950,6 +951,7 @@ class Jobs {
 				activeJobs: self.getActiveJobs(),
 				jobsChanged: true
 			} );
+			self.masterSync();
 
 		}); // loadSession
 	}

lib/job.js

@@ -216,6 +216,7 @@ class Jobs {
 			activeJobs: this.getActiveJobs(),
 			jobsChanged: true
 		} );
+		this.masterSync();
 	}
 
 	appendJobLog(job, msg, data) {
@@ -311,6 +312,7 @@ class Jobs {
 						activeJobs: this.getActiveJobs(),
 						jobsChanged: true
 					} );
+					this.masterSync();
 				}
 
 				// FUTURE NOTE: This will only launch a max of 1 queued job per event per second (per tick)
@@ -1278,6 +1280,7 @@ class Jobs {
 						jobsChanged: true,
 						state: Tools.copyHashRemoveKeys( self.state, { dirty: 1 } )
 					} );
+					self.masterSync();
 
 					// and notify all job watchers that the job is fully complete
 					self.doPageBroadcast( 'Job?id=' + job.id, 'job_completed', {} );

lib/multi.js

@@ -976,8 +976,8 @@ class Multi {
 		this.electionTimer = setTimeout( this.electMaster.bind(this), multi.master_timeout_sec * 1000 );
 	}
 
-	masterTick() {
-		// called every second, maintain master peers
+	masterSync() {
+		// sync all active data with peers
 		var self = this;
 		if (!this.master) return;
 
@@ -990,7 +990,18 @@ class Multi {
 				jobDetails: self.jobDetails,
 				activeAlerts: self.activeAlerts
 			});
-			peer.socket.tick();
+		});
+	}
+	
+	masterTick() {
+		// called every second, maintain master peers
+		var self = this;
+		if (!this.master) return;
+		
+		this.masterSync();
+		
+		this.peers.forEach( function(peer) {
+			if (peer.socket) peer.socket.tick();
 		});
 	}