Browse Source

transport: make tr stop safe

Xiang Li 10 years ago
parent
commit
ea688c1f06
1 changed files with 2 additions and 0 deletions
  1. 2 0
      rafthttp/transport.go

+ 2 - 0
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()
 	}