Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 397 for timedOut (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

          Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) throws X {
        // TODO(cpovirk): benchmark a version of this method that accepts a GetCheckedTypeValidator
        bestGetCheckedTypeValidator().validateClass(exceptionClass);
        try {
          return future.get(timeout, unit);
        } catch (InterruptedException e) {
          currentThread().interrupt();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. cmd/globals.go

    	globalDomainIPs   set.StringSet // Root domain IP address(s) for a distributed MinIO deployment
    
    	globalOperationTimeout       = newDynamicTimeout(10*time.Minute, 5*time.Minute) // default timeout for general ops
    	globalDeleteOperationTimeout = newDynamicTimeout(5*time.Minute, 1*time.Minute)  // default time for delete ops
    
    	globalBucketObjectLockSys *BucketObjectLockSys
    	globalBucketQuotaSys      *BucketQuotaSys
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  3. src/main/java/jcifs/internal/smb1/trans/TransWaitNamedPipe.java

         */
        public TransWaitNamedPipe(final Configuration config, final String pipeName) {
            super(config, SMB_COM_TRANSACTION, TRANS_WAIT_NAMED_PIPE);
            this.name = pipeName;
            this.timeout = 0xFFFFFFFF;
            this.maxParameterCount = 0;
            this.maxDataCount = 0;
            this.maxSetupCount = (byte) 0x00;
            this.setupCount = 2;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. .github/workflows/mint.yml

    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      mint-test:
        runs-on: mint
        timeout-minutes: 120
        steps:
          - name: cleanup #https://github.com/actions/checkout/issues/273
            run: |
              sudo -S rm -rf ${GITHUB_WORKSPACE}
              mkdir ${GITHUB_WORKSPACE}
          - name: checkout-step
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/TransCallNamedPipe.java

            name = pipeName;
            pipeData = data;
            pipeDataOff = off;
            pipeDataLen = len;
            command = SMB_COM_TRANSACTION;
            subCommand = TRANS_CALL_NAMED_PIPE;
            timeout = 0xFFFFFFFF;
            maxParameterCount = 0;
            maxDataCount = 0xFFFF;
            maxSetupCount = (byte) 0x00;
            setupCount = 2;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/Monitor.java

       * threads take special action by participating in the signal-passing game.
       */
    
      /*
       * Timeout handling is intricate, especially given our ambitious goals:
       * - Avoid underflow and overflow of timeout values when specified timeouts are close to
       *   Long.MIN_VALUE or Long.MAX_VALUE.
       * - Favor responding to interrupts over timeouts.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          } finally {
            lockStateChanged(this);
          }
        }
    
        @Override
        public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException {
          aboutToAcquire(this);
          try {
            return super.tryLock(timeout, unit);
          } finally {
            lockStateChanged(this);
          }
        }
    
        @Override
        public void unlock() {
          try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/exception/LdapConfigurationExceptionTest.java

        }
    
        public void test_newlineCharactersInMessage() {
            // Test with newline characters in message
            String message = "LDAP error:\n- Connection failed\n- Invalid credentials\n- Timeout";
            LdapConfigurationException exception = new LdapConfigurationException(message);
    
            assertEquals(message, exception.getMessage());
            assertTrue(exception.getMessage().contains("\n"));
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      // TODO(lukes): Consider throwing InterruptedException when appropriate.
      @Override
      @ParametricNullness
      public V get() {
        return value;
      }
    
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit) throws ExecutionException {
        checkNotNull(unit);
        return get();
      }
    
      @Override
      public boolean isCancelled() {
        return false;
      }
    
      @Override
      public boolean isDone() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  10. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

              IllegalStateException("Invalid content-type: ${body.contentType()}"),
              response,
            )
            return
          }
    
          // This is a long-lived response. Cancel full-call timeouts.
          call?.timeout()?.cancel()
    
          // Replace the body with a stripped one so the callbacks can't see real data.
          val response = response.stripBody()
    
          val reader = ServerSentEventReader(body.source(), this)
          try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top