Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for ReadFull (0.19 sec)

  1. cmd/erasure-encode.go

    	writer := &parallelWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    		errs:        make([]error, len(writers)),
    	}
    
    	for {
    		var blocks [][]byte
    		n, err := io.ReadFull(src, buf)
    		if err != nil {
    			if !IsErrIgnored(err, []error{
    				io.EOF,
    				io.ErrUnexpectedEOF,
    			}...) {
    				return 0, err
    			}
    		}
    
    		eof := err == io.EOF || err == io.ErrUnexpectedEOF
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3K bytes
    - Viewed (0)
  2. internal/crypto/key.go

    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    		logger.CriticalIf(context.Background(), errOutOfEntropy)
    	}
    
    	const Context = "object-encryption-key generation"
    	mac := hmac.New(sha256.New, extKey)
    	mac.Write([]byte(Context))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/dummy-data-generator_test.go

    // also returned.
    func cmpReaders(r1, r2 io.Reader) (bool, string) {
    	bufLen := 32 * 1024
    	b1, b2 := make([]byte, bufLen), make([]byte, bufLen)
    	for i := 0; true; i++ {
    		n1, e1 := io.ReadFull(r1, b1)
    		n2, e2 := io.ReadFull(r2, b2)
    		if n1 != n2 {
    			return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2)
    		}
    		if !bytes.Equal(b1[:n1], b2[:n2]) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  5. internal/ioutil/read_file.go

    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    	st, err := f.Stat()
    	if err != nil {
    		return nil, nil, err
    	}
    
    	dst := make([]byte, st.Size())
    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    // ReadFile reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  6. internal/s3select/json/preader.go

    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 6.4K bytes
    - Viewed (0)
  7. cmd/streaming-v4-unsigned.go

    			return n, cr.err
    		}
    	}
    
    	if cap(cr.buffer) < size {
    		cr.buffer = make([]byte, size)
    	} else {
    		cr.buffer = cr.buffer[:size]
    	}
    
    	// Now, we read the payload.
    	_, err = io.ReadFull(cr.reader, cr.buffer)
    	if err == io.EOF && size != 0 {
    		err = io.ErrUnexpectedEOF
    	}
    	if err != nil && err != io.EOF {
    		cr.err = err
    		return n, cr.err
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat May 06 02:53:12 GMT 2023
    - 6.1K bytes
    - Viewed (1)
  8. cmd/bitrot-streaming.go

    		}
    	}
    	if offset != b.currOffset {
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	b.h.Reset()
    	_, err = io.ReadFull(b.rc, b.hashBytes)
    	if err != nil {
    		return 0, err
    	}
    	_, err = io.ReadFull(b.rc, buf)
    	if err != nil {
    		return 0, err
    	}
    	b.h.Write(buf)
    	if !bytes.Equal(b.h.Sum(nil), b.hashBytes) {
    		return 0, errFileCorrupt
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. internal/auth/credentials.go

    	}
    	if length <= 0 {
    		length = accessKeyMaxLen
    	}
    	if length < accessKeyMinLen {
    		return "", errors.New("auth: access key length is too short")
    	}
    
    	key := make([]byte, length)
    	if _, err := io.ReadFull(random, key); err != nil {
    		return "", err
    	}
    	for i := range key {
    		key[i] = alphaNumericTable[key[i]%alphaNumericTableLen]
    	}
    	return string(key), nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  10. 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)
Back to top