control.go 932 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. package dialer
  2. import (
  3. "context"
  4. "net"
  5. "syscall"
  6. )
  7. type controlFn = func(ctx context.Context, network, address string, c syscall.RawConn) error
  8. func addControlToListenConfig(lc *net.ListenConfig, fn controlFn) {
  9. llc := *lc
  10. lc.Control = func(network, address string, c syscall.RawConn) (err error) {
  11. switch {
  12. case llc.Control != nil:
  13. if err = llc.Control(network, address, c); err != nil {
  14. return
  15. }
  16. }
  17. return fn(context.Background(), network, address, c)
  18. }
  19. }
  20. func addControlToDialer(d *net.Dialer, fn controlFn) {
  21. ld := *d
  22. d.ControlContext = func(ctx context.Context, network, address string, c syscall.RawConn) (err error) {
  23. switch {
  24. case ld.ControlContext != nil:
  25. if err = ld.ControlContext(ctx, network, address, c); err != nil {
  26. return
  27. }
  28. case ld.Control != nil:
  29. if err = ld.Control(network, address, c); err != nil {
  30. return
  31. }
  32. }
  33. return fn(ctx, network, address, c)
  34. }
  35. }