- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for buffer_end (0.48 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
} else { absl::MutexLock l(&gcs_file->buffer_mutex); size_t buffer_end = gcs_file->buffer_start + gcs_file->buffer.size(); size_t copy_size = 0; if (offset < buffer_end && gcs_file->buffer_start) { copy_size = (std::min)(n, static_cast<size_t>(buffer_end - offset)); memcpy(buffer, gcs_file->buffer.data() + (offset - gcs_file->buffer_start),
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 23 06:55:53 UTC 2023 - 46.9K bytes - Viewed (0) -
src/bufio/bufio.go
return NewReaderSize(rd, defaultBufSize) } // Size returns the size of the underlying buffer in bytes. func (b *Reader) Size() int { return len(b.buf) } // Reset discards any buffered data, resets all state, and switches // the buffered reader to read from r. // Calling Reset on the zero value of [Reader] initializes the internal buffer // to the default size. // Calling b.Reset(b) (that is, resetting a [Reader] to itself) does nothing.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector.go
// TLS, and in TLS the client speaks first, so we know there's // no unbuffered data. But we can double-check. if br.Buffered() > 0 { proxyConn.Close() return nil, fmt.Errorf("unexpected %d bytes of buffered data from CONNECT proxy %q", br.Buffered(), proxyAddress) } return proxyConn, nil } type proxier interface { // proxy returns a connection to addr.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 12.5K bytes - Viewed (0) -
src/cmd/internal/archive/archive.go
r.error(fmt.Errorf("debug/goobj: internal error: misuse of skip")) } if n < int64(len(r.tmp)) { // Since the data is so small, a just reading from the buffered // reader is better than flushing the buffer and seeking. r.readFull(r.tmp[:n]) } else if n <= int64(r.b.Buffered()) { // Even though the data is not small, it has already been read. // Advance the buffer instead of seeking. for n > int64(len(r.tmp)) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 15 15:39:57 UTC 2023 - 12.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/declarations/GroovyFileInterceptors.java
public static void intercept_eachByte( @Receiver File self, int bufferLen, Closure<?> closure, @CallerClassName String consumer ) throws IOException { Instrumented.fileOpened(self, consumer); ResourceGroovyMethods.eachByte(self, bufferLen, closure); } @InterceptGroovyCalls @InstanceMethod
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 24 15:57:56 UTC 2023 - 16.8K bytes - Viewed (0) -
internal/grid/benchmark_test.go
select { case <-ctx.Done(): return nil case out <- toSend: } } return nil }, Subroute: "some-subroute", OutCapacity: 1, // Only one message buffered. InCapacity: 0, })) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/yaml/decoder_test.go
} } } func TestBigYAML(t *testing.T) { d := ` stuff: 1 ` maxLen := 5 * 1024 * 1024 bufferLen := 4 * 1024 // maxLen 5 M dd := strings.Repeat(d, 512*1024) r := NewDocumentDecoder(io.NopCloser(bytes.NewReader([]byte(dd[:maxLen-1])))) b := make([]byte, bufferLen) n, err := r.Read(b) if err != io.ErrShortBuffer { t.Fatalf("expected ErrShortBuffer: %d / %v", n, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 12.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
* Prepares the HTTP headers and sends them to the server. * * For streaming requests with a body, headers must be prepared **before** the output stream has * been written to. Otherwise the body would need to be buffered! * * For non-streaming requests with a body, headers must be prepared **after** the output stream * has been written to and closed. This ensures that the `Content-Length` header field receives * the proper value.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/services/LoggingServiceRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 20.3K bytes - Viewed (0) -
src/encoding/json/stream.go
err = dec.d.unmarshal(v) // fixup token streaming state dec.tokenValueEnd() return err } // Buffered returns a reader of the data remaining in the Decoder's // buffer. The reader is valid until the next call to [Decoder.Decode]. func (dec *Decoder) Buffered() io.Reader { return bytes.NewReader(dec.buf[dec.scanp:]) } // readValue reads a JSON value into dec.buf.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 12.9K bytes - Viewed (0)