Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for CopyBuffer (0.06 sec)

  1. cmd/object-api-utils_test.go

    			r, idxCB := newS2CompressReader(bytes.NewReader(tt.data), int64(len(tt.data)), false)
    			defer r.Close()
    
    			var rdrBuf bytes.Buffer
    			_, err := io.CopyBuffer(&rdrBuf, r, buf)
    			if err != nil {
    				t.Fatal(err)
    			}
    			r.Close()
    			idx := idxCB()
    			if !tt.wantIdx && len(idx) > 0 {
    				t.Errorf("index returned above threshold")
    			}
    			if tt.wantIdx {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil.go

    func Copy(dst io.Writer, src io.Reader) (written int64, err error) {
    	bufp := ODirectPoolMedium.Get().(*[]byte)
    	defer ODirectPoolMedium.Put(bufp)
    	buf := *bufp
    
    	return io.CopyBuffer(writerOnly{dst}, src, buf)
    }
    
    // SameFile returns if the files are same.
    func SameFile(fi1, fi2 os.FileInfo) bool {
    	if !os.SameFile(fi1, fi2) {
    		return false
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    		if err != nil {
    			return err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch tmp[0] {
    		case 0:
    			// 0 is unbuffered, copy the rest.
    			_, err := io.CopyBuffer(w, respBody, buf)
    			if err == io.EOF {
    				return nil
    			}
    			return err
    		case 1:
    			errorText, err := io.ReadAll(respBody)
    			if err != nil {
    				return err
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  4. src/archive/tar/reader_test.go

    						err = nil // Expected error
    					}
    					break
    				}
    				hdrs = append(hdrs, hdr)
    
    				if v.chksums == nil {
    					continue
    				}
    				h := crc32.NewIEEE()
    				_, err = io.CopyBuffer(h, tr, rdbuf) // Effectively an incremental read
    				if err != nil {
    					break
    				}
    				chksums = append(chksums, fmt.Sprintf("%x", h.Sum(nil)))
    			}
    
    			for i, hdr := range hdrs {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  5. api/go1.5.txt

    pkg image/gif, const DisposalPrevious ideal-int
    pkg image/gif, type GIF struct, BackgroundIndex uint8
    pkg image/gif, type GIF struct, Config image.Config
    pkg image/gif, type GIF struct, Disposal []uint8
    pkg io, func CopyBuffer(Writer, Reader, []uint8) (int64, error)
    pkg log, const LUTC = 32
    pkg log, const LUTC ideal-int
    pkg log, func Output(int, string) error
    pkg log, method (*Logger) SetOutput(io.Writer)
    pkg math/big, const Above = 1
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 30 21:14:09 UTC 2015
    - 46.6K bytes
    - Viewed (0)
Back to top