Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 24 of 24 for copyBuffer (0.3 sec)

  1. 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)
  2. 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)
  3. platforms/core-runtime/files/src/main/java/org/gradle/internal/file/ThreadLocalBufferProvider.java

        private final ThreadLocal<byte[]> copyBuffers;
    
        public ThreadLocalBufferProvider(final int bufferSize) {
            this.copyBuffers = new ThreadLocal<byte[]>() {
                @Override
                protected byte[] initialValue() {
                    return new byte[bufferSize];
                }
            };
        }
    
        @Override
        public byte[] getBuffer() {
            return copyBuffers.get();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:55:52 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"(*SectionReader).Size", Method, 0},
    		{"ByteReader", Type, 0},
    		{"ByteScanner", Type, 0},
    		{"ByteWriter", Type, 1},
    		{"Closer", Type, 0},
    		{"Copy", Func, 0},
    		{"CopyBuffer", Func, 5},
    		{"CopyN", Func, 0},
    		{"Discard", Var, 16},
    		{"EOF", Var, 0},
    		{"ErrClosedPipe", Var, 0},
    		{"ErrNoProgress", Var, 1},
    		{"ErrShortBuffer", Var, 0},
    		{"ErrShortWrite", Var, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
Back to top