- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,757 for lost (0.02 sec)
-
docs/metrics/prometheus/alerts.md
for: 5m labels: severity: critical annotations: summary: "Instance {{ $labels.server }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }}" description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes." ``` ## Verify the configuration and alerts
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 23 15:13:23 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CloseableUtil.java
/** * Closes a {@link Closeable}. * <p> * If an exception is thrown by {@link Closeable#close()}, an error message is logged. The exception is not rethrown. This prevents the original exception from being lost in situations like the following: * </p> * <pre> * InputStream is = ...; * try { * is.read(...); * } finally { * close(is); * } * </pre> * <p>
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 2.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* [RealConnection.isEligible] for details. * * 3. Attempt plans from prior connect attempts for this call. These occur as either follow-ups to * failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost * a race in fast follow-up. * * 4. If there's no existing connection, make a list of routes (which may require blocking DNS
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 4.2K bytes - Viewed (0) -
buildscripts/heal-manual.go
if err != nil { log.Fatalln(err) } opts := madmin.HealOpts{ Recursive: true, // recursively heal all objects at 'prefix' Remove: true, // remove content that has lost quorum and not recoverable ScanMode: madmin.HealNormalScan, // by default do not do 'deep' scanning } start, _, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, "", false, false)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 27 09:47:58 UTC 2024 - 2.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocketListener.kt
code: Int, reason: String, ) { } /** * Invoked when a web socket has been closed due to an error reading from or writing to the * network. Both outgoing and incoming messages may have been lost. No further calls to this * listener will be made. */ open fun onFailure( webSocket: WebSocket, t: Throwable, response: Response?, ) { }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
*/ open fun onClosed(eventSource: EventSource) { } /** * Invoked when an event source has been closed due to an error reading from or writing to the * network. Incoming events may have been lost. No further calls to this listener will be made. */ open fun onFailure( eventSource: EventSource, t: Throwable?, response: Response?, ) { }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 1.7K bytes - Viewed (0) -
cmd/shared-lock.go
continue } keepLock: for { select { case <-ctx.Done(): return case <-lkctx.Context().Done(): // The context of the lock is canceled, this can happen // if one lock lost quorum due to cluster instability // in that case, try to lock again. break keepLock case ld.lockContext <- lkctx: // Send the lock context to anyone asking for it } } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
* finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException { ExecutorService exec = newCachedThreadPool(); int listenerCount = 20;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
docs/de/docs/advanced/async-tests.md
Beachten Sie, dass wir async/await mit dem neuen `AsyncClient` verwenden – der Request ist asynchron. /// /// warning | Achtung Falls Ihre Anwendung auf Lifespan-Events angewiesen ist, der `AsyncClient` löst diese Events nicht aus. Um sicherzustellen, dass sie ausgelöst werden, verwenden Sie `LifespanManager` von <a href="https://github.com/florimondmanca/asgi-lifespan#usage" class="external-link" target="_blank">florimondmanca/asgi-lifespan</a>.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 4.3K bytes - Viewed (1) -
guava/src/com/google/common/collect/ForwardingSet.java
* @since 2.0 */ @GwtCompatible public abstract class ForwardingSet<E extends @Nullable Object> extends ForwardingCollection<E> implements Set<E> { // TODO(lowasser): identify places where thread safety is actually lost /** Constructor for use by subclasses. */ protected ForwardingSet() {} @Override protected abstract Set<E> delegate(); @Override public boolean equals(@Nullable Object object) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.7K bytes - Viewed (0)