Method
SendData
(dataPk wshrpc.CommandStreamData)
Source from the content-addressed store, hash-verified
| 113 | } |
| 114 | |
| 115 | func (b *Broker) SendData(dataPk wshrpc.CommandStreamData) { |
| 116 | b.sendQueue.Enqueue(workItem{workType: "senddata", dataPk: dataPk}) |
| 117 | } |
| 118 | |
| 119 | // RecvData and RecvAck are designed to be non-blocking and must remain so to prevent deadlock. |
| 120 | // They only enqueue work items to be processed asynchronously by the work queue's goroutine. |
Callers
nothing calls this directly
Tested by
no test coverage detected