Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 170 for Canceled (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top