Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 133 for raddr (0.13 sec)

  1. src/net/tcpsock_solaris.go

    		}
    		if err := setKeepAliveCount(c.fd, config.Count); err != nil {
    			return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    		}
    	} else if err := setKeepAliveIdleAndIntervalAndCount(c.fd, config.Idle, config.Interval, config.Count); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    
    	return nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  2. src/net/unixsock.go

    	}
    	return n, addr, err
    }
    
    // ReadFrom implements the [PacketConn] ReadFrom method.
    func (c *UnixConn) ReadFrom(b []byte) (int, Addr, error) {
    	if !c.ok() {
    		return 0, nil, syscall.EINVAL
    	}
    	n, addr, err := c.readFrom(b)
    	if err != nil {
    		err = &OpError{Op: "read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	if addr == nil {
    		return n, nil, err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. src/net/ipsock_plan9.go

    		return nil, mapErr(ctx.Err())
    	}
    }
    
    func dialPlan9Blocking(ctx context.Context, net string, laddr, raddr Addr) (fd *netFD, err error) {
    	if isWildcard(raddr) {
    		raddr = toLocal(raddr, net)
    	}
    	f, dest, proto, name, err := startPlan9(ctx, net, raddr)
    	if err != nil {
    		return nil, err
    	}
    	if la := plan9LocalAddr(laddr); la == "" {
    		err = hangupCtlWrite(ctx, proto, f, "connect "+dest)
    	} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 29 20:38:53 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  4. src/net/unixsock_test.go

    		t.Skip("unixgram test")
    	}
    
    	addr := testUnixAddr(t)
    	laddr, err := ResolveUnixAddr("unixgram", addr)
    	if err != nil {
    		t.Fatal(err)
    	}
    	c, err := ListenPacket("unixgram", addr)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.Remove(addr)
    	defer c.Close()
    
    	testUnixgramWriteConn(t, laddr)
    	testUnixgramWritePacketConn(t, laddr)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. src/net/net_fake.go

    			return ip
    		}
    	}
    
    	switch addr := addr.(type) {
    	case *TCPAddr:
    		ip := convertIP(addr.IP)
    		if ip == nil || len(ip) == len(addr.IP) {
    			return addr
    		}
    		return &TCPAddr{IP: ip, Port: addr.Port, Zone: addr.Zone}
    	case *UDPAddr:
    		ip := convertIP(addr.IP)
    		if ip == nil || len(ip) == len(addr.IP) {
    			return addr
    		}
    		return &UDPAddr{IP: ip, Port: addr.Port, Zone: addr.Zone}
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 19:24:21 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  6. src/net/fd_plan9.go

    	listen, ctl, data *os.File
    	laddr, raddr      Addr
    	isStream          bool
    }
    
    var netdir = "/net" // default network
    
    func newFD(net, name string, listen, ctl, data *os.File, laddr, raddr Addr) (*netFD, error) {
    	ret := &netFD{
    		net:    net,
    		n:      name,
    		dir:    netdir + "/" + net + "/" + name,
    		listen: listen,
    		ctl:    ctl, data: data,
    		laddr: laddr,
    		raddr: raddr,
    	}
    	ret.pfd.Destroy = ret.destroy
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 04 16:01:50 UTC 2018
    - 3.6K bytes
    - Viewed (0)
  7. src/net/ipsock_posix.go

    		if laddr == nil {
    			return syscall.AF_INET, false
    		}
    		return laddr.family(), false
    	}
    
    	if (laddr == nil || laddr.family() == syscall.AF_INET) &&
    		(raddr == nil || raddr.family() == syscall.AF_INET) {
    		return syscall.AF_INET, false
    	}
    	return syscall.AF_INET6, false
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  8. src/net/tcpsock.go

    	}
    	if raddr == nil {
    		return nil, &OpError{Op: "dial", Net: network, Source: laddr.opAddr(), Addr: nil, Err: errMissingAddress}
    	}
    	sd := &sysDialer{network: network, address: raddr.String()}
    	c, err := sd.dialTCP(context.Background(), laddr, raddr)
    	if err != nil {
    		return nil, &OpError{Op: "dial", Net: network, Source: laddr.opAddr(), Addr: raddr.opAddr(), Err: err}
    	}
    	return c, nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  9. src/net/mptcpsock_stub.go

    //go:build !linux
    
    package net
    
    import (
    	"context"
    )
    
    func (sd *sysDialer) dialMPTCP(ctx context.Context, laddr, raddr *TCPAddr) (*TCPConn, error) {
    	return sd.dialTCP(ctx, laddr, raddr)
    }
    
    func (sl *sysListener) listenMPTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) {
    	return sl.listenTCP(ctx, laddr)
    }
    
    func isUsingMultipathTCP(fd *netFD) bool {
    	return false
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 18 13:48:22 UTC 2023
    - 542 bytes
    - Viewed (0)
  10. src/net/fd_posix.go

    	// immutable until Close
    	family      int
    	sotype      int
    	isConnected bool // handshake completed or use of association with peer
    	net         string
    	laddr       Addr
    	raddr       Addr
    }
    
    func (fd *netFD) setAddr(laddr, raddr Addr) {
    	fd.laddr = laddr
    	fd.raddr = raddr
    	runtime.SetFinalizer(fd, (*netFD).Close)
    }
    
    func (fd *netFD) Close() error {
    	runtime.SetFinalizer(fd, nil)
    	return fd.pfd.Close()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 29 16:24:51 UTC 2022
    - 4.3K bytes
    - Viewed (0)
Back to top