rafthttp: remove unnecessary sendc from peer
parent
2e0dc8467d
commit
ec9e77db96
|
@ -106,7 +106,6 @@ type peer struct {
|
||||||
msgAppV2Reader *streamReader
|
msgAppV2Reader *streamReader
|
||||||
msgAppReader *streamReader
|
msgAppReader *streamReader
|
||||||
|
|
||||||
sendc chan raftpb.Message
|
|
||||||
recvc chan raftpb.Message
|
recvc chan raftpb.Message
|
||||||
propc chan raftpb.Message
|
propc chan raftpb.Message
|
||||||
|
|
||||||
|
@ -145,7 +144,6 @@ func startPeer(transport *Transport, urls types.URLs, peerID types.ID, fs *stats
|
||||||
writer: startStreamWriter(peerID, status, fs, r),
|
writer: startStreamWriter(peerID, status, fs, r),
|
||||||
pipeline: pipeline,
|
pipeline: pipeline,
|
||||||
snapSender: newSnapshotSender(transport, picker, peerID, status),
|
snapSender: newSnapshotSender(transport, picker, peerID, status),
|
||||||
sendc: make(chan raftpb.Message),
|
|
||||||
recvc: make(chan raftpb.Message, recvBufSize),
|
recvc: make(chan raftpb.Message, recvBufSize),
|
||||||
propc: make(chan raftpb.Message, maxPendingProposals),
|
propc: make(chan raftpb.Message, maxPendingProposals),
|
||||||
stopc: make(chan struct{}),
|
stopc: make(chan struct{}),
|
||||||
|
|
Loading…
Reference in New Issue