ciao-scheduler: Send node disconnect messaged with correct type

Messages for both node connected and disconnected were being erroneously sent with a type of ssntp.NodeConnected. This meant controller was not correctly noticing when nodes were being disconnected. Signed-off-by: Rob Bradford <[email protected]>
sboeuf · Aug 9, 2017 · bf29aeb · bf29aeb
1 parent 15fb864
commit bf29aeb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ciao-scheduler/scheduler.go b/ciao-scheduler/scheduler.go
@@ -192,7 +192,11 @@ func (sched *ssntpSchedulerServer) sendNodeConnectionEvents(nodeUUID string, nod
 	defer sched.controllerMutex.RUnlock()
 
 	for _, ctl := range sched.controllerMap {
-		sched.ssntp.SendEvent(ctl.uuid, ssntp.NodeConnected, b)
+		if connected {
+			sched.ssntp.SendEvent(ctl.uuid, ssntp.NodeConnected, b)
+		} else {
+			sched.ssntp.SendEvent(ctl.uuid, ssntp.NodeDisconnected, b)
+		}
 	}
 }