Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 440 for readFull (0.3 sec)

  1. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 29 19:14:09 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  2. src/go/internal/gcimporter/iimport.go

    		return
    	}
    
    	v := -n
    	if signed {
    		v = -(n &^ 1) >> 1
    	}
    	if v < 1 || uint(v) > maxBytes {
    		errorf("weird decoding: %v, %v => %v", n, signed, v)
    	}
    	b := make([]byte, v)
    	io.ReadFull(&r.declReader, b)
    	x.SetBytes(b)
    	if signed && n&1 != 0 {
    		x.Neg(x)
    	}
    }
    
    func (r *importReader) mpfloat(typ *types.Basic) constant.Value {
    	var mant big.Int
    	r.mpint(&mant, typ)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  3. src/encoding/gob/debug.go

    func (p *peekReader) peek(b []byte) (n int, err error) {
    	if len(p.data) > 0 {
    		n = copy(b, p.data)
    		if n == len(b) {
    			return
    		}
    		b = b[n:]
    	}
    	if len(b) == 0 {
    		return
    	}
    	m, e := io.ReadFull(p.r, b)
    	if m > 0 {
    		p.data = append(p.data, b[:m]...)
    	}
    	n += m
    	if e == io.ErrUnexpectedEOF {
    		// That means m > 0 but we reached EOF. If we got data
    		// we won't complain about not being able to peek enough.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jan 20 09:34:41 UTC 2023
    - 18.3K bytes
    - Viewed (0)
  4. src/os/readfrom_linux_test.go

    // mustContainData ensures that the specified file contains exactly the
    // specified data.
    func mustContainData(t *testing.T, f *File, data []byte) {
    	t.Helper()
    
    	got := make([]byte, len(data))
    	if _, err := io.ReadFull(f, got); err != nil {
    		t.Fatal(err)
    	}
    	if !bytes.Equal(got, data) {
    		t.Fatalf("didn't get the same data back from %s", f.Name())
    	}
    	if _, err := f.Read(make([]byte, 1)); err != io.EOF {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  5. src/encoding/gob/decode.go

    	width = 1
    	n, err := io.ReadFull(r, buf[0:width])
    	if n == 0 {
    		return
    	}
    	b := buf[0]
    	if b <= 0x7f {
    		return uint64(b), width, nil
    	}
    	n = -int(int8(b))
    	if n > uint64Size {
    		err = errBadUint
    		return
    	}
    	width, err = io.ReadFull(r, buf[0:n])
    	if err != nil {
    		if err == io.EOF {
    			err = io.ErrUnexpectedEOF
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 07 19:10:23 UTC 2023
    - 40.1K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    	}
    	defer xhttp.DrainBody(respBody)
    
    	dec := msgpNewReader(respBody)
    	defer readMsgpReaderPoolPut(dec)
    
    	err = rf.DecodeMsg(dec)
    	return rf, err
    }
    
    // ReadAll - reads all contents of a file.
    func (client *storageRESTClient) ReadAll(ctx context.Context, volume string, path string) ([]byte, error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    		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.
    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/aes_test.go

    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			dataCtx := value.DefaultContext("/foo/bar")
    			for _, l := range lengths {
    				data := make([]byte, l)
    				if _, err := io.ReadFull(rand.Reader, data); err != nil {
    					t.Fatalf("unable to read sufficient random bytes: %v", err)
    				}
    				original := append([]byte{}, data...)
    
    				ciphertext, err := tt.t.TransformToStorage(ctx, data, dataCtx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 19:25:52 UTC 2023
    - 23.2K bytes
    - Viewed (0)
  9. src/debug/macho/file.go

    			dlen := binary.BigEndian.Uint64(b[4:12])
    			dbuf := make([]byte, dlen)
    			r, err := zlib.NewReader(bytes.NewBuffer(b[12:]))
    			if err != nil {
    				return nil, err
    			}
    			if _, err := io.ReadFull(r, dbuf); err != nil {
    				return nil, err
    			}
    			if err := r.Close(); err != nil {
    				return nil, err
    			}
    			b = dbuf
    		}
    		return b, nil
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 18 19:33:30 UTC 2023
    - 17.9K bytes
    - Viewed (0)
  10. src/crypto/tls/handshake_server.go

    		if c.vers == VersionTLS12 {
    			copy(serverRandom[24:], downgradeCanaryTLS12)
    		} else {
    			copy(serverRandom[24:], downgradeCanaryTLS11)
    		}
    		serverRandom = serverRandom[:24]
    	}
    	_, err := io.ReadFull(c.config.rand(), serverRandom)
    	if err != nil {
    		c.sendAlert(alertInternalError)
    		return err
    	}
    
    	if len(hs.clientHello.secureRenegotiation) != 0 {
    		c.sendAlert(alertHandshakeFailure)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:30:50 UTC 2024
    - 27.6K bytes
    - Viewed (0)
Back to top