Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 798 for NEXT (0.04 sec)

  1. cmd/last-minute.go

    func (l *lastMinuteLatency) forwardTo(t int64) {
    	if l.LastSec >= t {
    		return
    	}
    	if t-l.LastSec >= 60 {
    		l.Totals = [60]AccElem{}
    		return
    	}
    	for l.LastSec != t {
    		// Clear next element.
    		idx := (l.LastSec + 1) % 60
    		l.Totals[idx] = AccElem{}
    		l.LastSec++
    	}
    }
    
    // LastMinuteHistogram keeps track of last minute sizes added.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  2. cmd/lock-rest-server.go

    		// Verifies every minute for locks held more than 2 minutes.
    		select {
    		case <-ctx.Done():
    			return
    		case <-lkTimer.C:
    			globalLockServer.expireOldLocks(lockValidityDuration)
    
    			// Reset the timer for next cycle.
    			lkTimer.Reset(lockMaintenanceInterval)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/primitives/ImmutableDoubleArray.java

        }
        return builder().addAll(values).build();
      }
    
      /**
       * Returns an immutable array containing all the values from {@code stream}, in order.
       *
       * @since NEXT (but since 22.0 in the JRE flavor)
       */
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // Users will use this only if they're already using streams.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 23K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/RateLimiter.java

     * acquire(1000)} will result in exactly the same throttling, if any), but it affects the throttling
     * of the <i>next</i> request. I.e., if an expensive task arrives at an idle RateLimiter, it will be
     * granted immediately, but it is the <i>next</i> request that will experience extra throttling,
     * thus paying for the cost of the expensive task.
     *
     * @author Dimitris Andreou
     * @since 13.0
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * Each derivation can capture the next value or any intermediate objects for later closing.
     *
     * <p>A step can be the input to at most one derived step. Once you transform its value, catch its
     * exception, or combine it with others, you cannot do anything else with it, including declare it
     * to be the last step of the pipeline.
     *
     * <h4>Transforming</h4>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      // These properties are only accessed by the thread executing the call.
    
      /** Initialized in [callStart]. */
      private var callStackTrace: Any? = null
    
      /** Finds an exchange to send the next request and receive the next response. */
      private var exchangeFinder: ExchangeFinder? = null
    
      var connection: RealConnection? = null
        private set
      private var timeoutEarlyExit = false
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. architecture/environments/operator.md

    and the Helm values (Istio behavior configuration).
    
    1. The fields defined in the user CR override any values defined in the configuration profile CR.  The
    resulting CR is converted to Helm values.yaml format and passed to the next step.
    1. Part of the configuration profile contains settings in the Helm values.yaml schema format. User overrides of
    these fields are applied and merged with the output of this step. The result of this step is a merge of configuration
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. internal/ringbuffer/ring_buffer.go

    // and can be read back from another goroutine.
    // It is safe to concurrently read and write RingBuffer.
    type RingBuffer struct {
    	buf       []byte
    	size      int
    	r         int // next position to read
    	w         int // next position to write
    	isFull    bool
    	err       error
    	block     bool
    	mu        sync.Mutex
    	wg        sync.WaitGroup
    	readCond  *sync.Cond // Signaled when data has been read.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ImmutableMap.java

        return new UnmodifiableIterator<K>() {
          @Override
          public boolean hasNext() {
            return entryIterator.hasNext();
          }
    
          @Override
          public K next() {
            return entryIterator.next().getKey();
          }
        };
      }
    
      @LazyInit @RetainedWith @CheckForNull private transient ImmutableCollection<V> values;
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

                break;
              case 1:
                assertThat(network.edgeConnectingOrNull(node, otherNode))
                    .isEqualTo(edgesConnecting.iterator().next());
                assertThat(network.hasEdgeConnecting(node, otherNode)).isTrue();
                break;
              default:
                assertThat(network.hasEdgeConnecting(node, otherNode)).isTrue();
                try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 32.7K bytes
    - Viewed (0)
Back to top