udp_linux_64.go 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. //go:build linux && (amd64 || arm64 || ppc64 || ppc64le || mips64 || mips64le || s390x || riscv64 || loong64) && !android && !e2e_testing
  2. // +build linux
  3. // +build amd64 arm64 ppc64 ppc64le mips64 mips64le s390x riscv64 loong64
  4. // +build !android
  5. // +build !e2e_testing
  6. package udp
  7. import (
  8. "golang.org/x/sys/unix"
  9. )
  10. type iovec struct {
  11. Base *byte
  12. Len uint64
  13. }
  14. type msghdr struct {
  15. Name *byte
  16. Namelen uint32
  17. Pad0 [4]byte
  18. Iov *iovec
  19. Iovlen uint64
  20. Control *byte
  21. Controllen uint64
  22. Flags int32
  23. Pad1 [4]byte
  24. }
  25. type rawMessage struct {
  26. Hdr msghdr
  27. Len uint32
  28. Pad0 [4]byte
  29. }
  30. func (u *StdConn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte) {
  31. msgs := make([]rawMessage, n)
  32. buffers := make([][]byte, n)
  33. names := make([][]byte, n)
  34. for i := range msgs {
  35. buffers[i] = make([]byte, MTU)
  36. names[i] = make([]byte, unix.SizeofSockaddrInet6)
  37. vs := []iovec{
  38. {Base: &buffers[i][0], Len: uint64(len(buffers[i]))},
  39. }
  40. msgs[i].Hdr.Iov = &vs[0]
  41. msgs[i].Hdr.Iovlen = uint64(len(vs))
  42. msgs[i].Hdr.Name = &names[i][0]
  43. msgs[i].Hdr.Namelen = uint32(len(names[i]))
  44. }
  45. return msgs, buffers, names
  46. }
  47. func setIovecBase(iov *iovec, base *byte) {
  48. iov.Base = base
  49. }
  50. func setIovecLen(iov *iovec, l int) {
  51. iov.Len = uint64(l)
  52. }
  53. func setMsghdrIovlen(hdr *msghdr, l int) {
  54. hdr.Iovlen = uint64(l)
  55. }
  56. func setMsghdrControllen(hdr *msghdr, l int) {
  57. hdr.Controllen = uint64(l)
  58. }