Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 440 for readFull (0.32 sec)

  1. src/crypto/ecdsa/ecdsa_legacy.go

    	// signatures will come out different from other architectures, which will
    	// break TLS recorded tests.
    	for {
    		N := c.Params().N
    		b := make([]byte, (N.BitLen()+7)/8)
    		if _, err = io.ReadFull(rand, b); err != nil {
    			return
    		}
    		if excess := len(b)*8 - N.BitLen(); excess > 0 {
    			b[0] >>= excess
    		}
    		k = new(big.Int).SetBytes(b)
    		if k.Sign() != 0 && k.Cmp(N) < 0 {
    			return
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:11:18 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/aes_extended_nonce.go

    }
    
    func (e *extendedNonceGCM) sha256KDFExpandOnly(info []byte) ([]byte, error) {
    	kdf := hkdf.Expand(sha256.New, e.seed, info)
    
    	derivedKey := make([]byte, derivedKeySizeExtendedNonceGCM)
    	if _, err := io.ReadFull(kdf, derivedKey); err != nil {
    		return nil, fmt.Errorf("failed to read a derived key from KDF: %w", err)
    	}
    
    	return derivedKey, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 19:25:52 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  3. src/net/http/internal/chunked_test.go

    		t.Fatalf("chunk writer wrote %q; want %q", g, e)
    	}
    
    	r := NewChunkedReader(&b)
    	data, err := io.ReadAll(r)
    	if err != nil {
    		t.Logf(`data: "%s"`, data)
    		t.Fatalf("ReadAll from reader: %v", err)
    	}
    	if g, e := string(data), chunk1+chunk2; g != e {
    		t.Errorf("chunk reader read %q; want %q", g, e)
    	}
    }
    
    func TestChunkReadMultiple(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jan 04 20:45:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. 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: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 21 21:14:38 UTC 2022
    - 47.1K bytes
    - Viewed (0)
  5. src/io/io.go

    	return c.Reader.(WriterTo).WriteTo(w)
    }
    
    // ReadAll reads from r until an error or EOF and returns the data it read.
    // A successful call returns err == nil, not err == EOF. Because ReadAll is
    // defined to read from src until EOF, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadAll(r Reader) ([]byte, error) {
    	b := make([]byte, 0, 512)
    	for {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:34:10 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  6. src/crypto/tls/handshake_client.go

    		// we're attempting TLS 1.2.
    		if maxVersion < VersionTLS12 && suite.flags&suiteTLS12 != 0 {
    			continue
    		}
    		hello.cipherSuites = append(hello.cipherSuites, suiteId)
    	}
    
    	_, err := io.ReadFull(config.rand(), hello.random)
    	if err != nil {
    		return nil, nil, nil, errors.New("tls: short read from Rand: " + err.Error())
    	}
    
    	// A random session ID is used to detect when the server accepted a ticket
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 38.6K bytes
    - Viewed (0)
  7. cmd/bitrot.go

    		return errFileCorrupt
    	}
    
    	bufp := xioutil.ODirectPoolSmall.Get().(*[]byte)
    	defer xioutil.ODirectPoolSmall.Put(bufp)
    
    	for left > 0 {
    		// Read expected hash...
    		h.Reset()
    		n, err := io.ReadFull(r, hashBuf)
    		if err != nil {
    			// Read's failed for object with right size, file is corrupt.
    			return err
    		}
    		// Subtract hash length..
    		left -= int64(n)
    		if left < shardSize {
    			shardSize = left
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. src/cmd/vendor/github.com/google/pprof/internal/elfexec/elfexec.go

    	padding := func(size int) int {
    		return ((size + (alignment - 1)) &^ (alignment - 1)) - size
    	}
    
    	var notes []elfNote
    	for {
    		noteHeader := make([]byte, 12) // 3 4-byte words
    		if _, err := io.ReadFull(r, noteHeader); err == io.EOF {
    			break
    		} else if err != nil {
    			return nil, err
    		}
    		namesz := order.Uint32(noteHeader[0:4])
    		descsz := order.Uint32(noteHeader[4:8])
    		typ := order.Uint32(noteHeader[8:12])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. src/net/http/fcgi/fcgi.go

    		return err
    	}
    	if rec.h.Version != 1 {
    		return errors.New("fcgi: invalid header version")
    	}
    	n := int(rec.h.ContentLength) + int(rec.h.PaddingLength)
    	if _, err = io.ReadFull(r, rec.buf[:n]); err != nil {
    		return err
    	}
    	return nil
    }
    
    func (r *record) content() []byte {
    	return r.buf[:r.h.ContentLength]
    }
    
    // writeRecord writes and sends a single record.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 11 18:51:39 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  10. src/internal/coverage/decodemeta/decodefile.go

    		payload = make([]byte, 0, len)
    	}
    	payload = append(payload, make([]byte, len)...)
    	if _, err := r.f.Seek(int64(off), io.SeekStart); err != nil {
    		return nil, err
    	}
    	if _, err := io.ReadFull(r.f, payload); err != nil {
    		return nil, err
    	}
    	return payload, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Oct 14 22:30:23 UTC 2023
    - 6.8K bytes
    - Viewed (0)
Back to top