Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 253 for isSynchronized (0.08 sec)

  1. src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java

            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            ComponentUtil.getSsoManager().register(this);
        }
    
        protected synchronized org.codelibs.spnego.SpnegoAuthenticator getAuthenticator() {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            if (authenticator != null && fessConfig.getSystemPropertyAsBoolean(SPNEGO_INITIALIZED, false)) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            }
    
            logger.info("Finished SuggestCreator.");
            System.exit(exitCode);
        }
    
        private static void destroyContainer() {
            TimeoutManager.getInstance().stop();
            synchronized (SingletonLaContainerFactory.class) {
                SingletonLaContainerFactory.destroy();
            }
        }
    
        private static int process(final Options options) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/LabelTypeHelper.java

                return false;
            }
            return true;
        }
    
        public Set<String> getMatchedLabelValueSet(final String path) {
            if (labelTypePatternList == null) {
                synchronized (this) {
                    if (labelTypePatternList == null) {
                        buildLabelTypePatternList(ComponentUtil.getComponent(LabelTypeService.class).getLabelTypeList());
                    }
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        }
      }
    
      private static final class TimeoutFutureException extends TimeoutException {
        private TimeoutFutureException(String message) {
          super(message);
        }
    
        @Override
        public synchronized Throwable fillInStackTrace() {
          setStackTrace(new StackTraceElement[0]);
          return this; // no stack trace, wouldn't be useful anyway
        }
      }
    
      @Override
      @CheckForNull
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

            refresh();
        }
    
        public void deleteBadWord(final String badWord) {
            suggester.indexer().deleteBadWord(badWord);
            refresh();
        }
    
        public synchronized void refresh() {
            suggester.refresh();
            if (popularWordHelper != null) {
                popularWordHelper.clearCache();
            }
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

        @Resource
        protected ContentLengthHelper contentLengthHelper;
    
        protected volatile SmbAuthenticationHolder smbAuthenticationHolder;
    
        protected CIFSContext cifsContext;
    
        @Override
        public synchronized void init() {
            if (smbAuthenticationHolder != null) {
                return;
            }
    
            if (logger.isDebugEnabled()) {
                logger.debug("Initializing SmbClient...");
            }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 23 01:54:36 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      }
    
      private static class TestApplication extends Application {
        private final List<Thread> hooks = Lists.newArrayList();
    
        @Override
        synchronized void addShutdownHook(Thread hook) {
          hooks.add(hook);
        }
    
        synchronized void shutdown() throws InterruptedException {
          for (Thread hook : hooks) {
            hook.start();
          }
          for (Thread hook : hooks) {
            hook.join();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

                throws ModelInterpolationException {
            if (!src.contains("${")) {
                return src;
            }
    
            Logger logger = getLogger();
    
            String result = src;
            synchronized (this) {
                for (ValueSource vs : valueSources) {
                    interpolator.addValueSource(vs);
                }
    
                for (InterpolationPostProcessor postProcessor : postProcessors) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java

                return OptionalThing.empty();
            }
            return OptionalThing.of(pipeline);
        }
    
        public void refresh() {
            crawlingConfigCache.invalidateAll();
        }
    
        public synchronized String store(final String sessionId, final CrawlingConfig crawlingConfig) {
            final String sessionCountId = sessionId + "-" + count;
            crawlingConfigMap.put(sessionCountId, crawlingConfig);
            count++;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

          while (true) {
            var tryAgain = false
            var readBytesDelivered = -1L
            var errorExceptionToDeliver: IOException? = null
    
            // 1. Decide what to do in a synchronized block.
    
            ******@****.***ck {
              val doReadTimeout = doReadTimeout()
              if (doReadTimeout) {
                readTimeout.enter()
              }
              try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
Back to top