From ea688c1f062b8d9c62bb76007ea48cb5aeb3be50 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Fri, 5 Feb 2016 13:53:43 -0800 Subject: [PATCH] transport: make tr stop safe --- rafthttp/transport.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/rafthttp/transport.go b/rafthttp/transport.go index 289e5ba93..cb5795803 100644 --- a/rafthttp/transport.go +++ b/rafthttp/transport.go @@ -187,6 +187,8 @@ func (t *Transport) Send(msgs []raftpb.Message) { } func (t *Transport) Stop() { + t.mu.Lock() + defer t.mu.Unlock() for _, r := range t.remotes { r.stop() }