| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- package internet
- import "syscall"
- const (
- TCP_FASTOPEN = 15 // nolint: revive,stylecheck
- )
- func setTFO(fd syscall.Handle, settings SocketConfig_TCPFastOpenState) error {
- switch settings {
- case SocketConfig_Enable:
- if err := syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, TCP_FASTOPEN, 1); err != nil {
- return err
- }
- case SocketConfig_Disable:
- if err := syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, TCP_FASTOPEN, 0); err != nil {
- return err
- }
- }
- return nil
- }
- func applyOutboundSocketOptions(network string, address string, fd uintptr, config *SocketConfig) error {
- if isTCPSocket(network) {
- if err := setTFO(syscall.Handle(fd), config.Tfo); err != nil {
- return err
- }
- if config.TcpKeepAliveInterval > 0 {
- if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 1); err != nil {
- return newError("failed to set SO_KEEPALIVE", err)
- }
- }
- }
- return nil
- }
- func applyInboundSocketOptions(network string, fd uintptr, config *SocketConfig) error {
- if isTCPSocket(network) {
- if err := setTFO(syscall.Handle(fd), config.Tfo); err != nil {
- return err
- }
- if config.TcpKeepAliveInterval > 0 {
- if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 1); err != nil {
- return newError("failed to set SO_KEEPALIVE", err)
- }
- }
- }
- return nil
- }
- func bindAddr(fd uintptr, ip []byte, port uint32) error {
- return nil
- }
- func setReuseAddr(fd uintptr) error {
- return nil
- }
- func setReusePort(fd uintptr) error {
- return nil
- }
|