(k int)
| 140 | } |
| 141 | |
| 142 | func (w *receiver) deleteMap(k int) { |
| 143 | w.receiverMtx.Lock() |
| 144 | if _, ok := w.receiver[k]; ok { |
| 145 | if len(w.receiver[k]) > 0 { |
| 146 | <-w.receiver[k] |
| 147 | } |
| 148 | close(w.receiver[k]) |
| 149 | delete(w.receiver, k) |
| 150 | } |
| 151 | defer w.receiverMtx.Unlock() |
| 152 | } |
| 153 | |
| 154 | func (w *receiver) getCmd() (v int) { |
| 155 | w.cmdMtx.Lock() |