Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 283 for Binding (0.11 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

         * `CollectionFuture.values`). This might be a no-op: If this future completed during
         * handleAllCompleted(), they will already have been nulled out. But in the case of
         * whenAll*().call*(), this future may be pending until the callback runs -- or even longer in
         * the case of callAsync(), which waits for the callback's returned future to complete.
         */
        releaseResources(ALL_INPUT_FUTURES_PROCESSED);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. internal/s3select/message.go

    	// in Finish()
    
    	quitFlag := false
    	for !quitFlag {
    		select {
    		case data := <-writer.errCh:
    			quitFlag = true
    			// Flush collected records before sending error message
    			if !writer.flushRecords() {
    				break
    			}
    			writer.write(data)
    
    		case payload, ok := <-writer.payloadCh:
    			if !ok {
    				// payloadCh is closed by caller to
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    	for _, dobj := range deletedObjects {
    		if dobj.ObjectName == "" {
    			continue
    		}
    
    		if replicateDeletes && (dobj.DeleteMarkerReplicationStatus() == replication.Pending || dobj.VersionPurgeStatus() == Pending) {
    			// copy so we can re-add null ID.
    			dobj := dobj
    			if isDirObject(dobj.ObjectName) && dobj.VersionID == "" {
    				dobj.VersionID = nullVersionID
    			}
    			dv := DeletedObjectReplicationInfo{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/transport/Transport.java

    /**
     * This class simplifies communication for protocols that support
     * multiplexing requests. It encapsulates a stream and some protocol
     * knowledge (provided by a concrete subclass) so that connecting,
     * disconnecting, sending, and receiving can be syncronized
     * properly. Apparatus is provided to send and receive requests
     * concurrently.
     */
    
    public abstract class Transport implements Runnable, AutoCloseable {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int nextPermitsToAcquire = max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          int nextPermitsToAcquire = max(1, random.nextInt(permits));
          permits -= nextPermitsToAcquire;
          rateLimiter.acquire(nextPermitsToAcquire);
        }
        rateLimiter.acquire(1); // to repay for any pending debt
        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       (However, cancellation can prevent an <i>unstarted</i> task from running.) Therefore, the
     *       next task will wait for any running callable (or pending {@code Future} returned by an
     *       {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code
     *       cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. cmd/batch-rotate.go

    	batchKeyRotateAPIVersion           = "v1"
    	batchKeyRotateJobDefaultRetries    = 3
    	batchKeyRotateJobDefaultRetryDelay = 25 * time.Millisecond
    )
    
    // Start the batch key rottion job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /**
       * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link
       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  10. cmd/storage-datatypes.go

    	IsLatest bool `msg:"is"`
    
    	// Deleted is set when this FileInfo represents
    	// a deleted marker for a versioned bucket.
    	Deleted bool `msg:"del"`
    
    	// TransitionStatus is set to Pending/Complete for transitioned
    	// entries based on state of transition
    	TransitionStatus string `msg:"ts"`
    	// TransitionedObjName is the object name on the remote tier corresponding
    	// to object (version) on the source tier.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top