()
| 264 | } |
| 265 | |
| 266 | func (mw *msgWriter) close() { |
| 267 | if mw.c.client { |
| 268 | mw.c.writeFrameMu.forceLock() |
| 269 | putBufioWriter(mw.c.bw) |
| 270 | } |
| 271 | |
| 272 | mw.writeMu.forceLock() |
| 273 | mw.putFlateWriter() |
| 274 | } |
| 275 | |
| 276 | func (c *Conn) writeControl(ctx context.Context, opcode opcode, p []byte) error { |
| 277 | ctx, cancel := context.WithTimeout(ctx, time.Second*5) |
nothing calls this directly
no test coverage detected