sockopt_windows.go 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. package internet
  2. import "syscall"
  3. const (
  4. TCP_FASTOPEN = 15 // nolint: revive,stylecheck
  5. )
  6. func setTFO(fd syscall.Handle, settings SocketConfig_TCPFastOpenState) error {
  7. switch settings {
  8. case SocketConfig_Enable:
  9. if err := syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, TCP_FASTOPEN, 1); err != nil {
  10. return err
  11. }
  12. case SocketConfig_Disable:
  13. if err := syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, TCP_FASTOPEN, 0); err != nil {
  14. return err
  15. }
  16. }
  17. return nil
  18. }
  19. func applyOutboundSocketOptions(network string, address string, fd uintptr, config *SocketConfig) error {
  20. if isTCPSocket(network) {
  21. if err := setTFO(syscall.Handle(fd), config.Tfo); err != nil {
  22. return err
  23. }
  24. if config.TcpKeepAliveInterval > 0 {
  25. if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 1); err != nil {
  26. return newError("failed to set SO_KEEPALIVE", err)
  27. }
  28. }
  29. }
  30. return nil
  31. }
  32. func applyInboundSocketOptions(network string, fd uintptr, config *SocketConfig) error {
  33. if isTCPSocket(network) {
  34. if err := setTFO(syscall.Handle(fd), config.Tfo); err != nil {
  35. return err
  36. }
  37. if config.TcpKeepAliveInterval > 0 {
  38. if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 1); err != nil {
  39. return newError("failed to set SO_KEEPALIVE", err)
  40. }
  41. }
  42. }
  43. return nil
  44. }
  45. func bindAddr(fd uintptr, ip []byte, port uint32) error {
  46. return nil
  47. }
  48. func setReuseAddr(fd uintptr) error {
  49. return nil
  50. }
  51. func setReusePort(fd uintptr) error {
  52. return nil
  53. }