Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for PacketConn (0.17 sec)

  1. pkg/dns/client/proxy.go

    		}
    	}
    }
    
    func (p *dnsProxy) Address() string {
    	if p.server != nil {
    		if p.server.Listener != nil {
    			return p.server.Listener.Addr().String()
    		}
    		if p.server.PacketConn != nil {
    			return p.server.PacketConn.LocalAddr().String()
    		}
    	}
    	return ""
    }
    
    func (p *dnsProxy) ServeDNS(w dns.ResponseWriter, req *dns.Msg) {
    	p.resolver.ServeDNS(p, w, req)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jul 19 02:12:19 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  2. 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)
  3. test/fixedbugs/issue7405.go

    type T1 struct {
    	T2
    	T3
    	T4
    }
    
    type T2 struct {
    	Conn
    }
    
    type T3 struct {
    	PacketConn
    }
    
    type T4 struct {
    	PacketConn
    	T5
    }
    
    type T5 struct {
    	x int
    	T6
    }
    
    type T6 struct {
    	y, z int
    }
    
    type Conn interface {
    	A()
    }
    
    type PacketConn interface {
    	B()
    }
    
    func F(a, b T1) bool {
    	return a == b
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 20 21:22:37 UTC 2014
    - 638 bytes
    - Viewed (0)
  4. src/net/packetconn_test.go

    		return nil, func() { t.Logf("skipping %s test", network) }
    	}
    	return []byte("PACKETCONN TEST"), nil
    }
    
    func TestPacketConn(t *testing.T) {
    	var packetConnTests = []struct {
    		net   string
    		addr1 string
    		addr2 string
    	}{
    		{"udp", "127.0.0.1:0", "127.0.0.1:0"},
    		{"unixgram", testUnixAddr(t), testUnixAddr(t)},
    	}
    
    	closer := func(c PacketConn, net, addr1, addr2 string) {
    		c.Close()
    		switch net {
    		case "unixgram":
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 3K bytes
    - Viewed (0)
  5. src/net/server_test.go

    				t.Fatal(err)
    			}
    
    			ls := (&packetListener{PacketConn: c1}).newLocalServer()
    			defer ls.teardown()
    			tpch := make(chan error, 1)
    			handler := func(ls *localPacketServer, c PacketConn) { packetTransponder(c, tpch) }
    			if err := ls.buildup(handler); err != nil {
    				t.Fatal(err)
    			}
    
    			trch := make(chan error, 1)
    			_, port, err := SplitHostPort(ls.PacketConn.LocalAddr().String())
    			if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  6. src/net/file_windows.go

    	// TODO: Implement this
    	return nil, syscall.EWINDOWS
    }
    
    func fileListener(f *os.File) (Listener, error) {
    	// TODO: Implement this
    	return nil, syscall.EWINDOWS
    }
    
    func filePacketConn(f *os.File) (PacketConn, error) {
    	// TODO: Implement this
    	return nil, syscall.EWINDOWS
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 02 16:11:03 UTC 2015
    - 521 bytes
    - Viewed (0)
  7. src/net/file_stub.go

    	"syscall"
    )
    
    func fileConn(f *os.File) (Conn, error)             { return nil, syscall.ENOPROTOOPT }
    func fileListener(f *os.File) (Listener, error)     { return nil, syscall.ENOPROTOOPT }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 481 bytes
    - Viewed (0)
  8. pilot/pkg/model/network_test.go

    	failingDNSServer.setFailure(true)
    	model.NetworkGatewayTestDNSServers = []string{
    		// try resolving with the failing server first to make sure the next upstream is retried
    		failingDNSServer.Server.PacketConn.LocalAddr().String(),
    		workingDNSServer.Server.PacketConn.LocalAddr().String(),
    	}
    	t.Cleanup(func() {
    		errW := workingDNSServer.Shutdown()
    		errF := failingDNSServer.Shutdown()
    		if errW != nil || errF != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 16 01:18:03 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  9. pkg/test/echo/server/endpoint/udp.go

    var _ Instance = &udpInstance{}
    
    type udpInstance struct {
    	Config
    	l net.PacketConn
    }
    
    func newUDP(config Config) Instance {
    	return &udpInstance{
    		Config: config,
    	}
    }
    
    func (s *udpInstance) GetConfig() Config {
    	return s.Config
    }
    
    func (s *udpInstance) Start(onReady OnReadyFunc) error {
    	var listener net.PacketConn
    	var port int
    	var err error
    	if s.Port.TLS {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 16:20:31 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  10. src/net/iprawsock.go

    	if err != nil {
    		return nil, err
    	}
    	return addrs.forResolve(network, address).(*IPAddr), nil
    }
    
    // IPConn is the implementation of the [Conn] and [PacketConn] interfaces
    // for IP network connections.
    type IPConn 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: Wed Jan 10 03:29:50 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top