Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 483 for Completer (0.07 sec)

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

                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.cancel(true);
                  if (!future.isDone()) {
                    errorMessage.set("Cancel call exited before future was complete.");
                  }
                }
              });
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
       * future to finish, and when it completes, run the listeners. This implementation will wait on
       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
       * <p>If the delegate future is interrupted or throws an unexpected unchecked exception, the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api.h

    // will block till the operation that produces `h` has completed.
    TF_CAPI_EXPORT extern const char* TFE_TensorHandleDeviceName(
        TFE_TensorHandle* h, TF_Status* status);
    
    // Returns the name of the device in whose memory `h` resides.
    //
    // This function will block till the operation that produces `h` has completed.
    TF_CAPI_EXPORT extern const char* TFE_TensorHandleBackingDeviceName(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 22.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

      private TimeoutFuture(ListenableFuture<V> delegate) {
        this.delegateRef = Preconditions.checkNotNull(delegate);
      }
    
      /** A runnable that is called when the delegate or the timer completes. */
      private static final class Fire<V extends @Nullable Object> implements Runnable {
        @CheckForNull @LazyInit TimeoutFuture<V> timeoutFutureRef;
    
        Fire(TimeoutFuture<V> timeoutFuture) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	type poolInfo struct {
    		position     int
    		completed    bool
    		decomStarted bool // started but not finished yet
    	}
    
    	rememberedPools := make(map[string]poolInfo)
    	for idx, pool := range p.Pools {
    		complete := false
    		decomStarted := false
    		if pool.Decommission != nil {
    			if pool.Decommission.Complete {
    				complete = true
    			}
    			decomStarted = true
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      }
    
      public void testListeningDecorator_scheduleSuccess() throws Exception {
        final CountDownLatch completed = new CountDownLatch(1);
        ScheduledThreadPoolExecutor delegate =
            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	defer func() {
    		if rinfo.ReplicationStatus == replication.Completed && tgt.ResetID != "" && dobj.OpType == replication.ExistingObjectReplicationType {
    			rinfo.ResyncTimestamp = fmt.Sprintf("%s;%s", UTCNow().Format(http.TimeFormat), tgt.ResetID)
    		}
    	}()
    
    	if dobj.VersionID == "" && rinfo.PrevReplicationStatus == replication.Completed && dobj.OpType != replication.ExistingObjectReplicationType {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. docs/bucket/replication/DESIGN.md

    If an object meets replication rules as set in the replication configuration, `X-Amz-Replication-Status` is first set to `PENDING` as the PUT operation completes and replication is queued (unless synchronous replication is in place). After replication is performed, the metadata on the source object version changes to `COMPLETED` or `FAILED` depending on whether replication succeeded. The object version on the target shows `X-Amz-Replication-Status` of `REPLICA`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top