- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 299 for reinitialized (0.71 seconds)
-
guava/src/com/google/common/cache/AbstractCache.java
private final LongAddable totalLoadTime = LongAddables.create(); private final LongAddable evictionCount = LongAddables.create(); /** Constructs an instance with all counts initialized to zero. */ public SimpleStatsCounter() {} /** * @since 11.0 */ @Override public void recordHits(int count) { hitCount.add(count); } /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 9.2K bytes - Click Count (0) -
src/main/java/jcifs/Config.java
* should be sufficient for most needs. * * If you want to retain the classic singleton behavior you can use * {@link jcifs.context.SingletonContext#getInstance()} * witch is initialized using system properties. * */ public class Config { /** * Private constructor to prevent instantiation of this utility class. */ private Config() {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 8.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
) : RoutePlanner.Plan, ExchangeCodec.Carrier { /** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: JavaNetSocket? = null /**Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 19.3K bytes - Click Count (2) -
cmd/global-heal.go
bgSeq, found := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID) if !found { return errors.New("no local healing sequence initialized, unable to heal the drive") } scanMode := madmin.HealNormalScan // Make sure to copy since `buckets slice` // is modified in place by tracker. healBuckets := make([]string, len(buckets))
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 04 13:49:12 GMT 2025 - 16.2K bytes - Click Count (0) -
ci/official/README.md
is a brief explanation of how they tie together: 1. `envs/*` are lists of variables made with bash syntax. A user must set a `TFCI` env param pointing to a list of `env` files. 2. `utilities/setup.sh`, initialized by all top-level scripts, reads and sets values from those `TFCI` paths. - `set -a` / `set -o allexport` exports the variables from `env` files so all scripts can use them.Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Thu Feb 01 03:21:19 GMT 2024 - 8K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/tree/Smb2TreeConnectRequestTest.java
treeFlagsField.setAccessible(true); // When - Create new request Smb2TreeConnectRequest req = new Smb2TreeConnectRequest(mockConfig, TEST_PATH); // Then - Tree flags should be initialized to 0 int flags = (int) treeFlagsField.get(req); assertEquals(0, flags); } @Test @DisplayName("Should handle maximum path length")
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 18.6K bytes - Click Count (0) -
cmd/tier.go
binary.LittleEndian.PutUint16(data[2:4], tierConfigVersion) // Marshal the tier config return config.MarshalMsg(data) } // getDriver returns a warmBackend interface object initialized with remote tier config matching tierName func (config *TierConfigMgr) getDriver(ctx context.Context, tierName string) (d WarmBackend, err error) { config.Lock() defer config.Unlock() var ok bool
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
return t; }); // Start health check task if (healthCheckInterval > 0) { startHealthCheckTask(); } log.info("MultiChannelManager initialized with maxChannels={}, strategy={}, healthCheckInterval={}ms", maxChannels, loadBalancingStrategy, healthCheckInterval); } /** * Creates channels for a new session. *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
}.apply { timeout(client.callTimeoutMillis.toLong(), MILLISECONDS) } private val executed = AtomicBoolean() // These properties are only accessed by the thread executing the call. /** Initialized in [callStart]. */ private var callStackTrace: Any? = null /** Finds an exchange to send the next request and receive the next response. */ private var exchangeFinder: ExchangeFinder? = nullCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 12:06:21 GMT 2026 - 19.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java
.disableAutomaticRetries() .build(); if (logger.isDebugEnabled()) { logger.debug("Initialized {} with timeout: {}ms", getClass().getSimpleName(), timeout); } logger.info("[LLM] {} initialized. model={}, timeout={}ms, maxConcurrent={}", getName(), getModel(), getTimeout(), getMaxConcurrentRequests());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 72K bytes - Click Count (0)