- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 174 for readWrite (0.23 sec)
-
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsClient.java
// Ensure we have a scope return googleCredential.createScoped(singletonList("https://www.googleapis.com/auth/devstorage.read_write")); } catch (IOException e) { throw new UncheckedIOException("Failed to get Google credentials for GCS connection", e); } } }); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 11:17:20 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
outerWithCloseNotifyAndFlush // http.Hijacker for the inner object InnerHijacker http.Hijacker } func (wr outerWithCloseNotifyFlushAndHijack) Hijack() (net.Conn, *bufio.ReadWriter, error) { if hijacker, ok := wr.UserProvidedDecorator.(http.Hijacker); ok { return hijacker.Hijack() } return wr.InnerHijacker.Hijack()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
// http.CloseNotifier if the inner object (tw.w) implements http.CloseNotifier. return tw.w.(http.CloseNotifier).CloseNotify() } func (tw *baseTimeoutWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) { tw.mu.Lock() defer tw.mu.Unlock() if tw.timedOut { return nil, nil, http.ErrHandlerTimeout } // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go
} // WriteHeader implements http.ResponseWriter. func (rl *respLogger) WriteHeader(status int) { rl.recordStatus(status) rl.w.WriteHeader(status) } func (rl *respLogger) Hijack() (net.Conn, *bufio.ReadWriter, error) { rl.hijacked = true // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements // http.Hijacker if the inner object (rl.w) implements http.Hijacker. return rl.w.(http.Hijacker).Hijack()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper_test.go
func (fw *fakeResponseWriterDecorator) Flush() { if fw.counter != nil { fw.counter.FlushInvoked++ } fw.ResponseWriter.(http.Flusher).Flush() } func (fw *fakeResponseWriterDecorator) Hijack() (net.Conn, *bufio.ReadWriter, error) { if fw.counter != nil { fw.counter.HijackInvoked++ } return fw.ResponseWriter.(http.Hijacker).Hijack() } func (fw *fakeResponseWriterDecorator) CloseNotify() <-chan bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:53 UTC 2021 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go
} func (a *auditResponseWriter) WriteHeader(code int) { a.processCode(code) a.ResponseWriter.WriteHeader(code) } func (a *auditResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) { // fake a response status before protocol switch happens a.processCode(http.StatusSwitchingProtocols) // the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/apis/core/types.go
const ( AzureDataDiskCachingNone AzureDataDiskCachingMode = "None" AzureDataDiskCachingReadOnly AzureDataDiskCachingMode = "ReadOnly" AzureDataDiskCachingReadWrite AzureDataDiskCachingMode = "ReadWrite" AzureSharedBlobDisk AzureDataDiskKind = "Shared" AzureDedicatedBlobDisk AzureDataDiskKind = "Dedicated" AzureManagedDisk AzureDataDiskKind = "Managed" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 268.9K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
make([]byte, 472), // header for the empty record {1, byte(typeStdin), 0x01, 0x2C, 0, 0, 0, 0}, }, nil), }, } type nilCloser struct { io.ReadWriter } func (c *nilCloser) Close() error { return nil } func TestStreams(t *testing.T) { var rec record outer: for _, test := range streamTests { buf := bytes.NewBuffer(test.raw) var content []byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
src/go/internal/gcimporter/gcimporter_test.go
{"encoding.BinaryMarshaler", "type BinaryMarshaler interface{MarshalBinary() (data []byte, err error)}"}, {"io.Reader", "type Reader interface{Read(p []byte) (n int, err error)}"}, {"io.ReadWriter", "type ReadWriter interface{Reader; Writer}"}, {"go/ast.Node", "type Node interface{End() go/token.Pos; Pos() go/token.Pos}"}, {"go/types.Type", "type Type interface{String() string; Underlying() Type}"}, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 16:22:59 UTC 2024 - 21.9K bytes - Viewed (0) -
tensorflow/compiler/jit/resource_operation_safety_analysis.cc
// variables. In the future we may consider doing some form of // inter-procedural analysis. if (MayCallFunction(n, flib_def)) { *out_resource_op_kind = XlaResourceOpKind::kReadWrite; } else { *out_resource_op_kind = std::nullopt; } return absl::OkStatus(); } // Returns true if a control or data dependence from a TensorFlow operation of
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 11:36:41 UTC 2024 - 11.2K bytes - Viewed (0)