- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 296 for chunkOf (0.15 sec)
-
src/internal/bytealg/count_arm64.s
BLO tail ANDS $0x1f, R0, R9 BEQ chunk // Work with not 32-byte aligned head BIC $0x1f, R0, R3 ADD $0x20, R3 PCALIGN $16 head_loop: MOVBU.P 1(R0), R5 CMP R5, R1 CINC EQ, R11, R11 SUB $1, R2, R2 CMP R0, R3 BNE head_loop // Work with 32-byte aligned chunks chunk: BIC $0x1f, R2, R9 // The first chunk can also be the last CBZ R9, tail // R3 = end of 32-byte chunks
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 17:00:27 UTC 2023 - 2K bytes - Viewed (0) -
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) -
tensorflow/cc/saved_model/image_format/internal_api.h
// separated into chunks and written to // `.cpb` (chunked proto). // // Write SavedModel to {file_prefix}{.pb|.cpb}. absl::Status WriteSavedModel(SavedModel* saved_model_proto, const std::string& file_prefix); // Writes the SavedModel proto to std::string // The bool field record whether it's saved as a chunked protobuf (true) or // regular protobuf (false)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Nov 30 21:50:27 UTC 2023 - 2.5K 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) -
cmd/streaming-v4-unsigned.go
"fmt" "io" "net/http" "strings" ) // newUnsignedV4ChunkedReader returns a new s3UnsignedChunkedReader that translates the data read from r // out of HTTP "chunked" format before returning it. // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. func newUnsignedV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { if trailer { // Discard anything unsigned.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
src/internal/bytealg/indexbyte_amd64.s
JB sseloop // Search the last 16-byte chunk. This chunk may overlap with the // chunks we've already searched, but that's ok. MOVQ AX, DI MOVOU (AX), X1 PCMPEQB X0, X1 PMOVMSKB X1, DX BSFL DX, DX JNZ ssesuccess failure: MOVQ $-1, (R8) RET // We've found a chunk containing the byte. // The chunk was loaded from DI. // The index of the matching byte in the chunk is DX. // The start of the data is SI.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 19:06:01 UTC 2023 - 3.1K bytes - Viewed (0) -
src/runtime/mpagealloc_32bit.go
mappedReady = scavIndexSize } else { // Set up the scavenge index. s.chunks = scavengeIndexArray[:] } s.min.Store(1) // The 0th chunk is never going to be mapped for the heap. s.max.Store(uintptr(len(s.chunks))) return } // sysGrow is a no-op on 32-bit platforms. func (s *scavengeIndex) sysGrow(base, limit uintptr, sysStat *sysMemStat) uintptr { return 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 20 20:08:25 UTC 2023 - 4.6K bytes - Viewed (0)