()
| 125 | } |
| 126 | |
| 127 | func (d *Device) Start() { |
| 128 | cpus := runtime.NumCPU() |
| 129 | d.wg.Add(2 * cpus) |
| 130 | for i := 0; i < cpus; i++ { |
| 131 | go d.msgToPacketRoutine(i) |
| 132 | go d.packetToMsgRoutine(i) |
| 133 | } |
| 134 | } |
| 135 | |
| 136 | func (d *Device) Stop() { |
| 137 | close(d.signals.stop) |
nothing calls this directly
no test coverage detected