()
| 1555 | } |
| 1556 | |
| 1557 | func (d *connDeadline) unsetConnWriteDeadline() { |
| 1558 | d.mutex.Lock() |
| 1559 | d.wconn = nil |
| 1560 | d.mutex.Unlock() |
| 1561 | } |
| 1562 | |
| 1563 | // saslHandshake sends the SASL handshake message. This will determine whether |
| 1564 | // the Mechanism is supported by the cluster. If it's not, this function will |