- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for readFull (0.12 sec)
-
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) -
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) -
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) -
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) -
src/index/suffixarray/suffixarray.go
_, err := w.Write(buf[0:binary.MaxVarintLen64]) return err } // readInt reads an int x from r using buf to buffer the read and returns x. func readInt(r io.Reader, buf []byte) (int64, error) { _, err := io.ReadFull(r, buf[0:binary.MaxVarintLen64]) // ok to continue with error x, _ := binary.Varint(buf) return x, err } // writeSlice writes data[:n] to w and returns n. // It uses buf to buffer the write.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.5K bytes - Viewed (0) -
src/io/pipe_test.go
r, w := Pipe() go func() { w.Write([]byte{}) w.Close() }() var b [2]byte ReadFull(r, b[0:2]) r.Close() } func TestWriteNil(t *testing.T) { r, w := Pipe() go func() { w.Write(nil) w.Close() }() var b [2]byte ReadFull(r, b[0:2]) r.Close() } func TestWriteAfterWriterClose(t *testing.T) { r, w := Pipe() defer r.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9K bytes - Viewed (0) -
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) -
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) -
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) -
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)