- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 950 for doPing (1.71 sec)
-
cmd/storage-rest-server.go
var hint string if endpoint.URL != nil { hint = fmt.Sprintf("Drive '%s' does not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support", endpoint.Path) } else { hint = "Drives do not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support" } logger.Fatal(config.ErrUnsupportedBackend(err).Hint(hint), "Unable to initialize backend")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
maven-di/src/main/java/org/apache/maven/di/impl/InjectorImpl.java
Binding<?> binding = ReflectionUtils.generateImplicitBinding(key); doBind(key, binding); } return this; } private LinkedHashSet<Key<?>> current = new LinkedHashSet<>(); private Injector doBind(Key<?> key, Binding<?> binding) { if (!current.add(key)) { current.add(key);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 14.3K bytes - Viewed (0) -
src/crypto/tls/handshake_server.go
tls3des.Value() // ensure godebug is initialized tls3des.IncNonDefault() } for _, id := range hs.clientHello.cipherSuites { if id == TLS_FALLBACK_SCSV { // The client is doing a fallback connection. See RFC 7507. if hs.clientHello.vers < c.config.maxSupportedVersion(roleServer) { c.sendAlert(alertInappropriateFallback) return errors.New("tls: client using inappropriate protocol fallback")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 27.6K bytes - Viewed (0) -
src/net/http/requestwrite_test.go
WantWrite string // Request.Write WantProxy string // Request.WriteProxy WantError error // wanted error from Request.Write } var reqWriteTests = []reqWriteTest{ // HTTP/1.1 => chunked coding; no body; no trailer 0: { Req: Request{ Method: "GET", URL: &url.URL{ Scheme: "http", Host: "www.techcrunch.com", Path: "/", }, Proto: "HTTP/1.1", ProtoMajor: 1,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:07:32 UTC 2022 - 23.3K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/cryptobyte/builder.go
} // Bytes returns the bytes written by the builder or an error if one has // occurred during building. func (b *Builder) Bytes() ([]byte, error) { if b.err != nil { return nil, b.err } return b.result[b.offset:], nil } // BytesOrPanic returns the bytes written by the builder or panics if an error // has occurred during building. func (b *Builder) BytesOrPanic() []byte { if b.err != nil { panic(b.err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 10 16:32:44 UTC 2023 - 9.9K bytes - Viewed (0) -
src/mime/multipart/multipart.go
// next part (if any) begins. func (p *Part) Read(d []byte) (n int, err error) { return p.r.Read(d) } // partReader implements io.Reader by reading raw bytes directly from the // wrapped *Part, without doing any Transfer-Encoding decoding. type partReader struct { p *Part } func (pr partReader) Read(d []byte) (int, error) { p := pr.p br := p.mr.bufReader
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/apis/config/types.go
Extenders []Extender // DelayCacheUntilActive specifies when to start caching. If this is true and leader election is enabled, // the scheduler will wait to fill informer caches until it is the leader. Doing so will have slower // failover with the benefit of lower memory overhead while waiting to become leader. // Defaults to false. DelayCacheUntilActive bool } // KubeSchedulerProfile is a scheduling profile.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 14.8K bytes - Viewed (0) -
src/database/sql/driver/driver.go
type Driver interface { // Open returns a new connection to the database. // The name is a string in a driver-specific format. // // Open may return a cached connection (one previously // closed), but doing so is unnecessary; the sql package // maintains a pool of idle connections for efficient re-use. // // The returned connection is only used by one goroutine at a // time. Open(name string) (Conn, error) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 09:04:12 UTC 2023 - 20.9K bytes - Viewed (0) -
src/go/types/check.go
"strings" "sync/atomic" ) // nopos, noposn indicate an unknown position var nopos token.Pos var noposn = atPos(nopos) // debugging/development support const debug = false // leave on during development // gotypesalias controls the use of Alias types. // As of Apr 16 2024 they are used by default. // To disable their use, set GODEBUG to gotypesalias=0.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 23.1K bytes - Viewed (0) -
src/runtime/time.go
// The timer set t.ts must be non-nil and locked, t must be t.ts.heap[0], and updateHeap // takes care of moving t within the timers heap to preserve the heap invariants. // If ts == nil, then t must not be in a heap (or is in a heap that is // temporarily not maintaining its invariant, such as during timers.adjust). func (t *timer) updateHeap() (updated bool) { assertWorldStoppedOrLockHeld(&t.mu) t.trace("updateHeap")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0)