Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for decrement (0.06 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. src/test/java/org/codelibs/fess/helper/CrawlerStatsHelperTest.java

            assertEquals(1, statsObject.count.get());
    
            assertEquals(2, statsObject.increment());
            assertEquals(2, statsObject.count.get());
    
            assertEquals(1, statsObject.decrement());
            assertEquals(1, statsObject.count.get());
    
            assertEquals(0, statsObject.decrement());
            assertEquals(0, statsObject.count.get());
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 15K bytes
    - Viewed (0)
  3. 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)
  4. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

             */
            public int increment() {
                return count.incrementAndGet();
            }
    
            /**
             * Decrements the reference count for this statistics object.
             *
             * @return the new reference count after decrementing
             */
            public int decrement() {
                return count.decrementAndGet();
            }
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  5. 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)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

            // Test increment
            assertEquals(1L, crawlerContext.incrementAndGetAccessCount());
            assertEquals(1L, crawlerContext.getAccessCount());
    
            assertEquals(2L, crawlerContext.incrementAndGetAccessCount());
            assertEquals(2L, crawlerContext.getAccessCount());
    
            // Test decrement
            assertEquals(1L, crawlerContext.decrementAndGetAccessCount());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top