Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 483 for stop (0.03 sec)

  1. internal/kms/config.go

    		client.Endpoints = endpoints
    
    		// Keep the default key in the KES cache to prevent availability issues
    		// when MinIO restarts
    		go func() {
    			timer := time.NewTicker(10 * time.Second)
    			defer timer.Stop()
    			defaultKey := env.Get(EnvKESDefaultKey, "")
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case <-timer.C:
    					client.DescribeKey(ctx, defaultKey)
    				}
    			}
    		}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. cmd/tier.go

    		return time.Duration(r.Float64() * 5 * float64(time.Second))
    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    	t := time.NewTimer(tierCfgRefresh + randInterval())
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    			if err != nil {
    				tierLogIf(ctx, err)
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/exec/Crawler.java

                System.exit(exitCode);
            }
        }
    
        private static void destroyContainer() {
            if (running.getAndSet(false)) {
                TimeoutManager.getInstance().stop();
                if (logger.isDebugEnabled()) {
                    logger.debug("Destroying LaContainer...");
                }
                SingletonLaContainerFactory.destroy();
                logger.info("Destroyed LaContainer.");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

            }
            generatorList.forEach(g -> {
                try {
                    g.destroy();
                } catch (final Exception e) {
                    logger.warn("Failed to stop thumbnail generator.", e);
                }
            });
        }
    
        public String getThumbnailPathOption() {
            return "-D" + Constants.FESS_THUMBNAIL_PATH + "=" + baseDir.getAbsolutePath();
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    		globalAllHealState.Unlock()
    	}
    
    	// Init background heal state
    	if globalBackgroundHealState == nil {
    		globalBackgroundHealState = newHealState(GlobalContext, false)
    	} else {
    		globalBackgroundHealState.Lock()
    		for _, v := range globalBackgroundHealState.healSeqMap {
    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  6. src/archive/tar/reader.go

    			}
    
    			// Set the final guess at the format.
    			if format.has(FormatUSTAR) && format.has(FormatPAX) {
    				format.mayOnlyBe(FormatUSTAR)
    			}
    			hdr.Format = format
    			return hdr, nil // This is a file, so stop
    		}
    	}
    }
    
    // handleRegularFile sets up the current file reader and padding such that it
    // can only read the following logical data section. It will properly handle
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. cmd/endpoint.go

    	var foundLocal bool
    	resolvedList := make([]bool, len(endpoints))
    	// Mark the starting time
    	startTime := time.Now()
    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    	for {
    		// Break if the local endpoint is found already Or all the endpoints are resolved.
    		if foundLocal || (epsResolved == len(endpoints)) {
    			break
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            }
        }
    
        private void forceStop() {
            systemHelper.setForceStop(true);
            for (final Crawler crawler : crawlerList) {
                crawler.stop();
            }
        }
    
        public long getExecuteTime() {
            return executeTime;
        }
    
        public List<String> getSessionIdList() {
            return sessionIdList;
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  9. cmd/metrics-resource.go

    	resourceMetricsMapMu.Lock()
    	resourceMetricsMap = map[MetricSubsystem]ResourceMetrics{}
    	resourceMetricsMapMu.Unlock()
    	metricsTimer := time.NewTimer(resourceMetricsCollectionInterval)
    	defer metricsTimer.Stop()
    
    	collectLocalResourceMetrics()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-metricsTimer.C:
    			collectLocalResourceMetrics()
    
    			// Reset the timer for next cycle.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

            }
    
            try {
                return getResponseData(uri, includeContent);
            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25.7K bytes
    - Viewed (0)
Back to top