(ctx context.Context)
| 169 | } |
| 170 | |
| 171 | func (c *Conn) setupWriteTimeout(ctx context.Context) bool { |
| 172 | if ctx.Done() == nil { |
| 173 | return false |
| 174 | } |
| 175 | |
| 176 | stop := context.AfterFunc(ctx, func() { |
| 177 | c.clearWriteTimeout() |
| 178 | c.close() |
| 179 | }) |
| 180 | swapTimeoutStop(&c.writeTimeoutStop, &stop) |
| 181 | return true |
| 182 | } |
| 183 | |
| 184 | func (c *Conn) clearWriteTimeout() { |
| 185 | swapTimeoutStop(&c.writeTimeoutStop, nil) |
no test coverage detected