Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 4,225 for Done (0.09 sec)

  1. cmd/xl-storage.go

    		}
    		if sizeS.tiers != nil {
    			sizeS.tiers[storageclass.STANDARD] = tierStats{}
    			sizeS.tiers[storageclass.RRS] = tierStats{}
    		}
    
    		done := globalScannerMetrics.time(scannerMetricApplyAll)
    		objInfos, err := item.applyVersionActions(ctx, objAPI, fivs.Versions, globalExpiryState)
    		done()
    
    		if err != nil {
    			res["err"] = err.Error()
    			return sizeSummary{}, errSkipFile
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  2. cmd/tier-sweeper.go

    	// 3. If bucket versioning is enabled and
    	//    a. version id is specified, remove its remote object.
    	//    b. version id is not specified, nothing to be done (a delete marker is added).
    	delTier := false
    	switch {
    	case !os.Versioned, os.Suspended: // 1, 2.a, 2.b
    		delTier = true
    	case os.Versioned && os.VersionID != "": // 3.a
    		delTier = true
    	}
    	if delTier {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. cmd/storage-errors.go

    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    var errDoneForNow = errors.New("done for now")
    
    // errSkipFile returned by the fn() for readDirFn() when it needs
    // to proceed to next entry.
    var errSkipFile = errors.New("skip this file")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    			if quit {
    				return
    			}
    
    			timer.Reset(randSleepFor())
    		}
    	}()
    
    	rebalanceLogEvent(ctx, "Pool %d rebalancing is started", poolIdx+1)
    
    	for {
    		select {
    		case <-ctx.Done():
    			doneCh <- ctx.Err()
    			return
    		default:
    		}
    
    		bucket, ok := z.nextRebalBucket(poolIdx)
    		if !ok {
    			// no more buckets to rebalance or target free_space/capacity reached
    			break
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     * Executor, and sequentially such that no two will ever be running at the same time.
     *
     * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order.
     *
     * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue.
     * When a task is {@linkplain Thread#interrupt interrupted}, execution of subsequent tasks
     * continues. See {@link QueueWorker#workOnQueue} for details.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     * Executor, and sequentially such that no two will ever be running at the same time.
     *
     * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order.
     *
     * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue.
     * When a task is {@linkplain Thread#interrupt interrupted}, execution of subsequent tasks
     * continues. See {@link QueueWorker#workOnQueue} for details.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SigningDigest.java

                Hexdump.hexdump( log, b, 0, b.length );
                log.flush();
            }
            updates = 0;
    
            return b;
        }
    
        /**
         * Performs MAC signing of the SMB.  This is done as follows.
         * The signature field of the SMB is overwritted with the sequence number;
         * The MD5 digest of the MAC signing key + the entire SMB is taken;
         * The first 8 bytes of this are placed in the signature field.
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7K bytes
    - Viewed (0)
  8. cmd/dynamic-timeouts_test.go

    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    				for j := 0; j < 100; j++ {
    					timeout.LogSuccess(time.Duration(float64(time.Second) * rng.Float64()))
    				}
    				to := timeout.Timeout()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  9. docs/en/docs/contributing.md

    ```
    
    </div>
    
    as Uvicorn by default will use the port `8000`, the documentation on port `8008` won't clash.
    
    ### Translations
    
    Help with translations is VERY MUCH appreciated! And it can't be done without the help from the community. 🌎 🚀
    
    Here are the steps to help with translations.
    
    #### Tips and guidelines
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 25 02:44:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. internal/event/target/webhook.go

    		id:         event.TargetID{ID: id, Name: "webhook"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		transport:  transport,
    		store:      queueStore,
    		cancel:     cancel,
    		cancelCh:   ctx.Done(),
    	}
    
    	// Calculate the webhook addr with the port number format
    	target.addr = args.Endpoint.Host
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
Back to top