- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 170 for Canceled (0.34 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
step2Waiter.awaitReturned(); step4Waiter.awaitStarted(); // Step 1 is not cancelled because it was done. assertWithMessage("step1.statusFuture().isCancelled()") .that(step1.statusFuture().isCancelled()) .isFalse(); // But its closeable is closed. assertClosed(closeable1); // Step 2 is cancelled because it wasn't complete. assertWithMessage("step2.statusFuture().isCancelled()")
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 75.4K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if err := healFreshDisk(ctx, z, disk); err != nil { globalBackgroundHealState.setDiskHealingStatus(disk, false) timedout := OperationTimedOut{} if !errors.Is(err, context.Canceled) && !errors.As(err, &timedout) && !errors.Is(err, errRetryHealing) { printEndpointError(disk, err, false) } return } // Only upon success pop the healed disk.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.5K bytes - Viewed (0) -
cmd/admin-handlers.go
ctx = lkctx.Context() defer nsLock.Unlock(lkctx) // Freeze all incoming S3 API calls before running speedtest. globalNotificationSys.ServiceFreeze(ctx, true) // Unfreeze as soon as request context is canceled or when the function returns. go func() { <-ctx.Done() globalNotificationSys.ServiceFreeze(ctx, false) }() durationStr := r.Form.Get(peerRESTDuration)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
cmd/data-scanner.go
err = saveConfig(ctx, objAPI, backgroundHealInfoPath, b) if err != nil { internalLogIf(ctx, err) } } // runDataScanner will start a data scanner. // The function will block until the context is canceled. // There should only ever be one scanner running per cluster. func runDataScanner(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
} // ReadMultiple will read multiple files and send each back as response. // Files are read and returned in the given order. // The resp channel is closed before the call returns. // Only a canceled context or network errors returns an error. func (client *storageRESTClient) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error { defer xioutil.SafeClose(resp)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 08 02:38:41 UTC 2025 - 30.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
public boolean cancel(boolean mayInterruptIfRunning) { logger.get().log(FINER, "cancelling {0}", this); boolean cancelled = future.cancel(mayInterruptIfRunning); if (cancelled) { close(); } return cancelled; } private void close() { logger.get().log(FINER, "closing {0}", this); closeables.close(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 97.8K bytes - Viewed (0) -
cmd/common-main.go
// syscall.SIGHUP to reload the certs. manager.ReloadOnSignal(syscall.SIGHUP) return x509Certs, manager, secureConn, nil } // contextCanceled returns whether a context is canceled. func contextCanceled(ctx context.Context) bool { select { case <-ctx.Done(): return true default: return false } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
) = TODO() override fun callEnd(call: Call) = TODO() override fun callFailed( call: Call, ioe: IOException, ) = TODO() override fun canceled(call: Call) = TODO() } val none: EventListener = EventListener.NONE } @Test fun eventListenerBuilder() { var builder: EventListener.Factory = EventListener.Factory { TODO() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 46.5K bytes - Viewed (0) -
cmd/metacache-entries.go
// The output channel will be closed when all inputs are emptied. // If file names are equal, compareMeta is called to select which one to choose. // The entry not chosen will be discarded. // If the context is canceled the function will return the error, // otherwise the function will return nil. func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/peer-rest-client.go
// Trace - send http trace request to peer nodes func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) { go func() { for { // Blocks until context is canceled or an error occurs. client.doTrace(ctx, traceCh, traceOpts) select { case <-ctx.Done(): return default: // There was error in the REST request, retry after sometime as probably the peer is down.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0)