From acee23112af15fb2021353b0b0ed453b0aa82014 Mon Sep 17 00:00:00 2001 From: ngaut Date: Mon, 4 Jan 2016 11:51:51 +0800 Subject: [PATCH] raft: typo --- raft/raft.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/raft/raft.go b/raft/raft.go index d26b9a830..b5817b3a8 100644 --- a/raft/raft.go +++ b/raft/raft.go @@ -262,7 +262,7 @@ func (r *raft) send(m pb.Message) { r.msgs = append(r.msgs, m) } -// sendAppend sends RRPC, with entries to the given peer. +// sendAppend sends RPC, with entries to the given peer. func (r *raft) sendAppend(to uint64) { pr := r.prs[to] if pr.isPaused() { @@ -338,7 +338,7 @@ func (r *raft) sendHeartbeat(to uint64) { r.send(m) } -// bcastAppend sends RRPC, with entries to all peers that are not up-to-date +// bcastAppend sends RPC, with entries to all peers that are not up-to-date // according to the progress recorded in r.prs. func (r *raft) bcastAppend() { for i := range r.prs { @@ -349,7 +349,7 @@ func (r *raft) bcastAppend() { } } -// bcastHeartbeat sends RRPC, without entries to all the peers. +// bcastHeartbeat sends RPC, without entries to all the peers. func (r *raft) bcastHeartbeat() { for i := range r.prs { if i == r.id {