Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Finished (0.08 sec)

  1. cmd/background-newdisks-heal-ops.go

    	// Filled during heal.
    	HealedBuckets []string
    
    	// ID of the current healing operation
    	HealID string
    
    	ItemsSkipped uint64
    	BytesSkipped uint64
    
    	RetryAttempts uint64
    
    	Finished bool // finished healing, whether with errors or not
    
    	// Add future tracking capabilities
    	// Be sure that they are included in toHealingDisk
    }
    
    // loadHealingTracker will load the healing tracker from the supplied disk.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/TransformerContextBuilder.java

         */
        TransformerContext initialize(ModelBuildingRequest request, ModelProblemCollector problems);
    
        /**
         * The immutable transformerContext, can be used after the buildplan is finished.
         *
         * @return the immutable transformerContext
         */
        TransformerContext build();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/events.md

    The first part of the function, before the `yield`, will be executed **before** the application starts.
    
    And the part after the `yield` will be executed **after** the application has finished.
    
    ### Async Context Manager
    
    If you check, the function is decorated with an `@asynccontextmanager`.
    
    That converts the function into something called an "**async context manager**".
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java

            String wallClock = session.getRequest().getDegreeOfConcurrency() > 1 ? " (Wall Clock)" : "";
    
            logger.info("Total time:  {}{}", formatDuration(time), wallClock);
    
            logger.info("Finished at: {}", formatTimestamp(finish));
        }
    
        @Override
        public void projectSkipped(ExecutionEvent event) {
            if (logger.isInfoEnabled()) {
                init();
                logger.info("");
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    				if !ok {
    					// check if we can get one entry at least
    					// proceed to heal nonetheless.
    					entry, _ = entries.firstFound()
    				}
    				jt.Take()
    				go healEntry(bucket, *entry)
    			},
    			finished: func(errs []error) {
    				if countErrs(errs, nil) != len(errs) {
    					retErr = fmt.Errorf("one or more errors reported during listing: %v", errors.Join(errs...))
    				}
    			},
    		})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    const (
    	healNotStartedStatus healStatusSummary = "not started"
    	healRunningStatus                      = "running"
    	healStoppedStatus                      = "stopped"
    	healFinishedStatus                     = "finished"
    )
    
    const (
    	// a heal sequence with this many un-consumed heal result
    	// items blocks until heal-status consumption resumes or is
    	// aborted due to timeout.
    	maxUnconsumedHealResultItems = 1000
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

           *   or it had already failed. (It couldn't have completed *successfully* or even had
           *   setFuture called on it: Neither of those can happen until we've finished processing all
           *   the completed inputs. And we're still processing at least one input, the one that
           *   triggered handleException.)
           *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    						foundObjs = foundObjs || err == nil
    					}
    					custom["success_versions"] = fmt.Sprint(successVersions)
    					custom["failed_versions"] = fmt.Sprint(failVersions)
    				},
    				// Too many disks failed.
    				finished: func(errs []error) {
    					if f.dataUsageScannerDebug {
    						console.Debugf(healObjectsPrefix+" too many errors: %v\n", errs)
    					}
    					cancel()
    				},
    			})
    
    			stopFn()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  9. cmd/iam.go

    		}
    	}
    
    	if firstTime {
    		bootstrapTraceMsg(fmt.Sprintf("globalIAMSys.Load(): (duration: %s)", loadDuration))
    		if globalIsDistErasure {
    			logger.Info("IAM load(startup) finished. (duration: %s)", loadDuration)
    		}
    	}
    
    	select {
    	case <-sys.configLoaded:
    	default:
    		close(sys.configLoaded)
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    			// - if we found healing tracker 'healing.bin'
    			dcinfo.Healing = errors.Is(err, errUnformattedDisk)
    			if !dcinfo.Healing {
    				if hi := s.Healing(); hi != nil && !hi.Finished {
    					dcinfo.Healing = true
    				}
    			}
    
    			dcinfo.ID = diskID
    			return dcinfo, err
    		},
    	)
    
    	// Success.
    	return s, nil
    }
    
    // getDiskInfo returns given disk information.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top