- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for circuit (0.11 sec)
-
src/main/java/jcifs/smb/SmbTransportImpl.java
} catch (SimpleCircuitBreaker.CircuitBreakerOpenException e) { // Log circuit breaker rejection auditLogger.logSecurityViolation("Circuit breaker open for SMB connection", java.util.Map.of("address", address.getHostAddress(), "port", String.valueOf(port))); throw new IOException("Connection rejected by circuit breaker: " + e.getMessage(), e); } catch (RuntimeException e) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
* from the peer. * * Web sockets may fail due to HTTP upgrade problems, connectivity problems, or if either peer * chooses to short-circuit the graceful shutdown process: * * * **Canceled:** the web socket connection failed. Messages that were successfully enqueued by * either peer may not have been transmitted to the other. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbConstants.java
/** Native LAN manager name */ String NATIVE_LANMAN = Config.getProperty("jcifs.smb1.smb.client.nativeLanMan", "jCIFS"); /** Virtual circuit number */ int VC_NUMBER = 1; /** Null transport instance */ SmbTransport NULL_TRANSPORT = new SmbTransport(null, 0, null, 0);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 10.3K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java
static boolean matchPattern(ArtifactRepository originalRepository, String pattern) { boolean result = false; String originalId = originalRepository.getId(); // simple checks first to short circuit processing below. if (WILDCARD.equals(pattern) || pattern.equals(originalId)) { result = true; } else { // process the list String[] repos = pattern.split(",");
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Feb 07 00:45:02 UTC 2025 - 33.5K bytes - Viewed (0) -
cmd/utils.go
} func lcp(strs []string, pre bool) string { // short-circuit empty list if len(strs) == 0 { return "" } xfix := strs[0] // short-circuit single-element list if len(strs) == 1 { return xfix } // compare first to rest for _, str := range strs[1:] { xfixl := len(xfix) strl := len(str) // short-circuit empty strings if xfixl == 0 || strl == 0 { return "" }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 33K bytes - Viewed (0) -
src/main/java/jcifs/Configuration.java
* * @return socket timeout for netbios connections, in milliseconds */ int getNetbiosSoTimeout(); /** * Gets the virtual circuit number for SMB connections * * @return virtual circuit number to use */ int getVcNumber(); /** * * Property {@code jcifs.smb.client.capabilities} (int) * * @return custom capabilitiesRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 25.4K bytes - Viewed (0) -
CLAUDE.md
- Connection pooling with limits - Background temp file deletion via `FileUtil.deleteInBackground()` **Fault Tolerance**: - `FaultTolerantClient` wrapper (retry, circuit breaker) - Graceful degradation (e.g., robots.txt parsing continues on errors) --- ## Key Components ### Crawler (`Crawler.java`) Main orchestrator for crawling operations. **Key Methods**:
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Fri Nov 28 17:31:34 UTC 2025 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeRangeMap.java
remove(range); entriesByLowerBound.put(range.lowerBound, new RangeMapEntry<K, V>(range, value)); } } @Override public void putCoalescing(Range<K> range, V value) { // don't short-circuit if the range is empty - it may be between two ranges we can coalesce. if (entriesByLowerBound.isEmpty()) { put(range, value); return; }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 22.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
localTask.run(); // Now check if our task attempted to reentrantly execute the next task. Runnable queuedTask; Executor queuedExecutor; // Intentionally using non-short-circuit operator while ((queuedTask = executingTaskQueue.nextTask) != null && (queuedExecutor = executingTaskQueue.nextExecutor) != null) { executingTaskQueue.nextTask = null;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
misc/go_android_exec/main.go
// However, if the os.Stderr (or os.Stdout) file descriptors are // passed on, the hanging adb subprocess will hold them open and // go test will hang forever. // // Avoid that by wrapping stderr, breaking the short circuit and // forcing cmd.Run to use another pipe and goroutine to pass // along stderr from adb. cmd.Stderr = struct{ io.Writer }{os.Stderr} err := cmd.Run()
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Aug 21 17:46:57 UTC 2023 - 15.3K bytes - Viewed (0)