(k int, c chan []byte)
| 129 | return crMap |
| 130 | } |
| 131 | func (w *receiver) pushMap(k int, c chan []byte) int { |
| 132 | w.receiverMtx.Lock() |
| 133 | if _, ok := w.receiver[k]; ok { |
| 134 | return 51003 |
| 135 | } |
| 136 | w.receiver[k] = c |
| 137 | defer w.receiverMtx.Unlock() |
| 138 | |
| 139 | return 200 |
| 140 | } |
| 141 | |
| 142 | func (w *receiver) deleteMap(k int) { |
| 143 | w.receiverMtx.Lock() |