Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 365 for timeouts (0.14 sec)

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

        resultFuture = buildChainingFuture(inputFuture);
        listener = new MockFutureListener(resultFuture);
      }
    
      public void testFutureGetBeforeCallback() throws Exception {
        // Verify that get throws a timeout exception before the callback is called.
        assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS));
      }
    
      public void testFutureGetThrowsWrappedException() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/NetShareEnum.java

            name = new String( "\\PIPE\\LANMAN" );
            maxParameterCount = 8;
    
    //        maxDataCount = 4096; why was this set?
            maxSetupCount = (byte)0x00;
            setupCount = 0;
            timeout = 5000;
        }
    
        int writeSetupWireFormat( byte[] dst, int dstIndex ) {
            return 0;
        }
        int writeParametersWireFormat( byte[] dst, int dstIndex ) {
            int start = dstIndex;
            byte[] descr;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

        public boolean isShutdown() {
          return false;
        }
    
        @Override
        public boolean isTerminated() {
          return false;
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          return false;
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

        public boolean isShutdown() {
          return false;
        }
    
        @Override
        public boolean isTerminated() {
          return false;
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          return false;
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.2K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:40:56 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/bucket-quota.go

    	sys.Init(newObjectLayerFn())
    
    	dui, err := bucketStorageCache.GetWithCtx(ctx)
    	timedout := OperationTimedOut{}
    	if err != nil && !errors.Is(err, context.DeadlineExceeded) && !errors.As(err, &timedout) {
    		if len(dui.BucketsUsage) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        private final AbstractFuture<?> future;
        private final long timeout;
        private final TimeUnit unit;
        private Exception exception;
        private volatile long startTime;
        private long timeSpentBlocked;
    
        TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) {
          this.future = future;
          this.timeout = timeout;
          this.unit = unit;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_experimental.cc

            "Coordination service is not enabled.");
        return;
      }
      absl::Duration timeout;
      if (timeout_in_ms > 0) {
        timeout = absl::Milliseconds(timeout_in_ms);
      } else {
        // Block until the key-value is set or the worker shuts down.
        timeout = absl::InfiniteDuration();
      }
      auto status_or_value = coord_agent->GetKeyValue(key, timeout);
      status->status = status_or_value.status();
      if (!status_or_value.ok()) return;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Futures.java

            return applyTransformation(input.get());
          }
    
          @Override
          public O get(long timeout, TimeUnit unit)
              throws InterruptedException, ExecutionException, TimeoutException {
            return applyTransformation(input.get(timeout, unit));
          }
    
          private O applyTransformation(I input) throws ExecutionException {
            try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  10. buildscripts/verify-healing-empty-erasure-set.sh

    	"${MINIO[@]}" --address ":$((start_port + 3))" $args >"${WORK_DIR}/dist-minio-server3.log" 2>&1 &
    	pid3=$!
    	disown $pid3
    
    	export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))"
    
    	timeout 15m /tmp/mc ready myminio || fail
    
    	# Wait for all drives to be online and formatted
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
Back to top