Method vmWriteSockaddr

cmd/run/engine/process/vm.go:208–253

vmWriteSockaddr writes a sockaddr struct and its length to the process' memory at ptr. It panics if addr is invalid or if ptr/sizePtr is NULL.

(n *seccomp.Notif, addr netip.AddrPort, ptr uintptr, sizePtr uintptr)

// vmWriteSockaddr writes a sockaddr struct and its length to the process'
// memory at ptr. It panics if addr is invalid or if ptr/sizePtr is NULL.
func (p *Process) vmWriteSockaddr(n *seccomp.Notif, addr netip.AddrPort, ptr uintptr, sizePtr uintptr) (syscall.Errno, error) {
	if !addr.IsValid() {
		panic("invalid AddrPort")
	}
	if ptr == 0 || sizePtr == 0 {
		panic(fmt.Sprintf("NULL: ptr=%x, sizePtr=%x", ptr, sizePtr))
	}

	avail, errno, err := p.vmReadUint32(n, sizePtr)
	if errno != 0 || err != nil {
		return errno, err
	}
	if avail < 0 {
		return unix.EINVAL, nil
	}

	var sa linux.SockAddr
	switch {
	case addr.Addr().Is6() || addr.Addr().Is4In6():
		sa = &linux.SockAddrInet6{
			Family: unix.AF_INET6,
			Addr:   linux.Inet6Addr(addr.Addr().As16()),
			Port:   htons(addr.Port()),
		}
	case addr.Addr().Is4():
		sa = &linux.SockAddrInet{
			Family: unix.AF_INET,
			Addr:   linux.InetAddr(addr.Addr().As4()),
			Port:   htons(addr.Port()),
		}
	}

	b := make([]byte, sa.SizeBytes(), sa.SizeBytes())
	sa.MarshalBytes(b)
	if uint32(sa.SizeBytes()) > avail {
		b = b[:avail]
	}

	if errno, err := p.vmWriteBytes(n, ptr, b); errno != 0 || err != nil {
		return errno, err
	}
	if errno, err := p.vmWriteUint32(n, sizePtr, uint32(sa.SizeBytes())); errno != 0 || err != nil {
		return errno, err
	}
	return 0, nil
}