Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 160 for readFull (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top