Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 647 for Complete (0.05 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.java

        extends AbstractFuture.TrustedFuture<OutputT> {
      // Lazily initialized the first time we see an exception; not released until all the input futures
      // & this future completes. Released when the future releases the reference to the running state
      private @Nullable Set<Throwable> seenExceptions = null;
      private int remaining;
    
      AggregateFutureState(int remainingFutures) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/transport/RequestTimeoutException.java

     */
    package jcifs.util.transport;
    
    /**
     * Exception thrown when a request times out during SMB communication.
     * Indicates that a request could not be completed within the specified timeout period.
     *
     * @author mbechler
     */
    public class RequestTimeoutException extends TransportException {
    
        /**
         *
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2K bytes
    - Viewed (0)
  3. samples/guide/src/main/java/okhttp3/recipes/Progress.java

          boolean firstUpdate = true;
    
          @Override public void update(long bytesRead, long contentLength, boolean done) {
            if (done) {
              System.out.println("completed");
            } else {
              if (firstUpdate) {
                firstUpdate = false;
                if (contentLength == -1) {
                  System.out.println("content-length: unknown");
                } else {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 3.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/TestLocking.java

            }
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti].join();
                logger.info(threads[ti].getName());
            }
    
            logger.info("Test completed");
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  5. CONTRIBUTING.md

    - To run `make verifiers`
    - To squash your commits into a single commit. `git rebase -i`. It's okay to force update your pull request.
    - To run `make test` and `make build` completes.
    
    ### Commit changes
    
    After verification, commit your changes. This is a [great post](https://chris.beams.io/posts/git-commit/) on how to write useful commit messages
    
    ```
    git commit -am 'Add some feature'
    ```
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/SettableFuture.java

     */
    @GwtCompatible
    public final class SettableFuture<V extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<V> {
      /**
       * Creates a new {@code SettableFuture} that can be completed or cancelled by a later method call.
       */
      public static <V extends @Nullable Object> SettableFuture<V> create() {
        return new SettableFuture<>();
      }
    
      @CanIgnoreReturnValue
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. docs/kms/IAM.md

       So, both - the old and new credentials - had to be present at the same time during a rotation
       and the old credentials had to be removed once the rotation completed. This process is now gone.
       The root credentials can now be changed easily.
    
    > Does this mean I need an enterprise KMS setup to run MinIO (securely)?
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. src/test/java/jcifs/dcerpc/msrpc/SamrAliasHandleTest.java

            // We cannot directly access private fields of MsrpcSamrOpenAlias or its superclass
            // Instead, we verify the interaction with the DcerpcHandle and the return value.
            // The fact that the constructor completes without exception and sets 'opened' to true
            // implies the correct parameters were used internally.
        }
    
        @Test
        void constructor_shouldThrowSmbExceptionOnOpenFailure() throws IOException {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    	StartTime time.Time   `msg:"startTs"` // Time at which rebalance-start was issued
    	EndTime   time.Time   `msg:"stopTs"`  // Time at which rebalance operation completed or rebalance-stop was called
    	Status    rebalStatus `msg:"status"`  // Current state of rebalance operation. One of Started|Stopped|Completed|Failed.
    }
    
    // rebalanceMeta contains information pertaining to an ongoing rebalance operation.
    type rebalanceMeta struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  10. cmd/rebalance-admin.go

    		eta := time.Duration(totalBytesToRebal * float64(elapsed) / float64(ps.Bytes))
    		if !ps.Info.EndTime.IsZero() {
    			stopTime = ps.Info.EndTime
    		}
    
    		if !stopTime.IsZero() { // rebalance is stopped or completed
    			elapsed = stopTime.Sub(ps.Info.StartTime)
    			eta = 0
    		}
    
    		r.Pools[i].Progress = rebalPoolProgress{
    			NumObjects:  ps.NumObjects,
    			NumVersions: ps.NumVersions,
    			Bytes:       ps.Bytes,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
Back to top