Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 494 for Load (0.19 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      private Class<?> settableFutureClass;
      private Class<?> abstractFutureClass;
    
      @Override
      protected void setUp() throws Exception {
        // Load the "normal" copy of SettableFuture and related classes.
        SettableFuture<?> unused = SettableFuture.create();
        // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. cmd/routers.go

    // Composed function registering routers for only distributed Erasure setup.
    func registerDistErasureRouters(router *mux.Router, endpointServerPools EndpointServerPools) {
    	var (
    		lockGrid   = globalLockGrid.Load()
    		commonGrid = globalGrid.Load()
    	)
    
    	// Register storage REST router only if its a distributed setup.
    	registerStorageRESTHandlers(router, endpointServerPools, commonGrid)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. cmd/config.go

    }
    
    // NewConfigSys - creates new config system object.
    func NewConfigSys() *ConfigSys {
    	return &ConfigSys{}
    }
    
    // Initialize and load config from remote etcd or local config directory
    func initConfig(objAPI ObjectLayer) (err error) {
    	bootstrapTraceMsg("load the configuration")
    	defer func() {
    		if err != nil {
    			bootstrapTraceMsg(fmt.Sprintf("loading configuration failed: %v", err))
    		}
    	}()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepository.java

    public class SimpleClassMetaDataRepository<T extends Attachable<T>> implements ClassMetaDataRepository<T> {
        private final Map<String, T> classes = new TreeMap<>();
    
        @SuppressWarnings("unchecked")
        public void load(File repoFile) {
            try {
                FileInputStream inputStream = new FileInputStream(repoFile);
                try {
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed May 21 06:20:45 UTC 2025
    - 4K bytes
    - Viewed (0)
  5. cmd/config-current.go

    		}
    	case config.LoggerWebhookSubSys:
    		loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.LoggerWebhookSubSys)
    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Unable to load logger webhook config: %w", err))
    		}
    		userAgent := getUserAgent(getMinioMode())
    		for n, l := range loggerCfg.HTTP {
    			if l.Enabled {
    				l.LogOnceIf = configLogOnceConsoleIf
    				l.UserAgent = userAgent
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops.go

    	defer locker.Unlock(lkctx)
    
    	// Load healing tracker in this disk
    	tracker, err := loadHealingTracker(ctx, disk)
    	if err != nil {
    		// A healing tracker may be deleted if another disk in the
    		// same erasure set with same healing-id successfully finished
    		// healing.
    		if errors.Is(err, errFileNotFound) {
    			return nil
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  7. internal/kms/kms.go

    	latency := make(map[time.Duration]uint64, len(k.latencyBuckets))
    	for i, b := range k.latencyBuckets {
    		latency[b] = k.latency[i].Load()
    	}
    
    	return &Metrics{
    		ReqOK:   k.reqOK.Load(),
    		ReqErr:  k.reqErr.Load(),
    		ReqFail: k.reqFail.Load(),
    		Latency: latency,
    	}, nil
    }
    
    // Status returns status information about the KMS.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 24 15:33:57 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. internal/kms/config.go

    				// Manually load the certificate and private key into memory.
    				// We need to check whether the private key is encrypted, and
    				// if so, decrypt it using the user-provided password.
    				certBytes, err := os.ReadFile(certFile)
    				if err != nil {
    					return tls.Certificate{}, fmt.Errorf("Unable to load KES client certificate as specified by the shell environment: %v", err)
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

      }
    
      // constructor tests
    
      public void testComputingFunction() {
        CacheLoader<Object, Object> loader =
            new CacheLoader<Object, Object>() {
              @Override
              public Object load(Object from) {
                return new Object();
              }
            };
        LocalLoadingCache<Object, Object> cache = makeCache(createCacheBuilder(), loader);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java

         */
        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initializing {}", this.getClass().getSimpleName());
            }
            load();
        }
    
        /**
         * Returns a list of available KeyMatch instances.
         *
         * @return A list of KeyMatch instances.
         */
        public List<KeyMatch> getAvailableKeyMatchList() {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 10.1K bytes
    - Viewed (0)
Back to top