- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 1,222 for states (0.06 sec)
-
src/main/java/jcifs/smb1/smb1/SmbSession.java
private static final int CACHE_POLICY = Config.getInt("jcifs.smb1.netbios.cachePolicy", 60 * 10) * 60; /* 10 hours */ static NbtAddress[] dc_list = null; static long dc_list_expiration; static int dc_list_counter; private static NtlmChallenge interrogate(final NbtAddress addr) throws SmbException { final UniAddress dc = new UniAddress(addr); final SmbTransport trans = SmbTransport.getSmbTransport(dc, 0);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 20.7K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
Avg: a.Avg, Max: a.Max, } return w } // QStat holds queue stats for replication type QStat struct { Count float64 `json:"count"` Bytes float64 `json:"bytes"` } func (q *QStat) add(o QStat) QStat { return QStat{Bytes: q.Bytes + o.Bytes, Count: q.Count + o.Count} } // InQueueMetric holds queue stats for replication type InQueueMetric struct { Curr QStat `json:"curr" msg:"cq"`
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 14.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/WebApiUtilTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 17.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheStats.java
* the License. */ package com.google.common.cache; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.math.LongMath.saturatedAdd; import static com.google.common.math.LongMath.saturatedSubtract; import static java.lang.Math.max; import com.google.common.annotations.GwtCompatible; import com.google.common.base.MoreObjects;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 12.6K bytes - Viewed (0) -
docs/SMB3_IMPLEMENTATION_PLAN.md
├── Smb2LeaseKey.java - 16-byte lease key management ├── Smb2LeaseState.java - Lease state flags (R, H, W) └── LeaseManager.java - Central lease management ``` #### 1.2 Implementation Tasks - [ ] Define lease state constants (SMB2_LEASE_READ, SMB2_LEASE_HANDLE, SMB2_LEASE_WRITE) - [ ] Implement lease key generation and management
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 10.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransPeekNamedPipeResponse.java
class TransPeekNamedPipeResponse extends SmbComTransactionResponse { private final SmbNamedPipe pipe; static final int STATUS_DISCONNECTED = 1; static final int STATUS_LISTENING = 2; static final int STATUS_CONNECTION_OK = 3; static final int STATUS_SERVER_END_CLOSED = 4; int status, available; TransPeekNamedPipeResponse(final SmbNamedPipe pipe) { this.pipe = pipe; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 2.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManagerBridge.java
import com.google.common.util.concurrent.Service.State; /** * Superinterface of {@link ServiceManager} to introduce a bridge method for {@code * servicesByState()}, to ensure binary compatibility with older Guava versions that specified * {@code servicesByState()} to return {@code ImmutableMultimap}. */ @J2ktIncompatible @GwtIncompatible interface ServiceManagerBridge { ImmutableMultimap<State, Service> servicesByState();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 1.2K bytes - Viewed (0) -
cmd/metrics-v3-bucket-replication.go
if s, ok := bucketReplStats[bucket]; ok { stats := s.ReplicationStats if stats.hasReplicationUsage() { for arn, stat := range stats.Stats { labels := []string{bucketL, bucket, targetArnL, arn} m.Set(bucketReplLastHrFailedBytes, float64(stat.Failed.LastHour.Bytes), labels...) m.Set(bucketReplLastHrFailedCount, float64(stat.Failed.LastHour.Count), labels...)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Jun 04 20:45:31 UTC 2025 - 8.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java
* * <pre> * public static void main(String[] args) { * Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit()); * ... * </pre> * * <p>The returned handler logs any exception at severity {@code SEVERE} and then shuts down the * process with an exit status of 1, indicating abnormal termination. */ public static UncaughtExceptionHandler systemExit() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Feb 10 21:03:40 UTC 2025 - 2.8K bytes - Viewed (0)