Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2001 - 2010 of 2,181 for Text (0.02 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. guava/src/com/google/common/collect/Lists.java

            }
    
            @Override
            public boolean hasPrevious() {
              return forwardIterator.hasNext();
            }
    
            @Override
            @ParametricNullness
            public T next() {
              if (!hasNext()) {
                throw new NoSuchElementException();
              }
              canRemoveOrSet = true;
              return forwardIterator.previous();
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 43.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java

          this.infiniteCandidates = infiniteCandidates.iterator();
        }
    
        @Override
        protected Set<E> delegate() {
          return infiniteCandidates.next();
        }
      }
    
      private static final class MutatedOnQueryList<E> extends ForwardingList<E> {
        final Iterator<ImmutableList<E>> infiniteCandidates;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/io/ResourceUtil.java

            assertArgumentNotNull("path", path);
    
            if (extension == null) {
                return path;
            }
            final String ext = "." + extension;
            if (path.endsWith(ext)) {
                return path;
            }
            return path.replace('.', '/') + ext;
        }
    
        /**
         * リソースパスを返します。
         *
         * @param clazz
         *            クラス。{@literal null}であってはいけません
         * @return リソースパス
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

          throw AssertionError("full event sequence: $fullEventSequence", e)
        }
      }
    
      inline fun <reified T : CallEvent> removeUpToEvent(): T = removeUpToEvent(T::class.java)
    
      /**
       * Remove and return the next event from the recorded sequence.
       *
       * @param eventClass a class to assert that the returned event is an instance of, or null to
       *     take any event class.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

        }
    
        // ensures that the number of invocations looks sane
        void assertInvariants(int expectedBytes) {
          // we should have seen as many bytes as the next multiple of chunk after expectedBytes - 1
          assertEquals(out.toByteArray().length, ceilToMultiple(expectedBytes, chunkSize));
          assertEquals(expectedBytes / chunkSize, processCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/RegularImmutableMap.java

       * The pointer to a key is stored in hashTable[Hashing.smear(key.hashCode()) % table.length],
       * save that if that location is already full, we try the next index, and the next, until we
       * find an empty table position.  Since the table has a power-of-two size, we use
       * & (table.length - 1) instead of % table.length, though.
       */
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 15 22:32:14 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/Striped64.java

              }
              collide = false;
              continue; // Retry with expanded table
            }
            h ^= h << 13; // Rehash
            h ^= h >>> 17;
            h ^= h << 5;
            hc[0] = h; // Record index for next time
          } else if (busy == 0 && cells == as && casBusy()) {
            boolean init = false;
            try { // Initialize table
              if (cells == as) {
                Cell[] rs = new Cell[2];
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/MultimapsTest.java

        Multimap<String, Integer> mod = HashMultimap.create();
        Multimap<String, Integer> unmod = Multimaps.unmodifiableMultimap(mod);
        mod.put("foo", 1);
        Entry<String, Integer> fromIterator = unmod.entries().iterator().next();
        assertThrows(UnsupportedOperationException.class, () -> fromIterator.setValue(2));
        Entry<String, Integer> fromToArray = (Entry<String, Integer>) unmod.entries().toArray()[0];
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 38.4K bytes
    - Viewed (0)
Back to top