Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 51 for tcpNone (0.15 sec)

  1. src/net/http/server.go

    }
    
    // ReadFrom is here to optimize copying from an [*os.File] regular file
    // to a [*net.TCPConn] with sendfile, or from a supported src type such
    // as a *net.TCPConn on Linux with splice.
    func (w *response) ReadFrom(src io.Reader) (n int64, err error) {
    	buf := getCopyBuf()
    	defer putCopyBuf(buf)
    
    	// Our underlying w.conn.rwc is usually a *TCPConn (with its
    	// own ReadFrom method). If not, just fall back to the normal
    	// copy method.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  2. src/net/rpc/server_test.go

    	// If the code is correct, this test will never fail, regardless of timeout.
    	args.A = 10 // 10 ms
    	done := make(chan *Call, 1)
    	call := client.Go("Arith.SleepMilli", args, reply, done)
    	c.(*net.TCPConn).CloseWrite()
    	<-done
    	if call.Error != nil {
    		t.Fatal(err)
    	}
    }
    
    func benchmarkEndToEnd(dial func() (*Client, error), b *testing.B) {
    	once.Do(startServer)
    	client, err := dial()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 18 05:23:29 UTC 2023
    - 19K bytes
    - Viewed (0)
  3. src/crypto/tls/handshake_client_test.go

    	// opening the listening socket, so we can't use that to wait until it
    	// has started listening. Thus we are forced to poll until we get a
    	// connection.
    	var tcpConn net.Conn
    	for i := uint(0); i < 5; i++ {
    		tcpConn, err = net.DialTCP("tcp", nil, &net.TCPAddr{
    			IP:   net.IPv4(127, 0, 0, 1),
    			Port: serverPort,
    		})
    		if err == nil {
    			break
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/test/test.go

    // was resolved before the other one was processed, the second one
    // would never be resolved.
    // Before this issue was fixed this test failed on Windows,
    // where va_list expands to a named char* type.
    typedef va_list TypeOne;
    typedef char *TypeTwo;
    
    // issue 28540
    
    static void twoargs1(void *p, int n) {}
    static void *twoargs2() { return 0; }
    static int twoargs3(void * p) { return 0; }
    
    // issue 28545
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 15:50:06 UTC 2024
    - 48.5K bytes
    - Viewed (0)
  5. src/net/http/transport_test.go

    					conn, err := d.DialContext(ctx, network, addr)
    					if err != nil {
    						return nil, err
    					}
    
    					tcpConn, ok := conn.(*net.TCPConn)
    					if !ok {
    						return nil, fmt.Errorf("%s/%s does not provide a *net.TCPConn", network, addr)
    					}
    
    					tConn.TCPConn = tcpConn
    					return tConn, nil
    				}
    			}
    
    			cst := newClientServerTest(
    				t,
    				mode,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  6. src/net/dial.go

    }
    
    // sysDialer contains a Dial's parameters and configuration.
    type sysDialer struct {
    	Dialer
    	network, address string
    	testHookDialTCP  func(ctx context.Context, net string, laddr, raddr *TCPAddr) (*TCPConn, error)
    }
    
    // Dial connects to the address on the named network.
    //
    // See func Dial for a description of the network and address
    // parameters.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  7. api/go1.21.txt

    pkg net, method (*Dialer) SetMultipathTCP(bool) #56539
    pkg net, method (*ListenConfig) MultipathTCP() bool #56539
    pkg net, method (*ListenConfig) SetMultipathTCP(bool) #56539
    pkg net, method (*TCPConn) MultipathTCP() (bool, error) #59166
    pkg reflect, method (Value) Clear() #55002
    pkg reflect, type SliceHeader //deprecated #56906
    pkg reflect, type StringHeader //deprecated #56906
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Aug 07 09:39:17 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

    }
    
    type wrappedListener struct {
    	net.Listener
    	t *testing.T
    }
    
    func (ln wrappedListener) Accept() (net.Conn, error) {
    	c, err := ln.Listener.Accept()
    
    	if tc, ok := c.(*net.TCPConn); ok {
    		ln.t.Logf("[server] seen new connection: %#v", tc)
    	}
    	return c, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  9. src/net/http/serve_test.go

    			if err != nil {
    				t.Errorf("Hijack in Handler: %v", err)
    				return
    			}
    			if _, ok := c.(*net.TCPConn); !ok {
    				// Verify it's not wrapped in some type.
    				// Not strictly a go1 compat issue, but in practice it probably is.
    				t.Errorf("type of hijacked conn is %T; want *net.TCPConn", c)
    			}
    			fmt.Fprintf(c, "HTTP/1.0 200 OK\r\nX-Addr: %v\r\nContent-Length: 0\r\n\r\n", r.RemoteAddr)
    			c.Close()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  10. api/go1.txt

    pkg net, method (*TCPConn) Close() error
    pkg net, method (*TCPConn) CloseRead() error
    pkg net, method (*TCPConn) CloseWrite() error
    pkg net, method (*TCPConn) File() (*os.File, error)
    pkg net, method (*TCPConn) LocalAddr() Addr
    pkg net, method (*TCPConn) Read([]uint8) (int, error)
    pkg net, method (*TCPConn) ReadFrom(io.Reader) (int64, error)
    pkg net, method (*TCPConn) RemoteAddr() Addr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top