Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 440 for readFull (0.12 sec)

  1. src/crypto/ecdh/x25519.go

    	return "X25519"
    }
    
    func (c *x25519Curve) GenerateKey(rand io.Reader) (*PrivateKey, error) {
    	key := make([]byte, x25519PrivateKeySize)
    	randutil.MaybeReadByte(rand)
    	if _, err := io.ReadFull(rand, key); err != nil {
    		return nil, err
    	}
    	return c.NewPrivateKey(key)
    }
    
    func (c *x25519Curve) NewPrivateKey(key []byte) (*PrivateKey, error) {
    	if len(key) != x25519PrivateKeySize {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 13 17:09:47 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. cmd/erasure-encode.go

    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    		errs:        make([]error, len(writers)),
    	}
    
    	for {
    		var blocks [][]byte
    		n, err := io.ReadFull(src, buf)
    		if err != nil {
    			if !IsErrIgnored(err, []error{
    				io.EOF,
    				io.ErrUnexpectedEOF,
    			}...) {
    				return 0, err
    			}
    		}
    
    		eof := err == io.EOF || err == io.ErrUnexpectedEOF
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. src/cmd/go/terminal_test.go

    	}
    	w.Close()
    	t.Cleanup(func() {
    		stdin.Close()
    		if err := cmd.Wait(); err != nil {
    			t.Errorf("suprocess failed with: %s", err)
    		}
    	})
    
    	buf := make([]byte, 2)
    	n, err := io.ReadFull(r, buf)
    	if err != nil || !(buf[0] == '1' || buf[0] == 'X') || !(buf[1] == '2' || buf[1] == 'X') {
    		t.Logf("read error: %v", err)
    		t.Fatalf("expected 2 bytes matching `[1X][2X]`; got %q", buf[:n])
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Dec 07 18:18:50 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  4. src/io/io_test.go

    	src := []byte("hello, world")
    	dst := make([]byte, len(src))
    	rb := bytes.NewBuffer(src)
    	wb := new(bytes.Buffer)
    	r := TeeReader(rb, wb)
    	if n, err := ReadFull(r, dst); err != nil || n != len(src) {
    		t.Fatalf("ReadFull(r, dst) = %d, %v; want %d, nil", n, err, len(src))
    	}
    	if !bytes.Equal(dst, src) {
    		t.Errorf("bytes read = %q want %q", dst, src)
    	}
    	if !bytes.Equal(wb.Bytes(), src) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Oct 09 22:04:41 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  5. pkg/wasm/httpfetcher.go

    	tr := tar.NewReader(io.LimitReader(buf, 1024*1024*256))
    
    	h, err := tr.Next()
    	if err != nil {
    		return nil
    	}
    
    	ret := make([]byte, h.Size)
    	_, err = io.ReadFull(tr, ret)
    	if err != nil {
    		return nil
    	}
    	return ret
    }
    
    func isGZ(b []byte) bool {
    	return len(b) > 2 && bytes.Equal(b[:2], gzMagicNumber)
    }
    
    func getFileFromGZ(b []byte) []byte {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 14 20:23:34 UTC 2022
    - 5.5K bytes
    - Viewed (0)
  6. internal/auth/credentials.go

    	}
    	if length <= 0 {
    		length = accessKeyMaxLen
    	}
    	if length < accessKeyMinLen {
    		return "", errors.New("auth: access key length is too short")
    	}
    
    	key := make([]byte, length)
    	if _, err := io.ReadFull(random, key); err != nil {
    		return "", err
    	}
    	for i := range key {
    		key[i] = alphaNumericTable[key[i]%alphaNumericTableLen]
    	}
    	return string(key), nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  7. src/os/writeto_linux_test.go

    		}
    	}); err != nil {
    		t.Fatalf("destination Conn Control error: %v", err)
    	}
    
    	// Verify the data size and content.
    	dataSize := len(data)
    	dstData := make([]byte, dataSize)
    	m, err := io.ReadFull(recv, dstData)
    	if err != nil {
    		t.Fatalf("server Conn Read error: %v", err)
    	}
    	if n != int64(dataSize) {
    		t.Fatalf("data length mismatch for io.Copy, got %d, want %d", n, dataSize)
    	}
    	if m != dataSize {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. cmd/erasure_test.go

    	{dataBlocks: 8, parityBlocks: 4, missingData: 2, missingParity: 2, reconstructParity: false, shouldFail: false},
    }
    
    func TestErasureEncodeDecode(t *testing.T) {
    	data := make([]byte, 256)
    	if _, err := io.ReadFull(rand.Reader, data); err != nil {
    		t.Fatalf("Failed to read random data: %v", err)
    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  9. src/net/external_test.go

    		return err
    	}
    	defer c.Close()
    	req := []byte("GET /robots.txt HTTP/1.0\r\nHost: www.google.com\r\n\r\n")
    	if _, err := c.Write(req); err != nil {
    		return err
    	}
    	b := make([]byte, 1000)
    	n, err := io.ReadFull(c, b)
    	if err != nil {
    		return err
    	}
    	if n < 1000 {
    		return fmt.Errorf("short read from %s:%s->%s", network, c.RemoteAddr(), c.LocalAddr())
    	}
    	return nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  10. src/mime/multipart/writer.go

    	if strings.ContainsAny(b, `()<>@,;:\"/[]?= `) {
    		b = `"` + b + `"`
    	}
    	return "multipart/form-data; boundary=" + b
    }
    
    func randomBoundary() string {
    	var buf [30]byte
    	_, err := io.ReadFull(rand.Reader, buf[:])
    	if err != nil {
    		panic(err)
    	}
    	return fmt.Sprintf("%x", buf[:])
    }
    
    // CreatePart creates a new multipart section with the provided
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top