control_zos.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. // Copyright 2020 The Go Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style
  3. // license that can be found in the LICENSE file.
  4. package ipv4
  5. import (
  6. "net"
  7. "unsafe"
  8. "golang.org/x/net/internal/iana"
  9. "golang.org/x/net/internal/socket"
  10. )
  11. func marshalPacketInfo(b []byte, cm *ControlMessage) []byte {
  12. m := socket.ControlMessage(b)
  13. m.MarshalHeader(iana.ProtocolIP, sysIP_PKTINFO, sizeofInetPktinfo)
  14. if cm != nil {
  15. pi := (*inetPktinfo)(unsafe.Pointer(&m.Data(sizeofInetPktinfo)[0]))
  16. if ip := cm.Src.To4(); ip != nil {
  17. copy(pi.Addr[:], ip)
  18. }
  19. if cm.IfIndex > 0 {
  20. pi.setIfindex(cm.IfIndex)
  21. }
  22. }
  23. return m.Next(sizeofInetPktinfo)
  24. }
  25. func parsePacketInfo(cm *ControlMessage, b []byte) {
  26. pi := (*inetPktinfo)(unsafe.Pointer(&b[0]))
  27. cm.IfIndex = int(pi.Ifindex)
  28. if len(cm.Dst) < net.IPv4len {
  29. cm.Dst = make(net.IP, net.IPv4len)
  30. }
  31. copy(cm.Dst, pi.Addr[:])
  32. }
  33. func setControlMessage(c *socket.Conn, opt *rawOpt, cf ControlFlags, on bool) error {
  34. opt.Lock()
  35. defer opt.Unlock()
  36. if so, ok := sockOpts[ssoReceiveTTL]; ok && cf&FlagTTL != 0 {
  37. if err := so.SetInt(c, boolint(on)); err != nil {
  38. return err
  39. }
  40. if on {
  41. opt.set(FlagTTL)
  42. } else {
  43. opt.clear(FlagTTL)
  44. }
  45. }
  46. if so, ok := sockOpts[ssoPacketInfo]; ok {
  47. if cf&(FlagSrc|FlagDst|FlagInterface) != 0 {
  48. if err := so.SetInt(c, boolint(on)); err != nil {
  49. return err
  50. }
  51. if on {
  52. opt.set(cf & (FlagSrc | FlagDst | FlagInterface))
  53. } else {
  54. opt.clear(cf & (FlagSrc | FlagDst | FlagInterface))
  55. }
  56. }
  57. } else {
  58. if so, ok := sockOpts[ssoReceiveDst]; ok && cf&FlagDst != 0 {
  59. if err := so.SetInt(c, boolint(on)); err != nil {
  60. return err
  61. }
  62. if on {
  63. opt.set(FlagDst)
  64. } else {
  65. opt.clear(FlagDst)
  66. }
  67. }
  68. if so, ok := sockOpts[ssoReceiveInterface]; ok && cf&FlagInterface != 0 {
  69. if err := so.SetInt(c, boolint(on)); err != nil {
  70. return err
  71. }
  72. if on {
  73. opt.set(FlagInterface)
  74. } else {
  75. opt.clear(FlagInterface)
  76. }
  77. }
  78. }
  79. return nil
  80. }