Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 50 for readFully (0.04 sec)

  1. src/archive/tar/reader_test.go

    					t.Fatalf("entry %d, Next(): got %v, want %v", i, err, nil)
    				}
    				buf := make([]byte, tc.cnt)
    				if _, err := io.ReadFull(tr, buf); err != nil {
    					t.Fatalf("entry %d, ReadFull(): got %v, want %v", i, err, nil)
    				}
    				if string(buf) != tc.output {
    					t.Fatalf("entry %d, ReadFull(): got %q, want %q", i, string(buf), tc.output)
    				}
    			}
    
    			if _, err := tr.Next(); err != io.EOF {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Dec 15 16:34:13 UTC 2025
    - 47.5K bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. src/archive/zip/zip_test.go

    	if err != nil {
    		t.Fatal("opening:", err)
    	}
    	rc.(*checksumReader).hash = fakeHash32{}
    	for i := 0; i < chunks; i++ {
    		_, err := io.ReadFull(rc, chunk)
    		if err != nil {
    			t.Fatal("read:", err)
    		}
    	}
    	if frag := int(size % chunkSize); frag > 0 {
    		_, err := io.ReadFull(rc, chunk[:frag])
    		if err != nil {
    			t.Fatal("read:", err)
    		}
    	}
    	gotEnd, err := io.ReadAll(rc)
    	if err != nil {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. cmd/erasure-encode_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	if !s.IsValid(w, r) {
    		return
    	}
    	volume := r.Form.Get(storageRESTVolume)
    	filePath := r.Form.Get(storageRESTFilePath)
    
    	buf := make([]byte, r.ContentLength)
    	_, err := io.ReadFull(r.Body, buf)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	err = s.getStorage().AppendFile(r.Context(), volume, filePath, buf)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    	}
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  6. internal/ioutil/ioutil.go

    	var written int64
    	for {
    		buf := alignedBuf
    		if totalSize > 0 {
    			remaining := totalSize - written
    			if remaining < int64(len(buf)) {
    				buf = buf[:remaining]
    			}
    		}
    
    		nr, err := io.ReadFull(r, buf)
    		eof := errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF)
    		if err != nil && !eof {
    			return written, err
    		}
    
    		buf = buf[:nr]
    		var (
    			n  int
    			un int
    			nw int64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  7. cmd/metacache-stream.go

    		sz, err := r.mr.ReadStringHeader()
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if cap(tmp) < int(sz) {
    			tmp = make([]byte, 0, sz+256)
    		}
    		tmp = tmp[:sz]
    		_, err = r.mr.R.ReadFull(tmp)
    		if err != nil {
    			r.err = err
    			return err
    		}
    		if string(tmp) >= s {
    			r.current.name = string(tmp)
    			r.current.metadata, r.err = r.mr.ReadBytes(nil)
    			return r.err
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  8. cmd/erasure-decode_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		disks := setup.disks
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(crand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    
    		writeAlgorithm := test.algorithm
    		if !test.algorithm.Available() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2.go

    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    	_, err := io.ReadFull(r, buf)
    	if err != nil {
    		return nil, fmt.Errorf("readXLMetaNoData(io.ReadFull): %w", err)
    	}
    	readMore := func(n int64) error {
    		has := int64(len(buf))
    		if has >= n {
    			return nil
    		}
    		if hasFull || n > size {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  10. cmd/storage-rest-client.go

    		values.Set(storageRESTBitrotHash, "")
    	}
    	respBody, err := client.callGet(ctx, storageRESTMethodReadFile, values, nil, -1)
    	if err != nil {
    		return 0, err
    	}
    	defer xhttp.DrainBody(respBody)
    	n, err := io.ReadFull(respBody, buf)
    	return int64(n), toStorageErr(err)
    }
    
    // ListDir - lists a directory.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
Back to top