- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 90 for buffer_end (0.15 sec)
-
src/net/lookup_windows.go
// GetAddrInfoEx with lpOverlapped, which requires // Windows 8 or newer. I guess we'll need oldLookupIP, // newLookupIP, and newerLookUP. // // For now we just let it finish and write to the // buffered channel. return nil, newDNSError(mapErr(ctx.Err()), name, "") } } func (r *Resolver) lookupPort(ctx context.Context, network, service string) (int, error) { if systemConf().mustUseGoResolver(r) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 14.2K bytes - Viewed (0) -
src/internal/trace/generation.go
// generation. type spilledBatch struct { gen uint64 *batch } // readGeneration buffers and decodes the structural elements of a trace generation // out of r. spill is the first batch of the new generation (already buffered and // parsed from reading the last generation). Returns the generation and the first // batch read of the next generation, if any. // // If gen is non-nil, it is valid and must be processed before handling the returned
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 22:14:45 UTC 2024 - 12.1K bytes - Viewed (0) -
src/crypto/tls/handshake_test.go
path := file.Name() file.WriteString(contents) file.Close() return path } // localListener is set up by TestMain and used by localPipe to create Conn // pairs like net.Pipe, but connected by an actual buffered TCP connection. var localListener struct { mu sync.Mutex addr net.Addr ch chan net.Conn } const localFlakes = 0 // change to 1 or 2 to exercise localServer/localPipe handling of mismatches
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 24.5K bytes - Viewed (0) -
pilot/test/xds/fake.go
// Override the default kube client constructor KubeClientBuilder func(objects ...runtime.Object) kubelib.Client // ListenerBuilder, if specified, allows making the server use the given // listener instead of a buffered conn. ListenerBuilder func() (net.Listener, error) // Time to debounce // By default, set to 0s to speed up tests DebounceTime time.Duration
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} return n, err } // diskHealthReader provides a wrapper that will update disk health on // ctx, on every successful read. // This should only be used directly at the os/syscall level, // otherwise buffered operations may return false health checks. func diskHealthReader(ctx context.Context, r io.Reader) io.Reader { // Check if context has a disk health check. tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
// output in a deterministic order. type sequencer struct { maxWeight int64 sem *semaphore.Weighted // weighted by input bytes (an approximate proxy for memory overhead) prev <-chan *reporterState // 1-buffered } // newSequencer returns a sequencer that allows concurrent tasks up to maxWeight // and writes tasks' output to out and err. func newSequencer(maxWeight int64, out, err io.Writer) *sequencer {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
) val call1 = client.newCall(Request(server.url("/"))) val response1 = call1.execute() waitForDataFrames(Http2Connection.OKHTTP_CLIENT_WINDOW_SIZE) // Cancel the call and discard what we've buffered for the response body. This should free up // the connection flow-control window so new requests can proceed. call1.cancel() assertThat( response1.body.source().discard(1, TimeUnit.SECONDS),
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
ErrWriteOnClosed = errors.New("write on closed ringbuffer") ) // RingBuffer is a circular buffer that implement io.ReaderWriter interface. // It operates like a buffered pipe, where data written to a RingBuffer // and can be read back from another goroutine. // It is safe to concurrently read and write RingBuffer. type RingBuffer struct { buf []byte size int
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/http/transport.go
br *bufio.Reader // used until empty io.ReadWriteCloser } func (b *readWriteCloserBody) Read(p []byte) (n int, err error) { if b.br != nil { if n := b.br.Buffered(); len(p) > n { p = p[:n] } n, err = b.br.Read(p) if b.br.Buffered() == 0 { b.br = nil } return n, err } return b.ReadWriteCloser.Read(p) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
func (sysver SystemVerificationCheck) Check() (warnings, errorList []error) { klog.V(1).Infoln("running all checks") // Create a buffered writer and choose a quite large value (1M) and suppose the output from the system verification test won't exceed the limit // Run the system verification check, but write to out buffered writer instead of stdout bufw := bufio.NewWriterSize(os.Stdout, 1*1024*1024) reporter := &system.StreamReporter{WriteStream: bufw}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0)