(item workItem)
| 128 | } |
| 129 | |
| 130 | func (b *Broker) processSendWork(item workItem) { |
| 131 | switch item.workType { |
| 132 | case "sendack": |
| 133 | b.processSendAck(item.ackPk) |
| 134 | case "senddata": |
| 135 | b.processSendData(item.dataPk) |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | func (b *Broker) processRecvWork(item workItem) { |
| 140 | switch item.workType { |
nothing calls this directly
no test coverage detected