- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 223 for readFull (0.38 sec)
-
cmd/storage-rest-server.go
if err == io.EOF { return nil } return err case 1: errorText, err := io.ReadAll(respBody) if err != nil { return err } return errors.New(string(errorText)) case 2: // Block of data var tmp [4]byte _, err := io.ReadFull(respBody, tmp[:]) if err != nil { return err } length := binary.LittleEndian.Uint32(tmp[:])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
src/crypto/tls/ticket.go
ciphertext := encrypted[aes.BlockSize : len(encrypted)-sha256.Size] authenticated := encrypted[:len(encrypted)-sha256.Size] macBytes := encrypted[len(encrypted)-sha256.Size:] if _, err := io.ReadFull(c.rand(), iv); err != nil { return nil, err } key := ticketKeys[0] block, err := aes.NewCipher(key.aesKey[:]) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 12.6K bytes - Viewed (0) -
src/net/http/transport_test.go
if err != nil { return fmt.Errorf("Post: %v", err) } got, err := io.ReadAll(res.Body) if err != nil { return fmt.Errorf("Body ReadAll: %v", err) } t.Logf("server response:\n%s", got) if !strings.Contains(string(got), deniedMsg) { // If we got an RST packet too early, we should have seen an error // from io.ReadAll, not a silently-truncated body.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/encoding/binary/binary.go
// Read returns [io.ErrUnexpectedEOF]. func Read(r io.Reader, order ByteOrder, data any) error { // Fast path for basic types and slices. if n, _ := intDataSize(data); n != 0 { bs := make([]byte, n) if _, err := io.ReadFull(r, bs); err != nil { return err } if decodeFast(bs, order, data) { return nil } } // Fallback to reflect-based decoding. v := reflect.ValueOf(data) size := -1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:29:31 UTC 2024 - 23.4K bytes - Viewed (0) -
src/net/splice_linux_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 14.5K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
if _, err := conn.Write(buf[:1]); err != nil { b.Fatal(err) } if _, err := io.ReadFull(conn, peek); err != nil { b.Fatal(err) } if _, err := conn.Write(buf); err != nil { b.Fatal(err) } if _, err = io.ReadFull(conn, peek); err != nil { b.Fatal(err) } conn.Close() } } func BenchmarkLatency(b *testing.B) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
src/net/http/client_test.go
say <- str n, err := io.ReadFull(res.Body, buf[0:len(str)]) if err != nil { t.Fatalf("ReadFull on %q: %v", str, err) } if n != len(str) { t.Fatalf("Receiving %q, only read %d bytes", str, n) } got := string(buf[0:n]) if got != str { t.Fatalf("Expected %q, got %q", str, got) } } close(say) _, err = io.ReadFull(res.Body, buf[0:1]) if err != io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
cmd/metacache-stream.go
continue } res = append(res, meta) } return metaCacheEntriesSorted{o: res}, nil } // readAll will return all remaining objects on the dst channel and close it when done. // The context allows the operation to be canceled. func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error { r.checkInit() if r.err != nil { return r.err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
src/math/rand/rand_test.go
} if n != 0 { t.Errorf("Read into empty buffer returned unexpected n of %d", n) } } func TestReadByOneByte(t *testing.T) { r := New(NewSource(1)) b1 := make([]byte, 100) _, err := io.ReadFull(iotest.OneByteReader(r), b1) if err != nil { t.Errorf("read by one byte: %v", err) } r = New(NewSource(1)) b2 := make([]byte, 100) _, err = r.Read(b2) if err != nil { t.Errorf("read: %v", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 16.9K bytes - Viewed (0) -
cmd/erasure-decode_test.go
if err != nil { t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err) } disks := setup.disks data := make([]byte, test.data) if _, err = io.ReadFull(crand.Reader, data); err != nil { t.Fatalf("Test %d: failed to generate random test data: %v", i, err) } writeAlgorithm := test.algorithm if !test.algorithm.Available() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 21.1K bytes - Viewed (0)