Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for PacketConn (0.23 sec)

  1. pkg/test/echo/server/endpoint/util.go

    	_ = os.Remove(uds)
    	ln, err := net.Listen("unix", uds)
    	if err != nil {
    		return nil, err
    	}
    
    	return ln, nil
    }
    
    func listenUDPAddress(ip string, port int) (net.PacketConn, int, error) {
    	parsedIP := net.ParseIP(ip)
    	ipBind := "udp"
    	if parsedIP != nil {
    		if parsedIP.To4() == nil && parsedIP.To16() != nil {
    			ipBind = "udp6"
    		} else if parsedIP.To4() != nil {
    			ipBind = "udp4"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  2. src/net/file_wasip1.go

    	}
    	pfd := f.PollFD().Copy()
    	fd := newPollFD(net, pfd)
    	if err := fd.init(); err != nil {
    		pfd.Close()
    		return nil, err
    	}
    	return newFileConn(fd), nil
    }
    
    func filePacketConn(f *os.File) (PacketConn, error) {
    	return nil, syscall.ENOPROTOOPT
    }
    
    func fileListenNet(filetype syscall.Filetype) (string, error) {
    	switch filetype {
    	case syscall.FILETYPE_SOCKET_STREAM:
    		return "tcp", nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 12 23:11:39 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  3. src/net/file.go

    // corresponding to the open file f.
    // It is the caller's responsibility to close f when finished.
    // Closing c does not affect f, and closing f does not affect c.
    func FilePacketConn(f *os.File) (c PacketConn, err error) {
    	c, err = filePacketConn(f)
    	if err != nil {
    		err = &OpError{Op: "file", Net: "file+net", Source: nil, Addr: fileAddr(f.Name()), Err: err}
    	}
    	return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 09 06:14:44 UTC 2019
    - 1.7K bytes
    - Viewed (0)
  4. src/net/file_unix.go

    		return &TCPListener{fd: fd}, nil
    	case *UnixAddr:
    		return &UnixListener{fd: fd, path: laddr.Name, unlink: false}, nil
    	}
    	fd.Close()
    	return nil, syscall.EINVAL
    }
    
    func filePacketConn(f *os.File) (PacketConn, error) {
    	fd, err := newFileFD(f)
    	if err != nil {
    		return nil, err
    	}
    	switch fd.laddr.(type) {
    	case *UDPAddr:
    		return newUDPConn(fd), nil
    	case *IPAddr:
    		return newIPConn(fd), nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. src/net/udpsock_test.go

    			// suitable address" error on some platforms.
    			t.Log(err)
    			continue
    		}
    		ls := (&packetListener{PacketConn: c1}).newLocalServer()
    		defer ls.teardown()
    		ch := make(chan error, 1)
    		handler := func(ls *localPacketServer, c PacketConn) { packetTransponder(c, ch) }
    		if err := ls.buildup(handler); err != nil {
    			t.Fatal(err)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 17.2K bytes
    - Viewed (0)
  6. src/net/udpsock.go

    type addrPortUDPAddr struct {
    	netip.AddrPort
    }
    
    func (addrPortUDPAddr) Network() string { return "udp" }
    
    // UDPConn is the implementation of the Conn and PacketConn interfaces
    // for UDP network connections.
    type UDPConn struct {
    	conn
    }
    
    // SyscallConn returns a raw network connection.
    // This implements the syscall.Conn interface.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 16:58:25 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  7. src/net/file_plan9.go

    	if err != nil {
    		return nil, err
    	}
    	if s != "Listen" {
    		return nil, errors.New("file does not represent a listener")
    	}
    
    	return &TCPListener{fd: fd}, nil
    }
    
    func filePacketConn(f *os.File) (PacketConn, error) {
    	return nil, syscall.EPLAN9
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. src/net/unixsock.go

    	}
    	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}
    	}
    	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 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. src/net/dial.go

    	addrs, err := DefaultResolver.resolveAddrList(ctx, "listen", network, address, nil)
    	if err != nil {
    		return nil, &OpError{Op: "listen", Net: network, Source: nil, Addr: nil, Err: err}
    	}
    	sl := &sysListener{
    		ListenConfig: *lc,
    		network:      network,
    		address:      address,
    	}
    	var c PacketConn
    	la := addrs.first(isIPv4)
    	switch la := la.(type) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  10. src/net/timeout_test.go

    	defer close(ch)
    	handler := func(ls *localPacketServer, c PacketConn) {
    		if dst, ok := <-ch; ok {
    			c.WriteTo([]byte("READFROM TIMEOUT TEST"), dst)
    		}
    	}
    	ls := newLocalPacketServer(t, "udp")
    	defer ls.teardown()
    	if err := ls.buildup(handler); err != nil {
    		t.Fatal(err)
    	}
    
    	host, _, err := SplitHostPort(ls.PacketConn.LocalAddr().String())
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 18:06:55 UTC 2024
    - 30K bytes
    - Viewed (0)
Back to top