- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 160 for readFull (0.2 sec)
-
src/internal/zstd/zstd.go
if len(skip) == 0 { skip = make([]byte, chunk) } if _, err := io.ReadFull(r.r, skip); err != nil { return r.wrapNonEOFError(relativeOffset, err) } relativeOffset += chunk size -= chunk } if size > 0 { if len(skip) == 0 { skip = make([]byte, size) } if _, err := io.ReadFull(r.r, skip); err != nil { return r.wrapNonEOFError(relativeOffset, err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 04:10:45 UTC 2024 - 12.7K bytes - Viewed (0) -
src/cmd/internal/archive/archive.go
r.readFull(r.tmp[:n]) } else if n <= int64(r.b.Buffered()) { // Even though the data is not small, it has already been read. // Advance the buffer instead of seeking. for n > int64(len(r.tmp)) { r.readFull(r.tmp[:]) n -= int64(len(r.tmp)) } r.readFull(r.tmp[:n]) } else { // Seek, giving up buffered data. r.b.MustSeek(r.offset+n, io.SeekStart)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 15 15:39:57 UTC 2023 - 12.1K bytes - Viewed (0) -
src/image/gif/reader.go
// Extensions. const ( eText = 0x01 // Plain Text eGraphicControl = 0xF9 // Graphic Control eComment = 0xFE // Comment eApplication = 0xFF // Application ) func readFull(r io.Reader, b []byte) error { _, err := io.ReadFull(r, b) if err == io.EOF { err = io.ErrUnexpectedEOF } return err } func readByte(r io.ByteReader) (byte, error) { b, err := r.ReadByte() if err == io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 16:15:54 UTC 2024 - 17.5K bytes - Viewed (0) -
src/image/jpeg/reader.go
if err != nil { return 0, err } d.bytes.nUnreadable = 2 if x != 0x00 { return 0, errMissingFF00 } return 0xff, nil } // readFull reads exactly len(p) bytes into p. It does not care about byte // stuffing. func (d *decoder) readFull(p []byte) error { // Unread the overshot bytes, if any. if d.bytes.nUnreadable != 0 { if d.bits.n >= 8 { d.unreadByteStuffedByte() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 22.5K bytes - Viewed (0) -
src/image/png/reader.go
return FormatError("bad tRNS length") } n, err := io.ReadFull(d.r, d.tmp[:length]) if err != nil { return err } d.crc.Write(d.tmp[:n]) copy(d.transparent[:], d.tmp[:length]) d.useTransparent = true case cbP1, cbP2, cbP4, cbP8: if length > 256 { return FormatError("bad tRNS length") } n, err := io.ReadFull(d.r, d.tmp[:length]) if err != nil { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 26K bytes - Viewed (0) -
src/crypto/cipher/gcm_test.go
test := func(ks int, pt, ad []byte) error { key := make([]byte, ks) if _, err := io.ReadFull(rand.Reader, key); err != nil { return err } asm, generic, err := newAESGCM(key) if err != nil { return err } if _, err := io.ReadFull(rand.Reader, pt); err != nil { return err } if _, err := io.ReadFull(rand.Reader, ad); err != nil { return err } nonce := make([]byte, 12)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 25 15:27:49 UTC 2023 - 35K bytes - Viewed (0) -
src/net/http/response_test.go
rbuf := make([]byte, 2500) n, err := io.ReadFull(resp.Body, rbuf) checkErr(err, "2500 byte ReadFull") if n != 2500 { fatalf("ReadFull only read %d bytes", n) } if test.compressed == false && !bytes.Equal(bytes.Repeat([]byte{'x'}, 2500), rbuf) { fatalf("ReadFull didn't read 2500 'x'; got %q", string(rbuf)) } resp.Body.Close() rest, err := io.ReadAll(bufr) checkErr(err, "ReadAll on remainder")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 19:01:29 UTC 2024 - 23.6K bytes - Viewed (0) -
src/net/tcpsock_test.go
t.Fatal(err) } defer server.Close() var buf [128]byte allocs := testing.AllocsPerRun(1000, func() { _, err := server.Write(buf[:]) if err != nil { t.Fatal(err) } _, err = io.ReadFull(client, buf[:]) if err != nil { t.Fatal(err) } }) if allocs > 0 { t.Fatalf("got %v; want 0", allocs) } var bufwrt [128]byte ch := make(chan bool) defer close(ch)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// // The signature is 64 bytes long (hex-encoded SHA256 hash) and // starts with a 16 byte header: len("chunk-signature=") + 64 == 80. var signature [80]byte _, err = io.ReadFull(cr.reader, signature[:]) if err == io.EOF { err = io.ErrUnexpectedEOF } if err != nil { cr.err = err return n, cr.err } if !bytes.HasPrefix(signature[:], []byte("chunk-signature=")) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/image/jpeg/scan.go
func (d *decoder) processSOS(n int) error { if d.nComp == 0 { return FormatError("missing SOF marker") } if n < 6 || 4+2*d.nComp < n || n%2 != 0 { return FormatError("SOS has wrong length") } if err := d.readFull(d.tmp[:n]); err != nil { return err } nComp := int(d.tmp[0]) if n != 4+2*nComp { return FormatError("SOS length inconsistent with number of components") } var scan [maxComponents]struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 25 00:46:29 UTC 2024 - 15.7K bytes - Viewed (0)