Commit bf8c0af0 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent e7446b47
...@@ -66,9 +66,8 @@ type _MasteredNode struct { ...@@ -66,9 +66,8 @@ type _MasteredNode struct {
// - state of partTab/nodeTab is operational // - state of partTab/nodeTab is operational
opMu sync.RWMutex opMu sync.RWMutex
mlink *neonet.NodeLink // link to master mlink *neonet.NodeLink // link to master
// state xneo.ClusterState // nodeTab/partTab/clusterState
opReady chan struct{} // reinitialized each time state becomes non-operational opReady chan struct{} // reinitialized each time state becomes non-operational
operational bool // cache for state.IsOperational() operational bool // cache for Node.State.IsOperational()
rxmFlags _MasteredNodeFlags // if e.g. δPartTab messages should be delivered to mlink.Recv1 rxmFlags _MasteredNodeFlags // if e.g. δPartTab messages should be delivered to mlink.Recv1
// XXX just use `.myInfo.NodeType == STORAGE` instead? // XXX just use `.myInfo.NodeType == STORAGE` instead?
...@@ -85,7 +84,7 @@ const ( ...@@ -85,7 +84,7 @@ const (
δPartTabPassThrough _MasteredNodeFlags = iota δPartTabPassThrough _MasteredNodeFlags = iota
) )
// newMasteredNode creats new _MasteredNode that connects to masterAddr/cluster via net. // newMasteredNode creates new _MasteredNode that connects to masterAddr/cluster via net.
func newMasteredNode(typ proto.NodeType, clusterName string, net xnet.Networker, masterAddr string) *_MasteredNode { func newMasteredNode(typ proto.NodeType, clusterName string, net xnet.Networker, masterAddr string) *_MasteredNode {
node := &_MasteredNode{ node := &_MasteredNode{
Node: xneo.NewNode(typ, clusterName, net, masterAddr), Node: xneo.NewNode(typ, clusterName, net, masterAddr),
......
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