Adding master notification

Author: LostLaser

Diff for: server/ring/message/election.go

@@ -18,6 +18,11 @@ func (e *Election) AddNotified(id string) {
 	e.notified = append(e.notified, id)
 }
 
+// NotifiedCount gets the number of items in the notified list
+func (e *Election) NotifiedCount() int {
+	return len(e.notified)
+}
+
 // GetHighest will return the highest value in the notified list
 func (e *Election) GetHighest() string {
 	max := ""

Diff for: server/ring/message/notify.go

@@ -6,8 +6,8 @@ type Notify struct {
 	visited []string
 }
 
-// NewElected creates a new instance of an Notify message
-func NewElected(id string) Notify {
+// NewNotify creates a new instance of an Notify message
+func NewNotify(id string) Notify {
 	e := Notify{}
 	e.visited = make([]string, 0)
 	e.Master = id

Diff for: server/ring/process.go

@@ -52,17 +52,20 @@ func (r *Process) electionResponder() {
 			// add name to alive list and send to neighbor
 			if m.Exists(r.ID) {
 				r.SetMaster(m.GetHighest())
-				q := message.NewElected(m.GetHighest())
+				q := message.NewNotify(m.GetHighest())
 				q.AddVisited(r.ID)
 				r.getNeighbor().notifyQueue <- q
 			} else {
-				r.Emitter.Write(r.ID, r.getNeighbor().ID, "ELECT")
+				r.Emitter.Write(r.ID, r.getNeighbor().ID, "START_NEW_ELECTION")
 				m.AddNotified(r.ID)
 				r.getNeighbor().electionQueue <- m
 			}
 		case m := <-r.notifyQueue:
 			// set master to consensus and send to neighbor
 			if !m.Visited(r.ID) {
+				if r.ID == m.Master {
+					r.Emitter.Write(r.ID, "", "ELECTED")
+				}
 				r.SetMaster(m.Master)
 				m.AddVisited(r.ID)
 				r.Emitter.Write(r.ID, r.getNeighbor().ID, "ELECT")