- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 198 for isShutdown (0.37 sec)
-
okhttp/src/test/java/okhttp3/SocksProxy.kt
Proxy.Type.SOCKS, InetSocketAddress.createUnresolved("localhost", serverSocket!!.localPort), ) } fun connectionCount(): Int = connectionCount.get() fun shutdown() { serverSocket!!.close() executor.shutdown() if (!executor.awaitTermination(5, TimeUnit.SECONDS)) { throw IOException("Gave up waiting for executor to shut down") } } private fun service(from: Socket) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz.go
return s.livezRegistry.addDelayedHealthChecks(delay, checks...) } // addReadyzShutdownCheck is a convenience function for adding a readyz shutdown check, so // that we can register that the api-server is no longer ready while we attempt to gracefully // shutdown. func (s *GenericAPIServer) addReadyzShutdownCheck(stopCh <-chan struct{}) error { return s.AddReadyzChecks(healthz.NewShutdownHealthz(stopCh)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 6K bytes - Viewed (0) -
platforms/core-execution/snapshots/src/test/groovy/org/gradle/internal/vfs/impl/DefaultFileSystemAccessConcurrencyTest.groovy
def updatedLocation = dir.file(num).file("in-dir.txt") assertIsFileSnapshot(read(updatedLocation), updatedLocation) } cleanup: executorService.shutdown() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:34:50 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
func (ec *ephemeralController) runWorker(ctx context.Context) { for ec.processNextWorkItem(ctx) { } } func (ec *ephemeralController) processNextWorkItem(ctx context.Context) bool { key, shutdown := ec.queue.Get() if shutdown { return false } defer ec.queue.Done(key) err := ec.syncHandler(ctx, key) if err == nil { ec.queue.Forget(key) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/ManualEvictionInMemoryCacheTest.groovy
latch.await() println "Created key ${key}" key } as Supplier<String>) } } executor.shutdown() executor.awaitTermination(2, TimeUnit.SECONDS) then: executor.isTerminated() concurrency.times { String key = "key${it}" assert cache.getIfPresent(key) == key
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
ConditionalExecution<?> operation; while ((operation = waitForNextOperation()) != null) { runBatch(operation); } } finally { shutDown(); } } private ConditionalExecution<?> waitForNextOperation() { lock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
src/net/rpc/client.go
codec ClientCodec reqMutex sync.Mutex // protects following request Request mutex sync.Mutex // protects following seq uint64 pending map[uint64]*Call closing bool // user has called Close shutdown bool // server has told us to stop } // A ClientCodec implements writing of RPC requests and // reading of RPC responses for the client side of an RPC session.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
pkg/kubelet/events/event.go
SuccessfulAttachVolume = "SuccessfulAttachVolume" SuccessfulMountVolume = "SuccessfulMountVolume" NodeRebooted = "Rebooted" NodeShutdown = "Shutdown" ContainerGCFailed = "ContainerGCFailed" ImageGCFailed = "ImageGCFailed" FailedNodeAllocatableEnforcement = "FailedNodeAllocatableEnforcement"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 3.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/TrackingHttpHandler.java
*/ WaitPrecondition getWaitPrecondition(); /** * Releases any blocked requests, in preparation for shutdown. */ void cancelBlockedRequests(); /** * Asserts that this handler has been completed successfully. */ void assertComplete(Collection<Throwable> failures);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.9K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
failingDNSServer.Server.PacketConn.LocalAddr().String(), workingDNSServer.Server.PacketConn.LocalAddr().String(), } t.Cleanup(func() { errW := workingDNSServer.Shutdown() errF := failingDNSServer.Shutdown() if errW != nil || errF != nil { t.Logf("failed shutting down fake dns servers") } }) meshNetworks := mesh.NewFixedNetworksWatcher(nil) xdsUpdater := xdsfake.NewFakeXDS()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0)