udp_linux_amd64.go 995 B

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package nebula
  2. import "unsafe"
  3. type iovec struct {
  4. Base *byte
  5. Len uint64
  6. }
  7. type msghdr struct {
  8. Name *byte
  9. Namelen uint32
  10. Pad0 [4]byte
  11. Iov *iovec
  12. Iovlen uint64
  13. Control *byte
  14. Controllen uint64
  15. Flags int32
  16. Pad1 [4]byte
  17. }
  18. type rawMessage struct {
  19. Hdr msghdr
  20. Len uint32
  21. Pad0 [4]byte
  22. }
  23. func (u *udpConn) PrepareRawMessages(n int) ([]rawMessage, [][]byte, [][]byte) {
  24. msgs := make([]rawMessage, n)
  25. buffers := make([][]byte, n)
  26. names := make([][]byte, n)
  27. for i := range msgs {
  28. buffers[i] = make([]byte, mtu)
  29. names[i] = make([]byte, 0x1c) //TODO = sizeofSockaddrInet6
  30. //TODO: this is still silly, no need for an array
  31. vs := []iovec{
  32. {Base: (*byte)(unsafe.Pointer(&buffers[i][0])), Len: uint64(len(buffers[i]))},
  33. }
  34. msgs[i].Hdr.Iov = &vs[0]
  35. msgs[i].Hdr.Iovlen = uint64(len(vs))
  36. msgs[i].Hdr.Name = (*byte)(unsafe.Pointer(&names[i][0]))
  37. msgs[i].Hdr.Namelen = uint32(len(names[i]))
  38. }
  39. return msgs, buffers, names
  40. }