Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for copyBuffer (0.21 sec)

  1. src/crypto/tls/tls_test.go

    			srv := Server(sconn, serverConfig)
    			if err := srv.Handshake(); err != nil {
    				panic(fmt.Errorf("handshake: %v", err))
    			}
    			if _, err := io.CopyBuffer(srv, srv, buf); err != nil {
    				panic(fmt.Errorf("copy buffer: %v", err))
    			}
    		}
    	}()
    
    	b.SetBytes(totalBytes)
    	clientConfig := testConfig.Clone()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 60.5K bytes
    - Viewed (0)
  2. src/net/http/httputil/reverseproxy_test.go

    	defer frontendProxy.Close()
    
    	if _, err = frontendProxy.Client().Get(frontendProxy.URL); err == nil {
    		t.Fatalf("want non-nil error")
    	}
    	// The race detector complains about the proxyLog usage in logf in copyBuffer
    	// and our usage below with proxyLog.Bytes() so we're explicitly using a
    	// channel to ensure that the ReverseProxy's ServeHTTP is done before we
    	// continue after Get.
    	<-donec
    
    	expected := []string{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 54.6K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		defer xioutil.ODirectPoolLarge.Put(bufp)
    	}
    
    	var written int64
    	if odirectEnabled {
    		written, err = xioutil.CopyAligned(diskHealthWriter(ctx, w), r, *bufp, fileSize, w)
    	} else {
    		written, err = io.CopyBuffer(diskHealthWriter(ctx, w), r, *bufp)
    	}
    	if err != nil {
    		w.Close()
    		return err
    	}
    
    	if written < fileSize && fileSize >= 0 {
    		w.Close()
    		return errLessData
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
Back to top