Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 74 for 250s (0.01 sec)

  1. src/test/java/org/codelibs/fess/suggest/settings/SuggestSettingsBuilderTest.java

                    .addInitialSettings("custom.key2", 42)
                    .scrollTimeout("100s")
                    .searchTimeout("50s")
                    .indexTimeout("200s")
                    .bulkTimeout("300s")
                    .indicesTimeout("150s")
                    .clusterTimeout("250s");
    
            SuggestSettings settings = builder.build(client, id);
    
            assertNotNull(settings);
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Sep 01 13:33:03 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  2. src/test/java/jcifs/tests/persistent/HandleReconnectorTest.java

        private HandleInfo testHandle;
    
        @BeforeEach
        public void setUp() {
            MockitoAnnotations.openMocks(this);
            reconnector = new HandleReconnector(mockManager, 2, 50); // 2 retries, 50ms delay
    
            HandleGuid guid = new HandleGuid();
            byte[] fileId = new byte[16];
            for (int i = 0; i < 16; i++) {
                fileId[i] = (byte) (i + 1);
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        val requestBodyDelay = 250L
        val responseHeadersStartDelay = 250L
        val responseBodyStartDelay = 250L
        val responseBodyEndDelay = 250L
    
        // Warm up the client so the timing part of the test gets a pooled connection.
        server.enqueue(MockResponse())
        val warmUpCall =
          client.newCallWithListener(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

     * connects successfully. This kicks off new attempts every 250 ms until a connect succeeds.
     */
    internal class FastFallbackExchangeFinder(
      override val routePlanner: RoutePlanner,
      private val taskRunner: TaskRunner,
    ) : ExchangeFinder {
      private val connectDelayNanos = TimeUnit.MILLISECONDS.toNanos(250L)
      private var nextTcpConnectAtNanos = Long.MIN_VALUE
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/AllocInfoTest.java

                // Given
                TestAllocInfo allocInfo = new TestAllocInfo(1000L, 250L);
    
                // When - calculate percentage free
                double percentFree = (allocInfo.getFree() * 100.0) / allocInfo.getCapacity();
    
                // Then
                assertEquals(25.0, percentFree, 0.001);
            }
    
            @Test
            @DisplayName("Should support available space check pattern")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  6. docs/config/README.md

    config set alias/ heal max_sleep=1s` and maximum concurrent requests allowed before we start slowing things down can be configured with `mc admin config set alias/ heal max_io=30` . By default the wait delay is `250ms` beyond 100 concurrent operations. This means the healer will sleep *250 milliseconds* at max for each heal operation if there are more than *100* concurrent client requests.
    
    In most setups this is sufficient to heal the content after drive replacements. Setting `max_sleep`...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.1K bytes
    - Viewed (1)
  7. okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

        server.enqueue(
          MockResponse
            .Builder()
            .headersDelay(250, TimeUnit.MILLISECONDS)
            .body(BIG_ENOUGH_BODY)
            .build(),
        )
        val request =
          Request
            .Builder()
            .url(server.url("/"))
            .post(sleepingRequestBody(250))
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(2000, TimeUnit.MILLISECONDS)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test performs two races:
       *
       *  * The first race is between plan0 and plan1, with a 250 ms head start for plan0.
       *  * The second race is between plan2 and plan3, with a 250 ms head start for plan2.
       *
       * We get plan0 and plan1 from the route planner.
       * We get plan2 as a follow-up to plan1, typically retry the same IP but different TLS.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/DefaultIntervalControllerTest.java

            params.put("delayMillisBeforeProcessing", 250L);
            // Not setting delayMillisAtNoUrlInQueue and delayMillisForWaitingNewUrl
    
            final DefaultIntervalController controller = new DefaultIntervalController(params);
    
            assertEquals(150L, controller.getDelayMillisAfterProcessing());
            assertEquals(500L, controller.getDelayMillisAtNoUrlInQueue()); // default
            assertEquals(250L, controller.getDelayMillisBeforeProcessing());
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:58:39 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/suggest/index/SuggestDeleteResponseTest.java

            assertEquals(0, response.getErrors().size());
        }
    
        @Test
        public void test_getTook() throws Exception {
            SuggestDeleteResponse response = new SuggestDeleteResponse(null, 250);
    
            assertEquals(250, response.getTook());
        }
    
        @Test
        public void test_hasError() throws Exception {
            SuggestDeleteResponse response1 = new SuggestDeleteResponse(null, 100);
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Thu Nov 13 00:40:54 UTC 2025
    - 3.9K bytes
    - Viewed (0)
Back to top