Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 1,276 for timeIt (0.05 seconds)

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

  1. src/test/java/jcifs/netbios/NameServiceClientImplTest.java

        }
    
        @Test
        @DisplayName("Should handle broadcast resolution timeout")
        @Timeout(value = 1, unit = TimeUnit.SECONDS) // Very short timeout
        void testBroadcastTimeout() {
            // Configure for broadcast-only resolution with very short timeout
            when(mockConfig.getResolveOrder()).thenReturn(Arrays.asList(ResolverType.RESOLVER_BCAST));
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 11K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

            }
        }
    
        /**
         * Handle a lease break with timeout
         *
         * @param key lease key
         * @param newState new lease state
         * @param timeoutSeconds timeout in seconds (0 or negative uses default)
         */
        public void handleLeaseBreakWithTimeout(Smb2LeaseKey key, int newState, int timeoutSeconds) {
            // Use default timeout if not specified or invalid
            if (timeoutSeconds <= 0) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  3. src/test/java/jcifs/util/transport/ConnectionTimeoutExceptionTest.java

        void testThrowableConstructor() {
            // Test the constructor with a cause
            Throwable cause = new RuntimeException("Root cause of timeout");
            ConnectionTimeoutException exception = new ConnectionTimeoutException(cause);
            assertEquals("java.lang.RuntimeException: Root cause of timeout", exception.getMessage(),
                    "Message should be derived from the cause");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      final void joinPool(ExecutorService exec) throws InterruptedException {
        try {
          exec.shutdown();
          assertTrue(
              "ExecutorService did not terminate in a timely manner",
              exec.awaitTermination(2 * LONG_DELAY_MS, MILLISECONDS));
        } catch (SecurityException ok) {
          // Allowed in case test doesn't have privs
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  6. src/main/java/jcifs/internal/smb2/persistent/HandleInfo.java

        }
    
        /**
         * Get the timeout
         * @return the timeout in milliseconds
         */
        public long getTimeout() {
            return timeout;
        }
    
        /**
         * Get the create time
         * @return the create time
         */
        public long getCreateTime() {
            return createTime;
        }
    
        /**
         * Get the last access time
         * @return the last access time
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 02:21:31 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

        delegate().putLast(e);
      }
    
      @Override
      public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerFirst(e, timeout, unit);
      }
    
      @Override
      public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerLast(e, timeout, unit);
      }
    
      @Override
      public E takeFirst() throws InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/job/SuggestJob.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
    - 10.5K bytes
    - Click Count (0)
  9. internal/deadlineconn/deadlineconn_test.go

    		}
    		received := string(b)
    		if received != "message one\n" {
    			t.Errorf(`server: expected: "message one\n", got: %v`, received)
    			return
    		}
    
    		// Wait for more than read timeout to simulate processing.
    		time.Sleep(3 * time.Second)
    
    		_, terr = deadlineconn.Read(b)
    		if terr != nil {
    			t.Errorf("failed to read from client. %v", terr)
    			return
    		}
    		received = string(b)
    		if received != "message two\n" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 11 17:15:17 GMT 2024
    - 4.8K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          assertThat(lastMethodCalled).isEqualTo(method);
        }
    
        void assertMethodWithTimeout(String method, long timeout, TimeUnit unit) {
          assertLastMethodCalled(method + "Timeout");
          assertEquals(unit.toMillis(timeout), lastTimeoutInMillis);
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          lastMethodCalled = "awaitTermination";
          return false;
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 10.1K bytes
    - Click Count (0)
Back to Top