- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 238 for Shutdown (0.05 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
override fun peek(): MockResponse = throw UnsupportedOperationException("unexpected call") fun enqueueResponse(response: MockResponse) { delegate.enqueue(response.wrap()) } override fun shutdown() { delegate.close() } fun setFailFast(failFast: Boolean) { delegate.setFailFast(failFast) } fun setFailFast(failFastResponse: MockResponse?) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 1.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
protected String filterPathEncoding; /** An array of supported language codes. */ protected String[] supportedLanguages; /** A list of shutdown hooks to be executed on system shutdown. */ protected List<Runnable> shutdownHookList = new ArrayList<>(); /** The previous state of the cluster. */ protected AtomicInteger previousClusterState = new AtomicInteger(0);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 36.6K bytes - Viewed (0) -
src/packaging/common/systemd/fess.service
# Set to "infinity" if you use the 'bootstrap.mlockall: true' option # in fess.yml and 'MAX_LOCKED_MEMORY=unlimited' in ${packaging.env.file} #LimitMEMLOCK=infinity # Shutdown delay in seconds, before process is tried to be killed with KILL (if configured) TimeoutStopSec=20 [Install] WantedBy=multi-user.target
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 1.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
} /** * Shutdown the channel manager */ public void shutdown() { scheduler.shutdown(); failover.shutdown(); for (ChannelInfo channel : channels.values()) { try { channel.getTransport().close();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/DevServer.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt
Proxy( 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: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 7.6K bytes - Viewed (0) -
cmd/erasure.go
func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker { return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...) } // Shutdown function for object storage interface. func (er erasureObjects) Shutdown(ctx context.Context) error { // Add any object layer shutdown activities here. closeStorageDisks(er.getDisks()...) return nil } // defaultWQuorum write quorum based on setDriveCount and defaultParityCount
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHook.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 1.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
executor.shutdown(); assertFalse(awaitTerminationUninterruptibly(executor, 1000, MILLISECONDS)); assertFalse(executor.isTerminated()); assertInterrupted(); } public void testTryAwaitTerminationInfiniteTimeout() { ExecutorService executor = newFixedThreadPool(1); requestInterruptIn(500); executor.execute(new SleepTask(1000)); executor.shutdown();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 31.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java
leaseManager = new LeaseManager(mockContext); } @AfterEach void tearDown() { if (leaseManager != null) { leaseManager.shutdown(); } } @Test @DisplayName("Should request new lease") void testRequestLease() { String path = "/share/file.txt"; int requestedState = Smb2LeaseState.SMB2_LEASE_FULL;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 13.2K bytes - Viewed (0)