Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 307 for STOP (0.11 sec)

  1. 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)
  2. 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)
  3. docs/en/docs/deployment/docker.md

    #### Directory Structure
    
    You should now have a directory structure like:
    
    ```
    .
    ├── app
    │   ├── __init__.py
    │   └── main.py
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. 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)
  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. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/background-newdisks-heal-ops.go

    func monitorLocalDisksAndHeal(ctx context.Context, z *erasureServerPools) {
    	// Perform automatic disk healing when a disk is replaced locally.
    	diskCheckTimer := time.NewTimer(defaultMonitorNewDiskInterval)
    	defer diskCheckTimer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-diskCheckTimer.C:
    			healDisks := globalBackgroundHealState.getHealLocalDiskEndpoints()
    			if len(healDisks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top