Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 231 for readFull (0.36 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/crypto/rand/rand.go

    //   - On wasip1/wasm, Reader uses random_get from wasi_snapshot_preview1.
    var Reader io.Reader
    
    // Read is a helper function that calls Reader.Read using io.ReadFull.
    // On return, n == len(b) if and only if err == nil.
    func Read(b []byte) (n int, err error) {
    	return io.ReadFull(Reader, b)
    }
    
    // batched returns a function that calls f to populate a []byte by chunking it
    // into subslices of, at most, readMax bytes.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 20:02:21 UTC 2024
    - 1.5K 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/crypto/rand/rand_test.go

    	"compress/flate"
    	"io"
    	"testing"
    )
    
    func TestRead(t *testing.T) {
    	var n int = 4e6
    	if testing.Short() {
    		n = 1e5
    	}
    	b := make([]byte, n)
    	n, err := io.ReadFull(Reader, b)
    	if n != len(b) || err != nil {
    		t.Fatalf("ReadFull(buf) = %d, %s", n, err)
    	}
    
    	var z bytes.Buffer
    	f, _ := flate.NewWriter(&z, 5)
    	f.Write(b)
    	f.Close()
    	if z.Len() < len(b)*99/100 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 19 20:02:21 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  5. src/crypto/subtle/xor_test.go

    					q := make([]byte, alignQ+n, alignQ+n+10)[alignQ:]
    					if n&1 != 0 {
    						p = p[:n]
    					} else {
    						q = q[:n]
    					}
    					if _, err := io.ReadFull(rand.Reader, p); err != nil {
    						t.Fatal(err)
    					}
    					if _, err := io.ReadFull(rand.Reader, q); err != nil {
    						t.Fatal(err)
    					}
    
    					d := make([]byte, alignD+n, alignD+n+10)
    					for i := range d {
    						d[i] = 0xdd
    					}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 16 15:51:19 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. internal/config/crypto.go

    	const (
    		MaxMetadataSize = 1 << 20 // max. size of the metadata
    		Version         = 1
    	)
    
    	var header [5]byte
    	if _, err := io.ReadFull(ciphertext, header[:]); err != nil {
    		return nil, err
    	}
    	if header[0] != Version {
    		return nil, fmt.Errorf("config: unknown ciphertext version %d", header[0])
    	}
    	size := binary.LittleEndian.Uint32(header[1:])
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. src/internal/sysinfo/cpuinfo_linux.go

    	"bufio"
    	"bytes"
    	"io"
    	"os"
    	"strings"
    )
    
    func readLinuxProcCPUInfo(buf []byte) error {
    	f, err := os.Open("/proc/cpuinfo")
    	if err != nil {
    		return err
    	}
    	defer f.Close()
    
    	_, err = io.ReadFull(f, buf)
    	if err != nil && err != io.ErrUnexpectedEOF {
    		return err
    	}
    
    	return nil
    }
    
    func osCPUInfoName() string {
    	modelName := ""
    	cpuMHz := ""
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 18:42:42 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  8. src/crypto/rand/rand_plan9.go

    		})
    		defer t.Stop()
    		entropy, err := os.Open(randomDevice)
    		if err != nil {
    			r.seedErr = err
    			return
    		}
    		defer entropy.Close()
    		_, r.seedErr = io.ReadFull(entropy, r.key[:])
    	})
    	if r.seedErr != nil {
    		return 0, r.seedErr
    	}
    
    	r.mu.Lock()
    	blockCipher, err := aes.NewCipher(r.key[:])
    	if err != nil {
    		r.mu.Unlock()
    		return 0, err
    	}
    	var (
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 18:57:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. 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
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. 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)
Back to top