Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 51 for synchronized (0.13 sec)

  1. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

            final int idx = sessionId.indexOf('-');
            if (idx >= 0) {
                return sessionId.substring(0, idx);
            }
            return sessionId;
        }
    
        public synchronized void store(final String sessionId, final boolean create) {
            CrawlingInfo crawlingInfo = create ? null : getCrawlingInfoService().getLast(sessionId);
            if (crawlingInfo == null) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. internal/logger/logrotate.go

    type Writer struct {
    	// opts are the configuration options for this Writer
    	opts Options
    
    	// f is the currently open file used for appends.
    	// Writes to f are only synchronized once Close() is called,
    	// or when files are being rotated.
    	f *os.File
    
    	pw *xioutil.PipeWriter
    	pr *xioutil.PipeReader
    }
    
    // Write writes p into the current file, rotating if necessary.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/exception/UserRoleLoginException.java

            this.actionClass = actionClass;
        }
    
        public Class<?> getActionClass() {
            return actionClass;
        }
    
        @Override
        public synchronized Throwable fillInStackTrace() {
            return null;
        }
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java

                dataMap.put(fessConfig.getIndexFieldDocId(), systemHelper.generateDocId(dataMap));
            }
    
            ComponentUtil.getLanguageHelper().updateDocument(dataMap);
    
            synchronized (docList) {
                docList.add(ingest(paramMap, dataMap));
                final long contentSize = indexingHelper.calculateDocumentSize(dataMap);
                docList.addContentSize(contentSize);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. internal/disk/fdatasync_linux.go

    // (st_size, as made by say ftruncate(2)), would require a metadata flush.
    //
    // The aim of fdatasync() is to reduce disk activity for applications that
    // do not require all metadata to be synchronized with the disk.
    func Fdatasync(f *os.File) error {
    	return syscall.Fdatasync(int(f.Fd()))
    }
    
    // FadviseDontNeed invalidates page-cache
    func FadviseDontNeed(f *os.File) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/exentity/ElevateWord.java

        public void setLabelTypeIds(final String[] labelTypeIds) {
            this.labelTypeIds = labelTypeIds;
        }
    
        public List<LabelType> getLabelTypeList() {
            if (labelTypeList == null) {
                synchronized (this) {
                    if (labelTypeList == null) {
                        final FessConfig fessConfig = ComponentUtil.getFessConfig();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    	// If NoWait is set, Get() will return the last good value,
    	// if TTL has expired but 2x TTL has not yet passed,
    	// but will fetch a new value in the background.
    	NoWait bool
    }
    
    // Cache contains a synchronized value that is considered valid
    // for a specific amount of time.
    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final CrawlerStatsHelper crawlerStatsHelper = ComponentUtil.getCrawlerStatsHelper();
            synchronized (indexUpdateCallback) {
                // required check
                if (!dataMap.containsKey(fessConfig.getIndexFieldUrl()) || dataMap.get(fessConfig.getIndexFieldUrl()) == null) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  9. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt

        abstract val fileSystemOperations: FileSystemOperations
    
        private
        var hasCleaned = false
    
        val logger = Logging.getLogger(CachesCleaner::class.java)
    
        fun cleanUpCaches() {
            synchronized(this) {
                if (hasCleaned) {
                    return
                }
                logger.lifecycle("Cleaning up caches...")
                val homeDir = parameters.homeDir.get()
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Fri Jun 28 08:29:28 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            return startProcess(sessionId, cmdList, pbCall, InputStreamThread.MAX_BUFFER_SIZE, null);
        }
    
        public synchronized JobProcess startProcess(final String sessionId, final List<String> cmdList, final Consumer<ProcessBuilder> pbCall,
                final int bufferSize, final Consumer<String> outputCallback) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
Back to top