- Sort Score
- Result 10 results
- Languages All
Results 671 - 680 of 861 for handles (0.07 sec)
-
cmd/metrics-v3.go
// metrics required a list of buckets to be passed to the loader, and the list // of buckets is not known until the request is made. So we keep a separate // map for bucket metrics and handle them specially. // Add the serverName and poolIndex labels to all non-cluster metrics. // // Also create metric group maps and set the cache. metricsCache := newMetricsCache()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 02 00:55:27 UTC 2024 - 13.6K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/FindBrokenInternalLinks.java
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Aug 21 08:08:05 UTC 2024 - 9.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
/** * Following the contract of {@link AbstractQueuedSynchronizer} we create a private subclass to * hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls * as well as to handle state changes in a thread-safe manner. The current state of the future * is held in the Sync state, and the lock is released whenever the state changes to {@link * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ElevateWordService.java
csvWriter.writeValues(list); elevateWordBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<ElevateWord>() { @Override public void handle(final ElevateWord entity) { final List<String> list = new ArrayList<>(); final String permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
openNetns, err := s.getOrOpenNetns(pod, netNs) if err != nil { return err } // If true, the pod will run in 'ingress mode'. This is intended to be used for "ingress" type workloads which handle // non-mesh traffic on inbound, and send to the mesh on outbound. // Basically, this just disables inbound redirection.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1alpha1/generated.proto
} // VolumeAttachmentSpec is the specification of a VolumeAttachment request. message VolumeAttachmentSpec { // attacher indicates the name of the volume driver that MUST handle this // request. This is the name returned by GetPluginName(). optional string attacher = 1; // source represents the volume that should be attached. optional VolumeAttachmentSource source = 2;
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 9.4K bytes - Viewed (0) -
guava/src/com/google/common/net/InetAddresses.java
* cause DNS services to be accessed. For this reason, you should prefer these methods as much as * possible over their JDK equivalents whenever you are expecting to handle only IP address string * literals -- there is no blocking DNS penalty for a malformed string. * * <p>When dealing with {@link Inet4Address} and {@link Inet6Address} objects as byte arrays (vis.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 47.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
interceptorThrowsRuntimeExceptionAsynchronous(true) } /** * When an interceptor throws an unexpected exception, asynchronous calls are canceled. The * exception goes to the uncaught exception handler. */ private fun interceptorThrowsRuntimeExceptionAsynchronous(network: Boolean) { val boom = RuntimeException("boom!") addInterceptor(network) { chain: Interceptor.Chain? -> throw boom }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
cmd/storage-rest_test.go
endpoint.SetIdx = 0 endpoint.DiskIdx = 0 poolEps := []PoolEndpoints{{ Endpoints: Endpoints{endpoint}, }} poolEps[0].SetCount = 1 poolEps[0].DrivesPerSet = 1 // Register handlers on newly created servers registerStorageRESTHandlers(tg.Mux[0], poolEps, tg.Managers[0]) registerStorageRESTHandlers(tg.Mux[1], poolEps, tg.Managers[1]) storage := globalLocalSetDrives[0][0][0]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 11.5K bytes - Viewed (0)