- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 101 for decrement (0.18 sec)
-
cmd/erasure-utils.go
return 0, reedsolomon.ErrShortData } // Counter to decrement total left to write. write := length // Counter to increment total written. var totalWritten int64 // Write all data blocks to dst. for _, block := range enBlocks[:dataBlocks] { // Skip blocks until we have reached our offset. if offset >= int64(len(block)) { // Decrement offset. offset -= int64(len(block)) continue }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/net/InetAddressesTest.java
address = InetAddresses.decrement(address); assertEquals(address66255, address); for (int i = 0; i < 255; i++) { address = InetAddresses.decrement(address); } assertEquals(address660, address); InetAddress address0000 = InetAddress.getByName("0.0.0.0"); assertThrows(IllegalArgumentException.class, () -> InetAddresses.decrement(address0000)); }
Java - Registered: Fri Mar 15 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 31.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/net/InetAddressesTest.java
address = InetAddresses.decrement(address); assertEquals(address66255, address); for (int i = 0; i < 255; i++) { address = InetAddresses.decrement(address); } assertEquals(address660, address); InetAddress address0000 = InetAddress.getByName("0.0.0.0"); assertThrows(IllegalArgumentException.class, () -> InetAddresses.decrement(address0000)); }
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 31.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
put(BEGIN_KEY, ComponentUtil.getSystemHelper().getCurrentTimeAsLong()); count = new AtomicInteger(1); } public int increment() { return count.incrementAndGet(); } public int decrement() { return count.decrementAndGet(); } } public enum StatsAction { ACCESSED, // ACCESS_EXCEPTION, //
Java - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LongAdder.java
|| !(uncontended = a.cas(v = a.value, v + x))) retryUpdate(x, hc, uncontended); } } /** Equivalent to {@code add(1)}. */ @Override public void increment() { add(1L); } /** Equivalent to {@code add(-1)}. */ public void decrement() { add(-1L); } /** * Returns the current sum. The returned value is NOT an atomic snapshot; invocation in
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
abstract void compareAndSetSeenExceptions( AggregateFutureState<?> state, @CheckForNull Set<Throwable> expect, Set<Throwable> update); /** Atomic decrement-and-get of the {@link AggregateFutureState#remaining} field. */ abstract int decrementAndGetRemainingCount(AggregateFutureState<?> state); } private static final class SafeAtomicHelper extends AtomicHelper {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LongAdder.java
|| !(uncontended = a.cas(v = a.value, v + x))) retryUpdate(x, hc, uncontended); } } /** Equivalent to {@code add(1)}. */ @Override public void increment() { add(1L); } /** Equivalent to {@code add(-1)}. */ public void decrement() { add(-1L); } /** * Returns the current sum. The returned value is NOT an atomic snapshot; invocation in
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Tue Apr 20 18:43:59 GMT 2021 - 5.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8K bytes - Viewed (0) -
cmd/namespace-lock.go
if readLock { locked = nsLk.GetRLock(ctx, opsID, lockSource, timeout) } else { locked = nsLk.GetLock(ctx, opsID, lockSource, timeout) } if !locked { // We failed to get the lock // Decrement ref count since we failed to get the lock n.lockMapMutex.Lock() n.lockMap[resource].ref-- if n.lockMap[resource].ref < 0 { logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/http-stats.go
} if w == nil { // when response recorder nil, this is an active request hstats.currentS3Requests.Inc(api) bh.httpStats[bucket] = hstats return } // else { hstats.currentS3Requests.Dec(api) // decrement this once we have the response recorder. hstats.totalS3Requests.Inc(api) code := w.StatusCode switch { case code == 0: case code == 499: // 499 is a good error, shall be counted as canceled.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0)