Commit c9d2d4e8 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 8700e53e
......@@ -247,7 +247,7 @@ func (r *EventRouter) Route(event interface{}) (dst *tsync.SyncChan) {
return dst
}
// XXX doc
// BranchNode branches events corresponsing to state on host.
func (r *EventRouter) BranchNode(host string, dst *tsync.SyncChan) {
r.mu.Lock()
defer r.mu.Unlock()
......@@ -467,10 +467,11 @@ func TestMasterStorage(t *testing.T) {
// XXX C-S
rt.BranchNode("m", cM)
rt.BranchNode("s", cS)
//rt.BranchNode("c", cC) XXX - no
rt.BranchLink("s-m", cSM, cMS)
rt.BranchLink("c-m", cCM, cMC)
//rt.BranchNode("s", cMS) // state on S is controlled by M
rt.BranchNode("s", cS) // XXX <- no
rt.BranchNode("c", cMC) // state on C is controlled by M
// cluster nodes
M := NewMaster("abc1", ":1", Mhost)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment