- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 86 for Everything (0.34 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
return "value 4"; } }), executor); // Pause in step 2. step2Waiter.awaitStarted(); // Everything should still be open. assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_subgraphs_pass.cc
return Hash64Combine(OutputTensor::Hash()(s.first), InputTensor::Hash()(s.second)); } }; // TODO(phawkins) add a canonical copy of these operator names and refactor // everything to use it. static const char* const kArgOp = "_Arg"; static const char* const kRetValOp = "_Retval"; class Encapsulator { public: Encapsulator(string group_attribute, Graph const* graph_in)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 51K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirReferenceShortener.kt
} /** * Same as above, but for more general callable symbols. * * Currently only checks constructor calls, assuming `true` for everything else. */ private fun importBreaksExistingReferences(callableToImport: FirCallableSymbol<*>, importAllInParent: Boolean): Boolean { if (callableToImport is FirConstructorSymbol) {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Fri Jun 07 16:54:07 UTC 2024 - 69.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
*/ fun protocols(protocols: List<Protocol>) = apply { // Create a private copy of the list. val protocolsCopy = protocols.toMutableList() // Validate that the list has everything we require and nothing we forbid. require(Protocol.H2_PRIOR_KNOWLEDGE in protocolsCopy || HTTP_1_1 in protocolsCopy) { "protocols must contain h2_prior_knowledge or http/1.1: $protocolsCopy" }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:21:33 UTC 2024 - 52K bytes - Viewed (0) -
cmd/peer-rest-server.go
for m := range re { if err := enc.Encode(m); err != nil { s.writeErrorResponse(w, errors.New("Encoding mrf failed: "+err.Error())) return } } } // DevNull - everything goes to io.Discard func (s *peerRESTServer) DevNull(w http.ResponseWriter, r *http.Request) { if !s.IsValid(w, r) { s.writeErrorResponse(w, errors.New("invalid request")) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
return "value 4"; } }), executor); // Pause in step 2. step2Waiter.awaitStarted(); // Everything should still be open. assertStillOpen(closeable1, closeable2, closeable3, closeable4); // Cancel step 3, resume step 2, and pause in step 4.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
go r.tearDown(oldInfo) } } // removeDeadStorage removes REST storage that isn't being used func (r *crdHandler) removeDeadStorage() { allCustomResourceDefinitions, err := r.crdLister.List(labels.Everything()) if err != nil { utilruntime.HandleError(err) return } r.customStorageLock.Lock() defer r.customStorageLock.Unlock() storageMap := r.customStorage.Load().(crdStorageMap)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
src/cmd/go/internal/modload/load.go
// checking whether modules are required directly for the purposes of pruning is // less important in vendor mode: if we were able to load the package, we have // everything we need to build the package, and dependencies' tests are pruned out // of the vendor directory anyway. continue } if mg, err := rs.Graph(ctx); err != nil { return false, err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 14:56:56 UTC 2024 - 84K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// a) Endpoints are any IP's outside the cluster ==> Choose NodeIP as the SourceVIP // b) Endpoints are IP addresses of a remote node => Choose NodeIP as the SourceVIP // c) Everything else (Local POD's, Remote POD's, Node IP of current node) ==> Choose the configured SourceVIP if strings.EqualFold(proxier.network.networkType, NETWORK_TYPE_OVERLAY) && !ep.IsLocal() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pilot/pkg/networking/core/listener.go
} } accessLogBuilder.setListenerAccessLog(opts.push, opts.proxy, res, istionetworking.ListenerClassGateway) return res } // isMatchAll returns true if this chain will match everything // This closely matches toFilterChainMatch func (chain *filterChainOpts) isMatchAll() bool { return (len(chain.sniHosts) == 0 || slices.Contains(chain.sniHosts, "*")) && len(chain.applicationProtocols) == 0 &&
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0)