Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for startWrite (0.1 sec)

  1. src/crypto/tls/handshake_client_test.go

    				panic(err)
    			}
    
    			server.Write(request[:])
    			server.Close()
    		}()
    
    		startWrite := make(chan struct{})
    		startRead := make(chan struct{})
    		readDone := make(chan struct{}, 1)
    
    		client := Client(c, testConfig)
    		go func() {
    			<-startWrite
    			var request [1]byte
    			client.Write(request[:])
    		}()
    
    		go func() {
    			<-startRead
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  2. src/net/http/h2_bundle.go

    }
    
    func (fr *http2Framer) maxHeaderListSize() uint32 {
    	if fr.MaxHeaderListSize == 0 {
    		return 16 << 20 // sane default, per docs
    	}
    	return fr.MaxHeaderListSize
    }
    
    func (f *http2Framer) startWrite(ftype http2FrameType, flags http2Flags, streamID uint32) {
    	// Write the FrameHeader.
    	f.wbuf = append(f.wbuf[:0],
    		0, // 3 bytes of length, filled in in endWrite
    		0,
    		0,
    		byte(ftype),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  3. src/net/http/responsecontroller_test.go

    	errc := make(chan error, 1)
    	startwritec := make(chan struct{})
    	cst := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
    		ctl := NewResponseController(w)
    		w.WriteHeader(200)
    		if err := ctl.Flush(); err != nil {
    			t.Errorf("ctl.Flush() = %v, want nil", err)
    		}
    		<-startwritec // don't set the deadline until the client reads response headers
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 06 19:20:31 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top