conn_go12.go 274 B

123456789101112131415161718192021
  1. // +build go1.2
  2. package gocql
  3. import (
  4. "net"
  5. "time"
  6. )
  7. func (c *Conn) setKeepalive(d time.Duration) error {
  8. if tc, ok := c.conn.(*net.TCPConn); ok {
  9. err := tc.SetKeepAlivePeriod(d)
  10. if err != nil {
  11. return err
  12. }
  13. return tc.SetKeepAlive(true)
  14. }
  15. return nil
  16. }