Commit 2fe63ef2 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 839d42a6
...@@ -193,7 +193,7 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func( ...@@ -193,7 +193,7 @@ func (node *_MasteredNode) talkMaster1(ctx, ctxPreTalkM context.Context, f func(
// XXX verify Mnid = M*; our nid corresponds to our type // XXX verify Mnid = M*; our nid corresponds to our type
// rebuild nicer task now when we know both our and master NIDs // rebuild nicer task now - when we know both our and master NIDs
// e.g. "client ?: talk master(127.0.0.1:21484)" -> "C1: talk M1". // e.g. "client ?: talk master(127.0.0.1:21484)" -> "C1: talk M1".
ctx := ctxPreTalkM ctx := ctxPreTalkM
defer task.Runningf(&ctx, "%s: talk %s", accept.YourNID, accept.MyNID)(&err) defer task.Runningf(&ctx, "%s: talk %s", accept.YourNID, accept.MyNID)(&err)
......
...@@ -83,7 +83,7 @@ type Node struct { ...@@ -83,7 +83,7 @@ type Node struct {
MasterAddr string // address of current master TODO -> masterRegistry MasterAddr string // address of current master TODO -> masterRegistry
// XXX reconsider not using State and have just .NodeTab, .PartTab, .ClusterState // XXX reconsider not using State and have just .NodeTab, .PartTab, .ClusterState
StateMu sync.RWMutex // <- XXX unexport StateMu sync.RWMutex // <- XXX unexport ? XXX not used -> move to MasteredNode ?
State ClusterState // nodeTab/partTab/stateCode XXX unexport? State ClusterState // nodeTab/partTab/stateCode XXX unexport?
// NodeTab *NodeTable // information about nodes in the cluster // NodeTab *NodeTable // information about nodes in the cluster
// PartTab *PartitionTable // information about data distribution in the cluster // PartTab *PartitionTable // information about data distribution in the cluster
......
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