Commit 7ef30219 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ea538368
......@@ -1247,7 +1247,7 @@ func (p *_MasteredPeer) run(ctx context.Context, f func() error) error {
}
}
// accept sends accept reply and pushes inital state0 snapshot to peer.
// accept sends accept reply and pushes initial state0 snapshot to peer.
func (p *_MasteredPeer) accept(ctx context.Context) (err error) {
defer task.Runningf(&ctx, "accept %s", p.node.NID)(&err)
......
......@@ -213,7 +213,7 @@ func (p *PeerNode) ResetLink(ctx context.Context) {
p.linkMu.Unlock()
if link != nil {
log.Infof(ctx, "%v: closing link", link)
log.Infof(ctx, "%s: closing link", link)
err := link.Close()
if err != nil {
log.Error(ctx, err)
......
......@@ -162,7 +162,7 @@ func (c *Cell) Readable() bool {
// The partition table created will be of len=np
func MakePartTab(np int, nreplica int, nodev []*PeerNode) *PartitionTable {
if nreplica < 1 {
panic("nreplica too small")
panic("nreplica < 1")
}
// TODO tests
......@@ -224,7 +224,7 @@ func (pt *PartitionTable) OperationalWith(nt *NodeTable) bool {
}
// ---- encode / decode PT to / from messages
// ---- encode / decode PT to / from messages ----
func (pt *PartitionTable) String() string {
buf := &bytes.Buffer{}
......
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