Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 361 for sekondi (0.51 sec)

  1. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

            });
            th.start();
    
            final CountDownLatch latch = new CountDownLatch(1);
            deferred.promise().then(response -> latch.countDown());
            assertTrue(latch.await(10, TimeUnit.SECONDS));
        }
    
        @Test
        public void test_doneAfterResolve() throws Exception {
            final Deferred<SuggestResponse> deferred = new Deferred<>();
    
            Thread th = new Thread(() -> {
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sat Mar 15 06:51:20 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/CrawlJob.java

         * -2: use system default, -1: never expire, 0 or positive: expire after specified days.
         */
        protected int documentExpires = -2;
    
        /**
         * Hot thread monitoring interval in seconds.
         * -1: disabled, positive value: enable hot thread monitoring with specified interval.
         * Used for performance analysis and debugging of the crawler process.
         */
        protected int hotThreadInterval = -1;
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  3. docs/smb3-features/03-multi-channel-design.md

            
            // Schedule periodic health checks
            scheduler.scheduleAtFixedRate(this::performHealthCheck, 10, 10, TimeUnit.SECONDS);
            
            // Schedule interface discovery
            scheduler.scheduleAtFixedRate(this::discoverInterfaces, 0, 30, TimeUnit.SECONDS);
        }
        
        public void initializeMultiChannel() throws IOException {
            // Check server capability
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  4. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

        runTest {
          server.enqueue(
            MockResponse
              .Builder()
              .bodyDelay(5, TimeUnit.SECONDS)
              .body("abc")
              .build(),
          )
    
          val call = client.newCall(request)
    
          assertFailsWith<TimeoutCancellationException> {
            withTimeout(1.seconds) {
              call.executeAsync().use {
                withContext(Dispatchers.IO) {
                  it.body.string()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

                    }
                });
            }
    
            // Start all threads simultaneously
            startLatch.countDown();
    
            // Wait for completion
            assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout");
            executor.shutdown();
    
            // Then - Verify no exceptions occurred
            if (!exceptions.isEmpty()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

      }
    
      public void testTimeToLive_setTwice() {
        CacheBuilder<Object, Object> builder =
            CacheBuilder.newBuilder().expireAfterWrite(3600, SECONDS);
        assertThrows(IllegalStateException.class, () -> builder.expireAfterWrite(3600, SECONDS));
      }
    
      @GwtIncompatible // Duration
      public void testTimeToLive_setTwice_duration() {
        CacheBuilder<Object, Object> builder =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb1/com/SmbComQueryInformationResponseTest.java

            // Verify time was read correctly (accounting for UTime conversion)
            long readTime = (Long) getFieldValue(response, "lastWriteTime");
            // UTime is seconds since 1970, so we need to compare at second precision
            assertEquals(lastWriteTime / 1000, readTime / 1000);
        }
    
        @Test
        void testReadParameterWordsWireFormatWithZeroWordCount() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            createCacheBuilder().expireAfterWrite(99999, SECONDS),
            createCacheBuilder().maximumSize(SMALL_MAX_SIZE).expireAfterAccess(SMALL_MAX_SIZE, SECONDS),
            createCacheBuilder().maximumSize(SMALL_MAX_SIZE).expireAfterWrite(SMALL_MAX_SIZE, SECONDS));
      }
    
      /** Returns an iterable containing all combinations weakKeys and weak/softValues. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 115.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

        protected final ConcurrentHashMap<String, JobProcess> runningProcessMap = new ConcurrentHashMap<>();
    
        /** Timeout in seconds for process destruction */
        protected int processDestroyTimeout = 10;
    
        /** Timeout in seconds for stream closing operations */
        protected int streamCloseTimeout = 10;
    
        /**
         * Default constructor for ProcessHelper.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 06:54:47 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt

     * limitations under the License.
     */
    package okhttp3.internal.duplex
    
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.TimeUnit.SECONDS
    import okhttp3.MediaType
    import okhttp3.RequestBody
    import okio.BufferedSink
    import org.junit.jupiter.api.Assertions.assertTrue
    
    /** A duplex request body that keeps the provided sinks so they can be written to later.  */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.5K bytes
    - Viewed (0)
Back to top