Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for ReadFull (0.19 sec)

  1. 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)
    	}
    }
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  2. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  3. 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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
  4. 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() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  5. src/bufio/bufio.go

    // Read reads data into p.
    // It returns the number of bytes read into p.
    // The bytes are taken from at most one Read on the underlying [Reader],
    // hence n may be less than len(p).
    // To read exactly len(p) bytes, use io.ReadFull(b, p).
    // If the underlying [Reader] can return a non-zero count with io.EOF,
    // then this Read method can do so as well; see the [io.Reader] docs.
    func (b *Reader) Read(p []byte) (n int, err error) {
    	n = len(p)
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Thu Oct 12 14:39:08 GMT 2023
    - 21.8K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    		values.Set(storageRESTBitrotHash, "")
    	}
    	respBody, err := client.call(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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  8. 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
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    	sz := stat.Size()
    	if sz <= metaDataReadDefault {
    		buf = metaDataPoolGet()
    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    // ReadAll is a raw call, reads content at any path and returns the buffer.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/encryption-v1.go

    	if int64(len(p)) < unreadPartLen {
    		n1, err = d.decrypter.Read(p)
    		if err != nil {
    			return 0, err
    		}
    		d.partDecRelOffset += int64(n1)
    	} else {
    		n1, err = io.ReadFull(d.decrypter, p[:unreadPartLen])
    		if err != nil {
    			return 0, err
    		}
    
    		// We should now proceed to next part, reset all
    		// values appropriately.
    		d.partEncRelOffset = 0
    		d.partDecRelOffset = 0
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
Back to top