Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for decrement (0.05 sec)

  1. 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
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

        abstract void compareAndSetSeenExceptions(
            AggregateFutureState<?> state, @Nullable Set<Throwable> expect, Set<Throwable> update);
    
        /** Performs an atomic decrement-and-get of {@link AggregateFutureState#remainingField}. */
        abstract int decrementAndGetRemainingCount(AggregateFutureState<?> state);
    
        abstract String atomicHelperTypeForTest();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. src/test/java/jcifs/util/transport/TransportTest.java

            @Test
            @DisplayName("acquire should increment usage count")
            void shouldIncrementUsageCount() {
                long initial = transport.getUsageCount();
                transport.acquire();
                assertEquals(initial + 1, transport.getUsageCount());
            }
    
            @Test
            @DisplayName("release should decrement usage count")
            void shouldDecrementUsageCount() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

     *   for successful and unsuccessful computations, respectively.
     * </p>
     *
     * <p>
     *   The Deferred class uses a CountDownLatch to allow you to wait for the computation to complete.
     *   The resolve and reject methods decrement the CountDownLatch, allowing the getResponse method
     *   to return the result of the computation.
     * </p>
     *
     * @param <RESPONSE> The type of the response.
     */
    public class Deferred<RESPONSE extends Response> {
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  7. 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"))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

         * @return The incremented access count.
         */
        public long incrementAndGetAccessCount() {
            return accessCount.incrementAndGet();
        }
    
        /**
         * Decrements the access count and returns the new value.
         * @return The decremented access count.
         */
        public long decrementAndGetAccessCount() {
            return accessCount.decrementAndGet();
        }
    
        /**
         * Returns the crawler status.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/FakeTicker.java

        checkArgument(autoIncrementStep >= 0, "May not auto-increment by a negative amount");
        this.autoIncrementStepNanos = timeUnit.toNanos(autoIncrementStep);
        return this;
      }
    
      /**
       * Sets the increment applied to the ticker whenever it is queried.
       *
       * <p>The default behavior is to auto increment by zero. i.e: The ticker is left unchanged when
       * queried.
       *
       * @since 28.0
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/FakeTicker.java

        checkArgument(autoIncrementStep >= 0, "May not auto-increment by a negative amount");
        this.autoIncrementStepNanos = timeUnit.toNanos(autoIncrementStep);
        return this;
      }
    
      /**
       * Sets the increment applied to the ticker whenever it is queried.
       *
       * <p>The default behavior is to auto increment by zero. i.e: The ticker is left unchanged when
       * queried.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 4.1K bytes
    - Viewed (0)
Back to top