From 17ad7d762fa608d3b3db5b5985cc728e11460ae0 Mon Sep 17 00:00:00 2001 From: Anshul Pundir Date: Tue, 9 Jan 2018 10:57:30 -0800 Subject: [PATCH] raft/transport: add log message to indicate message send retry if streaming unimplemented. Signed-off-by: Anshul Pundir --- manager/state/raft/transport/peer.go | 1 + 1 file changed, 1 insertion(+) diff --git a/manager/state/raft/transport/peer.go b/manager/state/raft/transport/peer.go index eb849c0803..bdd3ec0293 100644 --- a/manager/state/raft/transport/peer.go +++ b/manager/state/raft/transport/peer.go @@ -239,6 +239,7 @@ func (p *peer) sendProcessMessage(ctx context.Context, m raftpb.Message) error { // Try doing a regular rpc if the receiver doesn't support streaming. if grpc.Code(err) == codes.Unimplemented { + log.G(ctx).Info("sending message to raft peer using ProcessRaftMessage()") _, err = api.NewRaftClient(p.conn()).ProcessRaftMessage(ctx, &api.ProcessRaftMessageRequest{Message: &m}) }