sockopt_windows.go 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. package internet
  2. import (
  3. "syscall"
  4. )
  5. const (
  6. TCP_FASTOPEN = 15
  7. )
  8. func setTFO(fd syscall.Handle, tfo int) error {
  9. if tfo > 0 {
  10. tfo = 1
  11. }
  12. if tfo >= 0 {
  13. if err := syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, TCP_FASTOPEN, tfo); 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.ParseTFOValue()); err != nil {
  22. return err
  23. }
  24. if config.TcpKeepAliveIdle > 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. } else if config.TcpKeepAliveIdle < 0 {
  29. if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 0); err != nil {
  30. return newError("failed to unset SO_KEEPALIVE", err)
  31. }
  32. }
  33. }
  34. return nil
  35. }
  36. func applyInboundSocketOptions(network string, fd uintptr, config *SocketConfig) error {
  37. if isTCPSocket(network) {
  38. if err := setTFO(syscall.Handle(fd), config.ParseTFOValue()); err != nil {
  39. return err
  40. }
  41. if config.TcpKeepAliveIdle > 0 {
  42. if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 1); err != nil {
  43. return newError("failed to set SO_KEEPALIVE", err)
  44. }
  45. } else if config.TcpKeepAliveIdle < 0 {
  46. if err := syscall.SetsockoptInt(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_KEEPALIVE, 0); err != nil {
  47. return newError("failed to unset SO_KEEPALIVE", err)
  48. }
  49. }
  50. }
  51. return nil
  52. }
  53. func bindAddr(fd uintptr, ip []byte, port uint32) error {
  54. return nil
  55. }
  56. func setReuseAddr(fd uintptr) error {
  57. return nil
  58. }
  59. func setReusePort(fd uintptr) error {
  60. return nil
  61. }