Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,286 for GetWork (0.17 sec)

  1. src/net/error_test.go

    	for _, network := range []string{"tcp", "udp", "ip:4294967296", "unix", "unixpacket", "unixgram"} {
    		var err error
    		switch network {
    		case "tcp":
    			_, err = ListenTCP(network, &TCPAddr{Port: 1 << 16})
    		case "udp":
    			_, err = ListenUDP(network, &UDPAddr{Port: 1 << 16})
    		case "ip:4294967296":
    			_, err = ListenIP(network, nil)
    		case "unix", "unixpacket":
    			_, err = ListenUnix(network, &UnixAddr{Name: "//"})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  2. pkg/config/xds/filter_types.gen.go

    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/generic_proxy/matcher/v3"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/generic_proxy/router/v3"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/generic_proxy/v3"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/golang/v3alpha"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Jun 02 02:48:23 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

    /**
     * A concrete interceptor chain that carries the entire interceptor chain: all application
     * interceptors, the OkHttp core, all network interceptors, and finally the network caller.
     *
     * If the chain is for an application interceptor then [exchange] must be null. Otherwise it is for
     * a network interceptor and [exchange] must be non-null.
     */
    class RealInterceptorChain(
      internal val call: RealCall,
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. src/net/tcpsock.go

    //
    // See func [Dial] for a description of the network and address
    // parameters.
    func ResolveTCPAddr(network, address string) (*TCPAddr, error) {
    	switch network {
    	case "tcp", "tcp4", "tcp6":
    	case "": // a hint wildcard for Go 1.0 undocumented behavior
    		network = "tcp"
    	default:
    		return nil, UnknownNetworkError(network)
    	}
    	addrs, err := DefaultResolver.internetAddrList(context.Background(), network, address)
    	if err != 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)
  5. src/net/listen_test.go

    		}
    	default:
    		return UnknownNetworkError(network)
    	}
    	return nil
    }
    
    func checkSecondListener(network, address string, err error) error {
    	switch network {
    	case "tcp", "tcp4", "tcp6":
    		if err == nil {
    			return fmt.Errorf("%s should fail", network+" "+address)
    		}
    	case "udp", "udp4", "udp6":
    		if err == nil {
    			return fmt.Errorf("%s should fail", network+" "+address)
    		}
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. pkg/hbone/dialer.go

    func (d *dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
    	if network != "tcp" {
    		return net.Dial(network, address)
    	}
    	// TODO: use context
    	c, s := net.Pipe()
    	err := d.proxyTo(s, d.cfg, address)
    	if err != nil {
    		return nil, err
    	}
    	return c, nil
    }
    
    func (d dialer) Dial(network, address string) (c net.Conn, err error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 24 15:56:41 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  7. src/net/iprawsock_test.go

    			t.Fatal("should not fail")
    		}
    	}
    }
    
    func TestIPConnRemoteName(t *testing.T) {
    	network := "ip:tcp"
    	if !testableNetwork(network) {
    		t.Skipf("skipping %s test", network)
    	}
    
    	raddr := &IPAddr{IP: IPv4(127, 0, 0, 1).To4()}
    	c, err := DialIP(network, &IPAddr{IP: IPv4(127, 0, 0, 1)}, raddr)
    	if testenv.SyscallIsNotSupported(err) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 6K bytes
    - Viewed (0)
  8. container-tests/src/test/java/okhttp3/containers/SocksProxyTest.kt

    import org.testcontainers.containers.MockServerContainer
    import org.testcontainers.containers.Network
    import org.testcontainers.junit.jupiter.Container
    import org.testcontainers.junit.jupiter.Testcontainers
    import org.testcontainers.utility.DockerImageName
    
    @Testcontainers
    class SocksProxyTest {
      val network: Network = Network.newNetwork()
    
      @Container
      val mockServer: MockServerContainer =
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. pkg/config/analysis/analyzers/envoyfilter/envoyfilter.go

    		}
    
    		// check each operation type
    		if patch.Patch.Operation == network.EnvoyFilter_Patch_ADD {
    			// the ADD operation is an absolute operation but provide a warning
    			// indicating that the operation will be ignored when applyTo is set to ROUTE_CONFIGURATION,
    			// or HTTP_ROUTE
    			if patch.ApplyTo == network.EnvoyFilter_ROUTE_CONFIGURATION || patch.ApplyTo == network.EnvoyFilter_HTTP_ROUTE {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 16:43:05 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  10. pkg/registry/core/rangeallocation/OWNERS

    # See the OWNERS docs at https://go.k8s.io/owners
    
    approvers:
      - sig-network-approvers
    reviewers:
      - sig-network-reviewers
    labels:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 01:20:16 UTC 2023
    - 149 bytes
    - Viewed (0)
Back to top