From 91b62c0fbf8efae8d3203160fab0675ff0960245 Mon Sep 17 00:00:00 2001 From: Blake Mizerany Date: Mon, 25 Aug 2014 13:08:32 -0700 Subject: [PATCH] raft: messages -> byMsgType --- raft/node.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/raft/node.go b/raft/node.go index 8d9fe9de6..b5e4d0abc 100644 --- a/raft/node.go +++ b/raft/node.go @@ -107,7 +107,7 @@ func (n *Node) Propose(ctx context.Context, data []byte) error { // prevent this cluster from making progress. The ctx.Err() will be returned, // if any. func (n *Node) Step(ctx context.Context, msgs []Message) error { - sort.Sort(sort.Reverse(messages(msgs))) + sort.Sort(sort.Reverse(byMsgType(msgs))) for _, m := range msgs { ch := n.recvc if m.Type == msgProp { @@ -138,8 +138,8 @@ func (n *Node) ReadState(ctx context.Context) (st State, ents, cents []Entry, ms } } -type messages []Message +type byMsgType []Message -func (msgs messages) Len() int { return len(msgs) } -func (msgs messages) Less(i, j int) bool { return msgs[i].Type == msgProp } -func (msgs messages) Swap(i, j int) { msgs[i], msgs[j] = msgs[i], msgs[j] } +func (msgs byMsgType) Len() int { return len(msgs) } +func (msgs byMsgType) Less(i, j int) bool { return msgs[i].Type == msgProp } +func (msgs byMsgType) Swap(i, j int) { msgs[i], msgs[j] = msgs[i], msgs[j] }