(packet *Packet)
| 181 | } |
| 182 | |
| 183 | func (c *ForwardCtx) writePacket(packet *Packet) error { |
| 184 | c.encoderMu.Lock() |
| 185 | err := c.encoder.Encode(&packet) |
| 186 | c.encoderMu.Unlock() |
| 187 | return err |
| 188 | } |
| 189 | |
| 190 | func (c *ForwardCtx) handleData(packet *Packet) { |
| 191 | c.connMapMu.RLock() |
no test coverage detected