| // Copyright 2023 The Go Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style |
| // license that can be found in the LICENSE file. |
| |
| package net |
| |
| import ( |
| "internal/syscall/windows" |
| "syscall" |
| ) |
| |
| // SetKeepAliveConfig configures keep-alive messages sent by the operating system. |
| func (c *TCPConn) SetKeepAliveConfig(config KeepAliveConfig) error { |
| if !c.ok() { |
| return syscall.EINVAL |
| } |
| |
| if err := setKeepAlive(c.fd, config.Enable); err != nil { |
| return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} |
| } |
| if windows.SupportTCPKeepAliveIdle() && windows.SupportTCPKeepAliveInterval() { |
| if err := setKeepAliveIdle(c.fd, config.Idle); err != nil { |
| return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} |
| } |
| if err := setKeepAliveInterval(c.fd, config.Interval); err != nil { |
| return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} |
| } |
| } else if err := setKeepAliveIdleAndInterval(c.fd, config.Idle, config.Interval); err != nil { |
| return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} |
| } |
| if err := setKeepAliveCount(c.fd, config.Count); err != nil { |
| return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} |
| } |
| |
| return nil |
| } |