Commit e0e31499 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9b955162
...@@ -225,7 +225,7 @@ func (p *PeerNode) ResetLink(ctx context.Context) { ...@@ -225,7 +225,7 @@ func (p *PeerNode) ResetLink(ctx context.Context) {
p.linkMu.Unlock() p.linkMu.Unlock()
if link != nil { if link != nil {
log.Infof(ctx, "%v: closing link", link) log.Infof(ctx, "%s: closing link", link)
err := link.Close() err := link.Close()
if err != nil { if err != nil {
log.Error(ctx, err) log.Error(ctx, err)
......
...@@ -162,7 +162,7 @@ func (c *Cell) Readable() bool { ...@@ -162,7 +162,7 @@ func (c *Cell) Readable() bool {
// The partition table created will be of len=np // The partition table created will be of len=np
func MakePartTab(np int, nreplica int, nodev []*PeerNode) *PartitionTable { func MakePartTab(np int, nreplica int, nodev []*PeerNode) *PartitionTable {
if nreplica < 1 { if nreplica < 1 {
panic("nreplica too small") panic("nreplica < 1")
} }
// TODO tests // TODO tests
......
...@@ -153,7 +153,7 @@ func NewNode(typ proto.NodeType, clusterName string, net xnet.Networker, masterA ...@@ -153,7 +153,7 @@ func NewNode(typ proto.NodeType, clusterName string, net xnet.Networker, masterA
// XXX doc, naming // XXX doc, naming
// XXX WithStateHead ? WithStateSnapshot ? // XXX WithStateHead ? WithStateSnapshot ? -> ReadState ?
func (node *Node) WithState(f func(*/*readonly*/State)) { func (node *Node) WithState(f func(*/*readonly*/State)) {
node.stateLogMu.Lock() node.stateLogMu.Lock()
s := node.state s := node.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