Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 483 for Completer (0.09 sec)

  1. docs/distributed/samples/bootstrap-complete.ldif

    Shubhendu <******@****.***> 1726156740 +0530
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 15:59:00 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

      internal var activeTask: Task? = null
    
      /** Scheduled tasks ordered by [Task.nextExecuteNanoTime]. */
      internal val futureTasks = mutableListOf<Task>()
    
      /** True if the [activeTask] should be canceled when it completes. */
      internal var cancelActiveTask = false
    
      /**
       * Returns a snapshot of tasks currently scheduled for execution. Does not include the
       * currently-executing task unless it is also scheduled for future execution.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. cmd/bucket-replication_test.go

    			expectedSync: true,
    		},
    		{ // 4. replication status Complete
    			name: "existing object replication on object in Completed replication status",
    			info: ObjectInfo{
    				Size:                      100,
    				ReplicationStatusInternal: "arn1:COMPLETED",
    				ReplicationStatus:         replication.Completed,
    				VersionID:                 "a3348c34-c352-4498-82f0-1098e8b34df9",
    			},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>Cancelling a delegate future propagates to input futures once all the delegates complete,
       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
       * too.
       *
       * @since 17.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

          return callDone(e)
        }
    
        return e
      }
    
      /**
       * Complete this call. This should be called once these properties are all false:
       * [requestBodyOpen], [responseBodyOpen], and [expectMoreExchanges].
       *
       * This will release the connection if it is still held.
       *
       * It will also notify the listener that the call completed; either successfully or
       * unsuccessfully.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *
       * <p>The returned {@link Future} is completed when the pipeline's computation completes, or when
       * the pipeline is cancelled.
       *
       * <p>All objects the pipeline has captured for closing will begin to be closed asynchronously
       * <b>after</b> the returned {@code Future} is done: the future completes before closing starts,
       * rather than once it has finished.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle_test.go

    	}{
    		{
    			// restore in progress
    			restoreStatus: ongoingRestoreObj(),
    			ondisk:        false,
    		},
    		{
    			// restore completed but expired
    			restoreStatus: completedRestoreObj(time.Now().Add(-time.Hour)),
    			ondisk:        false,
    		},
    		{
    			// restore completed
    			restoreStatus: completedRestoreObj(time.Now().Add(time.Hour)),
    			ondisk:        true,
    		},
    	}
    
    	for i, tc := range testCases {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SpnegoContext.java

            if ( !this.completed ) {
                throw new CIFSException("Context is not established");
            }
            this.mechContext.verifyMIC(data, mic);
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.smb.SSPContext#isMICAvailable()
         */
        @Override
        public boolean isMICAvailable () {
            if ( !this.completed ) {
                return false;
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Jan 04 04:18:31 UTC 2021
    - 14.8K bytes
    - Viewed (0)
  9. .github/PULL_REQUEST_TEMPLATE

    + The PR title is formatted as follows: `net/http: frob the quux before blarfing`
      + The package name goes before the colon
      + The part after the colon uses the verb tense + phrase that completes the blank in,
        "This change modifies Go to ___________"
      + Lowercase verb after the colon
      + No trailing period
      + Keep the title as short as possible. ideally under 76 characters or shorter
    + No Markdown
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Feb 21 02:07:46 UTC 2018
    - 1.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone()
       * complete} or, if the computation is already complete, immediately.
       *
       * <p>There is no guaranteed ordering of execution of listeners, but any listener added through
       * this method is guaranteed to be called once the computation is complete.
       *
       * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top