1 // Copyright 2017 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.
6 // +build !js,!nacl,!plan9,!windows
13 "golang.org/x/net/internal/socket"
16 func (c *payloadHandler) readFrom(b []byte) (int, *ControlMessage, net.Addr, error) {
19 OOB: NewControlMessage(c.rawOpt.cflags),
22 switch c.PacketConn.(type) {
24 m.Buffers = [][]byte{b}
25 if err := c.RecvMsg(&m, 0); err != nil {
26 return 0, nil, nil, &net.OpError{Op: "read", Net: c.PacketConn.LocalAddr().Network(), Source: c.PacketConn.LocalAddr(), Err: err}
29 h := make([]byte, HeaderLen)
30 m.Buffers = [][]byte{h, b}
31 if err := c.RecvMsg(&m, 0); err != nil {
32 return 0, nil, nil, &net.OpError{Op: "read", Net: c.PacketConn.LocalAddr().Network(), Source: c.PacketConn.LocalAddr(), Err: err}
34 hdrlen := int(h[0]&0x0f) << 2
43 return 0, nil, nil, &net.OpError{Op: "read", Net: c.PacketConn.LocalAddr().Network(), Source: c.PacketConn.LocalAddr(), Err: errInvalidConnType}
45 var cm *ControlMessage
47 cm = new(ControlMessage)
48 if err := cm.Parse(m.OOB[:m.NN]); err != nil {
49 return 0, nil, nil, &net.OpError{Op: "read", Net: c.PacketConn.LocalAddr().Network(), Source: c.PacketConn.LocalAddr(), Err: err}
51 cm.Src = netAddrToIP4(m.Addr)
53 return m.N, cm, m.Addr, nil
56 func (c *payloadHandler) writeTo(b []byte, cm *ControlMessage, dst net.Addr) (int, error) {
62 err := c.SendMsg(&m, 0)
64 err = &net.OpError{Op: "write", Net: c.PacketConn.LocalAddr().Network(), Source: c.PacketConn.LocalAddr(), Addr: opAddr(dst), Err: err}