- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 45 for AtomicLong (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/smb/SmbFileHandleImpl.java
private final byte[] fileId; private boolean open = true; private final long tree_num; // for checking whether the tree changed private SmbTreeHandleImpl tree; private final AtomicLong usageCount = new AtomicLong(1); private final int flags; private final int access; private final int attrs; private final int options; private final String unc;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.4K bytes - Click Count (1) -
android/guava/src/com/google/common/cache/LongAddables.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; import com.google.common.base.Supplier; import java.util.concurrent.atomic.AtomicLong; /** * Source of {@link LongAddable} objects that deals with GWT, Unsafe, and all that. * * @author Louis Wasserman */ @GwtCompatible final class LongAddables {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 2K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/FakeTicker.java
* * <p>This class is thread-safe. * * @author Jige Yu * @since 10.0 */ @NullMarked @GwtCompatible public class FakeTicker extends Ticker { private final AtomicLong nanos = new AtomicLong(); private volatile long autoIncrementStepNanos; /** Advances the ticker value by {@code time} in {@code timeUnit}. */ @SuppressWarnings("GoodTime") // should accept a java.time.DurationCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 15:16:19 GMT 2025 - 4.1K bytes - Click Count (0) -
docs/smb3-features/04-directory-leasing-design.md
### 10.1 Directory Cache Statistics ```java public class DirectoryCacheStatistics { private final AtomicLong cacheHits = new AtomicLong(); private final AtomicLong cacheMisses = new AtomicLong(); private final AtomicLong cacheInvalidations = new AtomicLong(); private final AtomicLong changeNotifications = new AtomicLong(); public double getCacheHitRatio() { long hits = cacheHits.get();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 36.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/Smb2EncryptionContext.java
// Rotation metrics private final AtomicLong totalKeyRotations = new AtomicLong(0); private final AtomicLong lastKeyRotationTime = new AtomicLong(0); /** * AES-128-CCM cipher identifier for SMB3 encryption */ public static final int CIPHER_AES_128_CCM = EncryptionNegotiateContext.CIPHER_AES128_CCM; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 35.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
*/ public IndexUpdateCallbackImpl() { // Default constructor } /** Atomic counter for the number of documents processed */ protected AtomicLong documentSize = new AtomicLong(0); /** Total execution time for all operations */ protected volatile long executeTime = 0; /** List of documents waiting to be indexed */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTreeHandleImpl.java
private final SmbResourceLocatorImpl resourceLoc; private final SmbTreeConnection treeConnection; private final AtomicLong usageCount = new AtomicLong(1); /** * @param resourceLoc * @param treeConnection */ public SmbTreeHandleImpl(final SmbResourceLocatorImpl resourceLoc, final SmbTreeConnection treeConnection) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 11.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/IndexExportJob.java
excludeFields, query); } final long startTime = System.currentTimeMillis(); try { final AtomicLong processedCount = new AtomicLong(0); final long count = searchEngineClient.scrollSearch(fessConfig.getIndexDocumentSearchIndex(), requestBuilder -> { requestBuilder.setQuery(query).setSize(scrollSize);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 10.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
/** Sort list. */ protected List<SortBuilder<?>> sortList = new ArrayList<>(); /** Scroll ID. */ protected String scrollId = null; /** Document count. */ protected final AtomicLong docCount = new AtomicLong(0); /** Total document number. */ protected final long totalDocNum; /** * Constructor for ESSourceReader. * @param client The OpenSearch client.Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 11.1K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/LongAddables.java
* the License. */ package com.google.common.hash; import com.google.common.base.Supplier; import java.util.concurrent.atomic.AtomicLong; /** * Source of {@link LongAddable} objects that deals with GWT, Unsafe, and all that. * * @author Louis Wasserman */ final class LongAddables { private static final Supplier<LongAddable> SUPPLIER;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.9K bytes - Click Count (0)