add a comment

This commit is contained in:
yangzhouhan
2015-08-10 11:19:08 -07:00
parent 22561bcdfc
commit 95389ca819

View File

@ -59,6 +59,7 @@ func (b *recvBuffer) get() <-chan *kv {
return b.c
}
// stop terminates the recvBuffer. After it is called, the recvBuffer is not usable any more.
func (b *recvBuffer) stop() {
b.mu.Lock()
b.stopping = true