Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 1,216 for timeIt (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

      private static void runUntimedInterruptsTest(int times)
          throws InterruptedException, ExecutionException, TimeoutException {
        SettableFuture<String> future = SettableFuture.create();
        FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false);
    
        runNInterruptsTest(times, future, interruptReporter);
      }
    
      private static void runTimedInterruptsTest(int times)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                }
                if (exitValue != 0) {
                    final StringBuilder out = new StringBuilder();
                    if (processTimeout) {
                        out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                    }
                    out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                    throw new JobProcessingException(out.toString());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

            return source.timeout().intersectWith(timeout) {
              when (val limit = currentPartBytesRemaining(maxByteCount = byteCount)) {
                0L -> -1L
    
                // No more bytes in this part.
                else -> source.read(sink, limit)
              }
            }
          }
    
          override fun timeout(): Timeout = timeout
        }
    
        /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.3K bytes
    - Click Count (0)
  4. cmd/namespace-lock.go

    // Lock - block until write lock is taken or timeout has occurred.
    func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
    	lockSource := getSource(2)
    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

      }
    
      /**
       * Test to ensure we throw a read timeout on responses that are progressing too slowly.  For this
       * case, we take a 2KiB body and throttle it to 1KiB/second.  We set the read timeout to half a
       * second.  If our implementation is acting correctly, it will throw, as a byte doesn't arrive in
       * time.
       */
      @Test
      fun readTimeoutOnSlowConnection() {
        val body = repeat('y', 2048)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 67.5K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/SimpleMemoryManagementTest.java

    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.Timeout;
    import org.mockito.Mockito;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    import jcifs.Credentials;
    
    /**
     * Simple memory management tests to validate basic resource cleanup functionality
     */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java

                testRequest.setOverrideTimeout(timeout);
                assertEquals(timeout, testRequest.getOverrideTimeout());
            }
    
            @Test
            @DisplayName("setOverrideTimeout should handle null value")
            void testSetOverrideTimeoutNull() {
                testRequest.setOverrideTimeout(5000);
                testRequest.setOverrideTimeout(null);
                assertNull(testRequest.getOverrideTimeout());
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * ({@code this}) will be cancelled and interrupted.
       *
       * @param timeout when to time out the future
       * @param unit the time unit of the time parameter
       * @param scheduledExecutor The executor service to enforce the timeout.
       */
      @J2ktIncompatible
      @GwtIncompatible // ScheduledExecutorService
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public final FluentFuture<V> withTimeout(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/fscc/FsctlPipeWaitRequest.java

         *
         * @param name the pipe name to wait for
         * @param timeout the timeout value in milliseconds
         */
        public FsctlPipeWaitRequest(final String name, final long timeout) {
            this.nameBytes = name.getBytes(StandardCharsets.UTF_16LE);
            this.timeoutSpecified = true;
            this.timeout = timeout;
        }
    
        /**
         * {@inheritDoc}
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/ResponseJvmTest.kt

            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              check(!closed)
              return data.read(sink, byteCount)
            }
    
            override fun timeout(): Timeout = Timeout.NONE
          }
        return source.buffer().asResponseBody(null, -1)
      }
    
      private fun newResponse(
        responseBody: ResponseBody,
        code: Int = 200,
        fn: Response.Builder.() -> Unit = {},
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 2.8K bytes
    - Click Count (0)
Back to Top