Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1151 - 1160 of 1,191 for call (0.03 sec)

  1. internal/ioutil/ioutil.go

    // the function finishes executing, Run returns context.DeadlineExceeded to the caller.
    // channel so that the work function can attempt to exit gracefully.
    // Multiple calls to Run will run independently of each other.
    func (d *DeadlineWorker) Run(work func() error) error {
    	_, err := WithDeadline[struct{}](context.Background(), d.timeout, func(ctx context.Context) (struct{}, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication-stats.go

    	r.qCache.bucketStats[bucket] = v
    
    	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, -1*sz)
    	atomic.AddInt64(&r.qCache.srQueueStats.nowCount, -1)
    }
    
    // incProxy increments proxy metrics for proxied calls
    func (r *ReplicationStats) incProxy(bucket string, api replProxyAPI, isErr bool) {
    	if r != nil {
    		r.pCache.inc(bucket, api, isErr)
    	}
    }
    
    func (r *ReplicationStats) getProxyStats(bucket string) ProxyMetric {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. cmd/namespace-lock.go

    type LockContext struct {
    	ctx    context.Context
    	cancel context.CancelFunc
    }
    
    // Context returns lock context
    func (l LockContext) Context() context.Context {
    	return l.ctx
    }
    
    // Cancel function calls cancel() function
    func (l LockContext) Cancel() {
    	if l.cancel != nil {
    		l.cancel()
    	}
    }
    
    // newNSLock - return a new name space lock map.
    func newNSLock(isDistErasure bool) *nsLockMap {
    	nsMutex := nsLockMap{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. src/main/java/jcifs/config/DelegatingConfiguration.java

     *
     */
    public class DelegatingConfiguration implements Configuration {
    
        private final Configuration delegate;
    
    
        /**
         * @param delegate
         *            delegate to pass all non-overridden method calls to
         * 
         */
        public DelegatingConfiguration ( Configuration delegate ) {
            this.delegate = delegate;
        }
    
    
        /**
         * {@inheritDoc}
         * 
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:50:16 UTC 2020
    - 17.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Cut.java

     * way of "cutting" a "number line" (actually of instances of type {@code C}, not necessarily
     * "numbers") into two sections; this can be done below a certain value, above a certain value,
     * below all values or above all values. With this object defined in this way, an interval can
     * always be represented by a pair of {@code Cut} instances.
     *
     * @author Kevin Bourrillion
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/TempFileCreator.java

          /*
           * https://github.com/google/guava/issues/6634: ProcessHandle has more accurate information,
           * but that class isn't available under all environments that we support. We use it if
           * available and fall back if not.
           */
          String fromSystemProperty = requireNonNull(USER_NAME.value());
    
          try {
            Class<?> processHandleClass = Class.forName("java.lang.ProcessHandle");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 06 17:11:11 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/JavaPathType.java

     *
     * <p>One path type is handled in a special way: unlike other options,
     * the paths specified in a {@code --patch-module} Java option is effective only for a specified module.
     * This type is created by calls to {@link #patchModule(String)} and a new instance must be created for
     * every module to patch.</p>
     *
     * <p>Path types are often exclusive. For example, a dependency should not be both on the Java class-path
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Mon May 13 09:53:45 UTC 2024
    - 15K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/math/QuantilesTest.java

       * - scale with index and with indexes taking int-varargs, and with all overloads of compute
       *   taking a double-collection and with computeInPlace;
       * - scale with indexes taking integer-collection with compute taking a double-collection and with
       *   computeInPlace;
       * - (except that, for non-finite values, we don't do all combinations exhaustively);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 29.7K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    // but can be replaced atomically.
    //
    // This function should only be used with
    // - GetBucketInfo
    // - ListBuckets
    // For all other bucket specific metadata, use the relevant
    // calls implemented specifically for each of those features.
    func (sys *BucketMetadataSys) Get(bucket string) (BucketMetadata, error) {
    	if isMinioMetaBucketName(bucket) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  10. docs/bucket/replication/DESIGN.md

    version).After replication syncs the delete marker on the target, the DeleteMarker on the target shows `X-Amz-Replication-Status` of `REPLICA`. The status of DeleteMarker replication is returned by `X-Minio-Replication-DeleteMarker-Status` header on `HEAD/GET` calls for the delete marker version in question - i.e with `mc stat --version-id dm-version-id`
    
    It must be noted that if active-active replication is set up with delete marker replication, there is potential for duplicate delete markers to be created...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
Back to top