(b []byte)
| 76 | } |
| 77 | |
| 78 | func (mc *mysqlConn) writeWithTimeout(b []byte) (int, error) { |
| 79 | to := mc.cfg.WriteTimeout |
| 80 | if to > 0 { |
| 81 | if err := mc.netConn.SetWriteDeadline(time.Now().Add(to)); err != nil { |
| 82 | return 0, err |
| 83 | } |
| 84 | } |
| 85 | return mc.netConn.Write(b) |
| 86 | } |
| 87 | |
| 88 | func (mc *mysqlConn) resetSequence() { |
| 89 | mc.sequence = 0 |
no test coverage detected