- Sort Score
- Result 10 results
- Languages All
Results 671 - 680 of 815 for Threads (0.15 sec)
-
src/main/java/jcifs/smb1/smb1/SigningDigest.java
update(sequence, 0, sequence.length); index += 8; if (response.command == ServerMessageBlock.SMB_COM_READ_ANDX) { /* SmbComReadAndXResponse reads directly from the stream into separate byte[] b. */ final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) response; final int length = response.length - raxr.dataLength;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/BufferCacheImplTest.java
import jcifs.Configuration; @ExtendWith(MockitoExtension.class) class BufferCacheImplTest { @Mock Configuration cfg; // Verifies constructor that accepts Configuration reads the expected values and uses them @Test @DisplayName("Constructor(Configuration) uses cache size and maximum buffer size from config") void constructorUsesConfigurationAndAllocatesWithConfiguredSize() {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.5K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
"Count of online drives") driveCountMD = NewGaugeMD(driveCount, "Count of all drives") // iostat related driveReadsPerSecMD = NewGaugeMD(driveReadsPerSec, "Reads per second on a drive", allDriveLabels...) driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec, "Kilobytes read per second on a drive", allDriveLabels...) driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 7.8K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
return m } func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] { var ( // prevDriveIOStats is used to calculate "per second" // values for IOStat related disk metrics e.g. reads/sec. prevDriveIOStats map[string]madmin.DiskIOStats prevDriveIOStatsMu sync.RWMutex prevDriveIOStatsRefreshedAt time.Time )
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 8.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbOperationException.java
} return String.format("[%s] %s: %s", errorCode.name(), errorCode.getDescription(), message); } private String extractOperationName() { StackTraceElement[] stack = Thread.currentThread().getStackTrace(); for (StackTraceElement element : stack) { String className = element.getClassName(); if (className.startsWith("jcifs.smb") && !className.contains("Exception")) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @param executor the executor in which the listeners callback methods will be run. For fast, * lightweight listeners that would be safe to execute in any thread, consider {@link * MoreExecutors#directExecutor}. * @since 13.0 */ void addListener(Listener listener, Executor executor); /** * The lifecycle states of a service. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkArgument; import static java.lang.Thread.currentThread; import static java.util.Arrays.asList; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.annotations.VisibleForTesting;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 10.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
} /** * Creates a thread-safe set backed by a hash map. The set is backed by a {@link * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees. * * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The * set is serializable. * * @return a new, empty thread-safe {@code Set} * @since 15.0 */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 81.6K bytes - Viewed (0) -
internal/s3select/json/preader.go
type queueItem struct { input []byte // raw input sent to the worker dst chan []jstream.KVS // result of block decode err error // any error encountered will be set here } // Read - reads single record. // Once Read is called the previous record should no longer be referenced. func (r *PReader) Read(dst sql.Record) (sql.Record, error) { // If we have have any records left, return these before any error.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0) -
android/guava/pom.xml
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Nov 17 21:36:50 UTC 2025 - 9.8K bytes - Viewed (0)