Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 223 for readFull (0.53 sec)

  1. src/cmd/vendor/golang.org/x/telemetry/internal/mmap/mmap_other.go

    package mmap
    
    import (
    	"io"
    	"os"
    )
    
    // mmapFile on other systems doesn't mmap the file. It just reads everything.
    func mmapFile(f *os.File, _ *Data) (Data, error) {
    	b, err := io.ReadAll(f)
    	if err != nil {
    		return Data{}, err
    	}
    	return Data{f, b, nil}, nil
    }
    
    func munmapFile(d Data) error {
    	return nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 30 21:40:49 UTC 2024
    - 540 bytes
    - Viewed (0)
  2. src/encoding/csv/fuzz_test.go

    			r := NewReader(bytes.NewReader(in))
    			r.Comma = tt.Comma
    			r.Comment = tt.Comment
    			r.LazyQuotes = tt.LazyQuotes
    			r.TrimLeadingSpace = tt.TrimLeadingSpace
    
    			records, err := r.ReadAll()
    			if err != nil {
    				continue
    			}
    			t.Logf("first records = %#v", records)
    
    			buf.Reset()
    			w := NewWriter(buf)
    			w.Comma = tt.Comma
    			err = w.WriteAll(records)
    			if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 01:26:13 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. src/net/http/httptest/server_test.go

    	res, err := http.Get(ts.URL)
    	if err != nil {
    		t.Fatal(err)
    	}
    	got, err := io.ReadAll(res.Body)
    	res.Body.Close()
    	if err != nil {
    		t.Fatal(err)
    	}
    	if string(got) != "hello" {
    		t.Fatalf("got %q, want hello", string(got))
    	}
    
    	ts.Close()
    
    	res, err = http.Get(ts.URL)
    	if err == nil {
    		body, _ := io.ReadAll(res.Body)
    		t.Fatalf("Unexpected response after close: %v, %v, %s", res.Status, res.Header, body)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 18 16:57:12 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/ByteStreams.java

        }
    
        @Override
        public void readFully(byte b[]) {
          try {
            input.readFully(b);
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public void readFully(byte b[], int off, int len) {
          try {
            input.readFully(b, off, len);
          } catch (IOException e) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Jan 17 18:59:58 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  5. internal/config/crypto_test.go

    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    		data, err := io.ReadAll(ciphertext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    
    		plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. src/net/http/httptest/httptest_test.go

    				RequestURI: "*",
    			},
    		},
    	} {
    		t.Run(tt.name, func(t *testing.T) {
    			got := NewRequestWithContext(context.Background(), tt.method, tt.uri, tt.body)
    			slurp, err := io.ReadAll(got.Body)
    			if err != nil {
    				t.Errorf("ReadAll: %v", err)
    			}
    			if string(slurp) != tt.wantBody {
    				t.Errorf("Body = %q; want %q", slurp, tt.wantBody)
    			}
    			tt.want = tt.want.WithContext(context.Background())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 11 18:09:14 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. src/encoding/base32/base32_test.go

    	dec := NewDecoder(StdEncoding, strings.NewReader(encoded))
    	res1, err := io.ReadAll(dec)
    	if err != nil {
    		t.Errorf("ReadAll failed: %v", err)
    	}
    
    	dec = NewDecoder(StdEncoding, strings.NewReader(encodedShort))
    	var res2 []byte
    	res2, err = io.ReadAll(dec)
    	if err != nil {
    		t.Errorf("ReadAll failed: %v", err)
    	}
    
    	if !bytes.Equal(res1, res2) {
    		t.Error("Decoded results not equal")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 16:25:54 UTC 2024
    - 26K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/io/ByteStreams.java

        }
    
        @Override
        public void readFully(byte b[]) {
          try {
            input.readFully(b);
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public void readFully(byte b[], int off, int len) {
          try {
            input.readFully(b, off, len);
          } catch (IOException e) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Jan 17 18:59:58 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  9. src/internal/zstd/fuzz_test.go

    		cmd.Stdout = &compressed
    		cmd.Stderr = os.Stderr
    		if err := cmd.Run(); err != nil {
    			t.Errorf("running zstd failed: %v", err)
    		}
    
    		r := NewReader(bytes.NewReader(compressed.Bytes()))
    		got, err := io.ReadAll(r)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !bytes.Equal(got, b) {
    			showDiffs(t, got, b)
    		}
    	})
    }
    
    // Fuzz test to check that if we can decompress some data,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 30 04:10:45 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  10. platforms/core-runtime/files/src/main/java/org/gradle/api/internal/file/archive/impl/AbstractZipEntry.java

                    int size = size();
                    if (size >= 0) {
                        byte[] content = new byte[size];
                        ByteStreams.readFully(inputStream, content);
                        return content;
                    } else {
                        return ByteStreams.toByteArray(inputStream);
                    }
                }
            });
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 12:11:00 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top