Commit f2a1eb68 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 171c9f09
...@@ -23,11 +23,11 @@ package xneo ...@@ -23,11 +23,11 @@ package xneo
//go:generate gotrace gen . //go:generate gotrace gen .
import ( import (
"context" // "context"
"sync" "sync"
"lab.nexedi.com/kirr/go123/xnet" "lab.nexedi.com/kirr/go123/xnet"
"lab.nexedi.com/kirr/neo/go/internal/log" // "lab.nexedi.com/kirr/neo/go/internal/log"
"lab.nexedi.com/kirr/neo/go/neo/proto" "lab.nexedi.com/kirr/neo/go/neo/proto"
) )
...@@ -84,6 +84,7 @@ func NewNode(net xnet.Networker, typ proto.NodeType, clusterName, masterAddr str ...@@ -84,6 +84,7 @@ func NewNode(net xnet.Networker, typ proto.NodeType, clusterName, masterAddr str
} }
/*
// ---------------------------------------- // ----------------------------------------
// XXX kill -> only in MasteredNode / talkMaster // XXX kill -> only in MasteredNode / talkMaster
...@@ -130,3 +131,4 @@ func (node *Node) UpdateClusterState(ctx context.Context, msg *proto.NotifyClust ...@@ -130,3 +131,4 @@ func (node *Node) UpdateClusterState(ctx context.Context, msg *proto.NotifyClust
log.Infof(ctx, "state update: %v", msg.State) log.Infof(ctx, "state update: %v", msg.State)
node.ClusterState.Set(msg.State) node.ClusterState.Set(msg.State)
} }
*/
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