Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 140 for Canceled (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/handler-utils.go

    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    			if err != nil && !errors.Is(err, context.Canceled) {
    				proxyLogIf(GlobalContext, err)
    			}
    			if returnErr {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			}
    		},
    	})
    
    	r.URL.Scheme = "http"
    	if globalIsTLS {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  3. internal/grid/connection.go

    	}
    	defer func() {
    		if debugReqs {
    			_, ok := c.outgoing.Load(client.MuxID)
    			fmt.Println(client.MuxID, c.String(), "Connection.Request: DELETING MUX. Exists:", ok)
    		}
    		client.cancelFn(context.Canceled)
    		c.outgoing.Delete(client.MuxID)
    	}()
    	return client.traceRoundtrip(ctx, c.trace, h, req)
    }
    
    // Request allows to do a single remote request.
    // 'req' will not be used after the call and caller can reuse.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  4. cmd/metacache-stream.go

    		}
    		res = append(res, meta)
    	}
    	return metaCacheEntriesSorted{o: res}, nil
    }
    
    // readAll will return all remaining objects on the dst channel and close it when done.
    // The context allows the operation to be canceled.
    func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error {
    	r.checkInit()
    	if r.err != nil {
    		return r.err
    	}
    	defer xioutil.SafeClose(dst)
    	if r.current.name != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  5. internal/logger/target/http/http.go

    		if !isDirQueue {
    			err = h.send(ctx, buf.Bytes(), count, h.payloadType, h.httpTimeout)
    		} else {
    			_, err = h.store.PutMultiple(entries)
    		}
    
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				return
    			}
    
    			h.config.LogOnceIf(
    				context.Background(),
    				fmt.Errorf("unable to send audit/log entry(s) to '%s' err '%w': %d", name, err, count),
    				name,
    			)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  6. CHANGELOG.md

     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
        we didn't call `Response.close()` if the coroutine was canceled before its response was
        returned.
    
     *  Upgrade: [Okio 3.9.0][okio_3_9_0].
    
     *  Upgrade: [Kotlin 1.9.23][kotlin_1_9_23].
    
     *  Upgrade: [UnicodeĀ® IDNA 15.1.0][idna_15_1_0]
    
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 05 16:02:59 GMT 2025
    - 36.2K bytes
    - Click Count (2)
  7. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  8. 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()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  9. 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();
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 13:51:27 GMT 2025
    - 96.9K bytes
    - Click Count (0)
  10. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
Back to Top