Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 513 for Completer (0.11 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

        writeHeader(PREFIX_CLEAN, upstreamSize, metadata.size.toLong())
        file!!.channel.force(false)
    
        // This file is complete.
        synchronized(this@Relay) {
          complete = true
        }
    
        upstream?.closeQuietly()
        upstream = null
      }
    
      fun metadata(): ByteString = metadata
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  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. 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)
  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. 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)
  8. 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)
  9. 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)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

       */
      private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()
    
      /**
       * Results are posted here as they occur. The find job is done when either one plan completes
       * successfully or all plans fail.
       */
      private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>())
    
      override fun find(): RealConnection {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top