- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 120 for chunkOf (0.14 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware_test.go
} } } func TestProxyRequestContentLengthAndTransferEncoding(t *testing.T) { chunk := func(data []byte) []byte { out := &bytes.Buffer{} chunker := httputil.NewChunkedWriter(out) for _, b := range data { if _, err := chunker.Write([]byte{b}); err != nil { panic(err) } } chunker.Close() out.Write([]byte("\r\n")) return out.Bytes() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 39.4K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/StreamByteBuffer.java
for (byte[] buf : listOfByteArrays) { addChunk(new StreamByteBufferChunk(buf)); } } private void addChunk(StreamByteBufferChunk chunk) { chunks.add(chunk); totalBytesUnreadInList += chunk.bytesUnread(); } static class StreamByteBufferChunk { private int pointer; private byte[] buffer; private int size;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 16.6K bytes - Viewed (0) -
pilot/pkg/config/file/store.go
scope.Debugf("Failed to parse yamlText chunk: %v", yamlText) errs = multierror.Append(errs, e) break } chunk := bytes.TrimSpace(doc) if len(chunk) == 0 { continue } chunkResources, err := s.parseChunk(r, name, lineNum, chunk) if err != nil { var uerr *unknownSchemaError if errors.As(err, &uerr) { scope.Debugf("skipping unknown yaml chunk %s: %s", name, uerr.Error()) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/image/png/reader.go
if len(p) == 0 { return 0, nil } for d.idatLength == 0 { // We have exhausted an IDAT chunk. Verify the checksum of that chunk. if err := d.verifyChecksum(); err != nil { return 0, err } // Read the length and chunk type of the next chunk, and check that // it is an IDAT chunk. if _, err := io.ReadFull(d.r, d.tmp[:8]); err != nil { return 0, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 26K bytes - Viewed (0) -
src/net/http/httputil/dump_test.go
"Host: www.google.com\r\n" + "Transfer-Encoding: chunked\r\n\r\n" + chunk("abcdef") + chunk(""), }, // Verify that DumpRequest preserves the HTTP version number, doesn't add a Host, // and doesn't add a User-Agent. { Req: &http.Request{ Method: "GET", URL: mustParseURL("/foo"), ProtoMajor: 1, ProtoMinor: 0, Header: http.Header{ "X-Foo": []string{"X-Bar"}, }, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 17:34:07 UTC 2022 - 12.5K bytes - Viewed (0) -
src/net/http/response_test.go
Header: Header{}, Close: false, ContentLength: -1, TransferEncoding: []string{"chunked"}, }, "Body here\n", }, // Chunked response in response to a HEAD request { "HTTP/1.1 200 OK\r\n" + "Transfer-Encoding: chunked\r\n" + "\r\n", Response{ Status: "200 OK", StatusCode: 200, Proto: "HTTP/1.1",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 19:01:29 UTC 2024 - 23.6K bytes - Viewed (0) -
src/runtime/map_benchmark_test.go
idx = 0 } } } type chunk [17]byte func BenchmarkHashBytesSpeed(b *testing.B) { // a bunch of chunks, each with a different alignment mod 16 var chunks [size]chunk // initialize each to a different value for i := 0; i < size; i++ { chunks[i][0] = byte(i) } // put into a map m := make(map[chunk]int, size) for i, c := range chunks { m[c] = i } idx := 0 b.ResetTimer()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 09 16:41:16 UTC 2023 - 10.6K bytes - Viewed (0) -
src/image/png/reader_test.go
// These bytes come from https://go.dev/issue/54325 // // Per the PNG spec, a PLTE chunk contains 3 (not 4) bytes per palette // entry: RGB (not RGBA). The alpha value comes from the optional tRNS // chunk. Here, the PLTE chunk (0x50, 0x4c, 0x54, 0x45, etc) has 16 entries // (0x30 = 48 bytes) and the tRNS chunk (0x74, 0x52, 0x4e, 0x53, etc) has 1 // entry (0x01 = 1 byte) that sets the first palette entry's alpha to zero.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 24 12:12:12 UTC 2022 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/yaml/decoder.go
return err } // YAMLDecoder reads chunks of objects and returns ErrShortBuffer if // the data is not sufficient. type YAMLDecoder struct { r io.ReadCloser scanner *bufio.Scanner remaining []byte } // NewDocumentDecoder decodes YAML documents from the provided // stream in chunks by converting each document (as defined by // the YAML spec) into its own chunk. io.ErrShortBuffer will be
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 21:24:36 UTC 2021 - 10.2K bytes - Viewed (0) -
tensorflow/cc/saved_model/fingerprinting_utils_test.cc
TF_ASSERT_OK(read_metadata.status()); } ChunkMetadata chunk_metadata = read_metadata.value(); std::vector<ChunkInfo> chunks_info = std::vector<ChunkInfo>( chunk_metadata.chunks().begin(), chunk_metadata.chunks().end()); FieldIndex field_one_field_tag; field_one_field_tag.set_field(1); FieldIndex repeated_field_field_tag; repeated_field_field_tag.set_field(2);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Feb 20 22:19:55 UTC 2024 - 15.2K bytes - Viewed (0)