- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 104 for propagated (0.07 sec)
-
CHANGELOG/CHANGELOG-1.10.md
* kubeadm will no longer generate an unused etcd CA and certificates when configured to use an external etcd cluster. ([#63806](https://github.com/kubernetes/kubernetes/pull/63806), [@detiber](https://github.com/detiber)) * Fix incorrectly propagated ResourceVersion in ListRequests returning 0 items. ([#64150](https://github.com/kubernetes/kubernetes/pull/64150), [@wojtek-t](https://github.com/wojtek-t))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu May 05 13:44:43 UTC 2022 - 341.8K bytes - Viewed (0) -
docs/bucket/replication/README.md
replication can be viewed by doing a GET/HEAD on the object version - it will return a `X-Minio-Replication-DeleteMarker-Status` header and http response code of `405`. In the case of permanent deletes, if the delete replication is pending or failed to propagate to the target cluster, GET/HEAD will return additional `X-Minio-Replication-Delete-Status` header and a http response code of `405`. ...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
serverListener.assertFailure(EOFException::class.java) serverListener.assertExhausted() clientListener.assertFailure(e) } @Disabled("AsyncCall currently lets runtime exceptions propagate.") @Test @Throws( Exception::class, ) fun throwingOnFailLogs() { webServer.enqueue( MockResponse .Builder() .code(200) .body("Body")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 35.5K bytes - Viewed (0) -
docs/smb3-features/02-persistent-handles-design.md
log.error("Failed to reconnect durable handle", reconnectError); throw new IOException("Connection lost and reconnection failed", e); } } else { throw e; // No durable handle, propagate error } } ``` ### 6.3 Session Integration ```java // In SmbSession.java private PersistentHandleManager handleManager; public SmbSession(CIFSContext context, SmbTransport transport) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* fetchCounters().catchingAsync( * FetchException.class, x -> immediateFuture(0), directExecutor()); * } * * <p>The fallback can also choose to propagate the original exception when desired: * * {@snippet : * // Falling back to a zero counter only in case the exception was a * // TimeoutException. * ListenableFuture<Integer> faultTolerantFuture =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
// service or listener). Our contract says it is safe to call this method if // all services were NEW when it was called, and this has already been verified above, so we // don't propagate the exception. logger.get().log(Level.WARNING, "Unable to start Service " + service, e); } } return this; } /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
val lastGoodStreamId: Int withLock { if (isShutdown) { return } isShutdown = true lastGoodStreamId = this.lastGoodStreamId } // TODO: propagate exception message into debugData. // TODO: configure a timeout on the reader so that it doesn’t block forever. writer.goAway(lastGoodStreamId, statusCode, EMPTY_BYTE_ARRAY) } } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
WARN, journalIsCorrupt, ) } // The cache is corrupted, attempt to delete the contents of the directory. This can throw and // we'll let that propagate out as it likely means there is a severe filesystem problem. try { delete() } finally { closed = false } } rebuildJournal() initialized = true
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 34.7K bytes - Viewed (0) -
cmd/common-main.go
return true default: return false } } // bgContext returns a context that can be used for async operations. // Cancellation/timeouts are removed, so parent cancellations/timeout will // not propagate from parent. // Context values are preserved. // This can be used for goroutines that live beyond the parent context. func bgContext(parent context.Context) context.Context { return bgCtx{parent: parent} }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Streams.java
// exception later. If more than one stream throws an exception, the later ones are added to the // first as suppressed exceptions. We don't catch Error on the grounds that it should be allowed // to propagate immediately. Exception exception = null; for (BaseStream<?, ?> stream : toClose) { try { stream.close(); } catch (Exception e) { // sneaky checked exception
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 37K bytes - Viewed (0)