- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 189 for buffer_end (0.19 sec)
-
pkg/controlplane/apiserver/options/options_test.go
"k8s.io/apiserver/pkg/admission" apiserveroptions "k8s.io/apiserver/pkg/server/options" "k8s.io/apiserver/pkg/storage/etcd3" "k8s.io/apiserver/pkg/storage/storagebackend" auditbuffered "k8s.io/apiserver/plugin/pkg/audit/buffered" audittruncate "k8s.io/apiserver/plugin/pkg/audit/truncate" cliflag "k8s.io/component-base/cli/flag" "k8s.io/component-base/logs" "k8s.io/component-base/metrics" netutils "k8s.io/utils/net"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
src/image/jpeg/reader.go
d.bytes.i -= d.bytes.nUnreadable d.bytes.nUnreadable = 0 if d.bits.n >= 8 { d.bits.a >>= 8 d.bits.n -= 8 d.bits.m >>= 8 } } // readByte returns the next byte, whether buffered or not buffered. It does // not care about byte stuffing. func (d *decoder) readByte() (x byte, err error) { for d.bytes.i == d.bytes.j { if err = d.fill(); err != nil { return 0, err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 22.5K bytes - Viewed (0) -
src/encoding/ascii85/ascii85.go
// trailing partial block. func NewEncoder(w io.Writer) io.WriteCloser { return &encoder{w: w} } type encoder struct { err error w io.Writer buf [4]byte // buffered data waiting to be encoded nbuf int // number of bytes in buf out [1024]byte // output buffer } func (e *encoder) Write(p []byte) (n int, err error) { if e.err != nil { return 0, e.err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/http/httptrace/trace.go
// failure. TLSHandshakeDone func(tls.ConnectionState, error) // WroteHeaderField is called after the Transport has written // each request header. At the time of this call the values // might be buffered and not yet written to the network. WroteHeaderField func(key string, value []string) // WroteHeaders is called after the Transport has written // all request headers. WroteHeaders func()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 8.1K bytes - Viewed (0) -
src/image/gif/reader.go
// implements io.ByteReader and buffers blocks into the decoder's "tmp" buffer. type blockReader struct { d *decoder i, j uint8 // d.tmp[i:j] contains the buffered bytes err error } func (b *blockReader) fill() { if b.err != nil { return } b.j, b.err = readByte(b.d.r) if b.j == 0 && b.err == nil { b.err = io.EOF } if b.err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 16:15:54 UTC 2024 - 17.5K bytes - Viewed (0) -
src/runtime/mwbbuf.go
// buffer corruption. // // This must be non-preemptible because it uses the P's workbuf. // //go:nowritebarrierrec //go:systemstack func wbBufFlush1(pp *p) { // Get the buffered pointers. start := uintptr(unsafe.Pointer(&pp.wbBuf.buf[0])) n := (pp.wbBuf.next - start) / unsafe.Sizeof(pp.wbBuf.buf[0]) ptrs := pp.wbBuf.buf[:n] // Poison the buffer to make extra sure nothing is enqueued
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
/** * Report and attempt to recover from a failure to communicate with a server. Returns true if * `e` is recoverable, or false if the failure is permanent. Requests with a body can only * be recovered if the body is buffered or if the failure occurred before the request has been * sent. */ private fun recover( e: IOException, call: RealCall, userRequest: Request, requestSendStarted: Boolean,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
assert.Equal(t, responseBody, string(testConnConstructor.mockConn.written), "extra data written to net.Conn") }) // Partially written headers are buffered and decoded t.Run("simple-byte-by-byte", func(t *testing.T) { testConnConstructor := &mockConnInitializer{mockConn: &mockConn{}, initializeWriteConn: &mockConn{}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
src/cmd/link/internal/ld/outbuf.go
// is ignored where needed, and OutBuf writes to heap memory. var errNoFallocate = errors.New("operation not supported") const outbufMode = 0775 // OutBuf is a buffered file writer. // // It is similar to the Writer in cmd/internal/bio with a few small differences. // // First, it tracks the output architecture and uses it to provide // endian helpers. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 17 19:51:29 UTC 2022 - 8.1K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/options_test.go
"k8s.io/apiserver/pkg/admission" apiserveroptions "k8s.io/apiserver/pkg/server/options" "k8s.io/apiserver/pkg/storage/etcd3" "k8s.io/apiserver/pkg/storage/storagebackend" auditbuffered "k8s.io/apiserver/plugin/pkg/audit/buffered" audittruncate "k8s.io/apiserver/plugin/pkg/audit/truncate" cliflag "k8s.io/component-base/cli/flag" "k8s.io/component-base/logs" "k8s.io/component-base/metrics" kapi "k8s.io/kubernetes/pkg/apis/core"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 12.7K bytes - Viewed (0)