- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 256 for connectat (0.96 sec)
-
pilot/pkg/xds/discovery.go
} // Shutdown shuts down DiscoveryServer components. func (s *DiscoveryServer) Shutdown() { s.closeJwksResolver() s.pushQueue.ShutDown() } // Clients returns all currently connected clients. This method can be safely called concurrently, // but care should be taken with the underlying objects (ie model.Proxy) to ensure proper locking.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
guava/src/com/google/common/collect/Range.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/adsc/adsc.go
} a.mutex.RUnlock() err := a.Run() if err != nil { // TODO: fix reconnect time.AfterFunc(a.cfg.BackoffPolicy.NextBackOff(), a.reconnect) } } func (a *ADSC) handleRecv() { // We connected, so reset the backoff if a.cfg.BackoffPolicy != nil { a.cfg.BackoffPolicy.Reset() } for { var err error msg, err := a.stream.Recv() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
src/net/http/httptest/server.go
// requests) and new connections (those which connected // but never sent a request). StateNew connections are // super rare and have only been seen (in // previously-flaky tests) in the case of // socket-late-binding races from the http Client // dialing this server and then getting an idle // connection before the dial completed. There is thus // a connected connection in StateNew with no
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubeapiserver/authenticator/config.go
} // NOTE(ericchiang): Keep the OpenID Connect after Service Accounts. // // Because both plugins verify JWTs whichever comes first in the union experiences // cache misses for all requests using the other. While the service account plugin // simply returns an error, the OpenID Connect plugin may query the provider to // update the keys, causing performance hits.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/prepare-storage.go
if errors.Is(err, errDiskNotFound) && verboseLogging { if globalEndpoints.NEndpoints() > 1 { logger.Error("Unable to connect to %s: %v", endpoints[i], isServerResolvable(endpoints[i], time.Second)) } else { logger.Fatal(err, "Unable to connect to %s: %v", endpoints[i], isServerResolvable(endpoints[i], time.Second)) } } else { if globalEndpoints.NEndpoints() > 1 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
build-logic/dependency-modules/src/main/kotlin/gradlebuild/modules/extension/ExternalModulesExtension.kt
val maven3SettingsBuilder = "org.apache.maven:maven-settings-builder" val mavenResolverApi = "org.apache.maven.resolver:maven-resolver-api" val mavenResolverConnectorBasic = "org.apache.maven.resolver:maven-resolver-connector-basic" val mavenResolverImpl = "org.apache.maven.resolver:maven-resolver-impl" val mavenResolverSupplier = "org.apache.maven.resolver:maven-resolver-supplier"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 25 22:44:42 UTC 2024 - 15K bytes - Viewed (0) -
internal/grid/benchmark_test.go
})) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload) errFatal(err) // Wait for all to connect // Parallel writes per server. b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) { defer timeout(60 * time.Second)()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
src/net/rpc/server.go
func Accept(lis net.Listener) { DefaultServer.Accept(lis) } // Can connect to RPC service using HTTP CONNECT to rpcPath. var connected = "200 Connected to Go RPC" // ServeHTTP implements an [http.Handler] that answers RPC requests. func (server *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) { if req.Method != "CONNECT" { w.Header().Set("Content-Type", "text/plain; charset=utf-8")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/prepare_quantize_dynamic_range.cc
} return true; } return false; } // Insert CastOp which is used to for converting float32 ConstantOp into // float16 quantization. If there is an existing CastOp connected to the // ConstantOp, the quantize_op will be rewired to the existing CastOp. This // guarantees at most one CastOp is created for float32 to float16 conversion.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 20.8K bytes - Viewed (0)