Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for PacketConn (0.22 sec)

  1. src/net/mockserver_test.go

    	pcmu sync.RWMutex
    	PacketConn
    	done chan bool // signal that indicates server stopped
    }
    
    func (ls *localPacketServer) buildup(handler func(*localPacketServer, PacketConn)) error {
    	go func() {
    		handler(ls, ls.PacketConn)
    		close(ls.done)
    	}()
    	return nil
    }
    
    func (ls *localPacketServer) teardown() error {
    	ls.pcmu.Lock()
    	if ls.PacketConn != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/dns/client/dns_test.go

    	case <-up:
    	}
    	t.Cleanup(func() { _ = server.Shutdown() })
    	server.Addr = server.PacketConn.LocalAddr().String()
    
    	select {
    	case <-time.After(time.Second * 10):
    		t.Fatalf("setup timeout")
    	case <-up:
    	}
    	t.Cleanup(func() { _ = tcp.Shutdown() })
    	t.Cleanup(func() { _ = server.Shutdown() })
    	tcp.Addr = server.PacketConn.LocalAddr().String()
    	return server.Addr
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 16:17:34 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. src/net/net.go

    	if err != nil {
    		err = &OpError{Op: "file", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err}
    	}
    	return
    }
    
    // PacketConn is a generic packet-oriented network connection.
    //
    // Multiple goroutines may invoke methods on a PacketConn simultaneously.
    type PacketConn interface {
    	// ReadFrom reads a packet from the connection,
    	// copying the payload into p. It returns the number of
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. src/vendor/golang.org/x/net/nettest/nettest.go

    // loopback IP address or local file system path.
    //
    // The provided network must be "udp", "udp4", "udp6" or "unixgram".
    func NewLocalPacketListener(network string) (net.PacketConn, error) {
    	stackOnce.Do(probeStack)
    	switch network {
    	case "udp":
    		if canListenTCP4OnLoopback {
    			if c, err := net.ListenPacket("udp4", "127.0.0.1:0"); err == nil {
    				return c, nil
    			}
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. src/net/dnsclient_unix.go

    			return dnsmessage.Parser{}, dnsmessage.Header{}, err
    		}
    		if d, ok := ctx.Deadline(); ok && !d.IsZero() {
    			c.SetDeadline(d)
    		}
    		var p dnsmessage.Parser
    		var h dnsmessage.Header
    		if _, ok := c.(PacketConn); ok {
    			p, h, err = dnsPacketRoundTrip(c, id, q, udpReq)
    		} else {
    			p, h, err = dnsStreamRoundTrip(c, id, q, tcpReq)
    		}
    		c.Close()
    		if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  9. src/net/lookup.go

    	// always be a literal IP address and not a host name, and the
    	// port in the address parameter will be a literal port number
    	// and not a service name.
    	// If the Conn returned is also a PacketConn, sent and received DNS
    	// messages must adhere to RFC 1035 section 4.2.1, "UDP usage".
    	// Otherwise, DNS messages transmitted over Conn must adhere
    	// to RFC 7766 section 5, "Transport Protocol Selection".
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  10. src/net/dnsclient_unix_test.go

    	}
    	return len(b), nil
    }
    
    func (f *fakeDNSConn) SetDeadline(t time.Time) error {
    	f.t = t
    	return nil
    }
    
    type fakeDNSPacketConn struct {
    	PacketConn
    	fakeDNSConn
    }
    
    func (f *fakeDNSPacketConn) SetDeadline(t time.Time) error {
    	return f.fakeDNSConn.SetDeadline(t)
    }
    
    func (f *fakeDNSPacketConn) Close() error {
    	return f.fakeDNSConn.Close()
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 72.4K bytes
    - Viewed (0)
Back to top