Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 2,682 for latch (0.03 seconds)

  1. src/main/java/jcifs/smb/SmbFile.java

                        }
                        return this.treeHandle;
    
                    } catch (InterruptedException ie) {
                        Thread.currentThread().interrupt();
                        throw new SmbException("Connection retry interrupted", ie);
                    } catch (CIFSException retryException) {
                        log.debug("Connection retry also failed", retryException);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 103.2K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/job/ExecJob.java

        }
    
        /**
         * Adds custom system properties that match the given regex pattern to the command list.
         *
         * @param cmdList the command list to add properties to
         * @param regex the regular expression pattern to match property names
         */
        protected void addFessCustomSystemProperties(final List<String> cmdList, final String regex) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/ReflectionFreeAssertThrows.java

                  + " map in that class.");
        }
        Object result;
        try {
          result = supplier.get();
        } catch (Throwable t) {
          if (predicate.apply(t)) {
            // We are careful to set up INSTANCE_OF to match each Predicate to its target Class.
            @SuppressWarnings("unchecked")
            T caught = (T) t;
            return caught;
          }
          throw new AssertionError(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 7K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/util/ComponentUtil.java

         * @return The index updater.
         */
        public static IndexUpdater getIndexUpdater() {
            return getComponent(INDEX_UPDATER);
        }
    
        /**
         * Gets the key match helper component.
         * @return The key match helper.
         */
        public static KeyMatchHelper getKeyMatchHelper() {
            return getComponent(KEY_MATCH_HELPER);
        }
    
        /**
         * Gets the indexing helper component.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 30.9K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            try {
                urlFilterService.delete(sessionId);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlFilter: sessionId={}", sessionId, e);
            }
            try {
                urlQueueService.delete(sessionId);
            } catch (final Exception e) {
                logger.warn("Failed to delete UrlQueue: sessionId={}", sessionId, e);
            }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  6. cmd/bitrot.go

    type BitrotVerifier struct {
    	algorithm BitrotAlgorithm
    	sum       []byte
    }
    
    // BitrotAlgorithmFromString returns a bitrot algorithm from the given string representation.
    // It returns 0 if the string representation does not match any supported algorithm.
    // The zero value of a bitrot algorithm is never supported.
    func BitrotAlgorithmFromString(s string) (a BitrotAlgorithm) {
    	for alg, name := range bitrotAlgorithms {
    		if name == s {
    			return alg
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/util/KuromojiCSVUtilTest.java

            } catch (NullPointerException e) {
                // Expected behavior
            }
        }
    
        @Test
        public void test_parse_null_input() {
            // Test null input handling
            try {
                KuromojiCSVUtil.parse(null);
                fail("Should throw NullPointerException for null input");
            } catch (NullPointerException e) {
                // Expected behavior
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 18.9K bytes
    - Click Count (0)
  8. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

                } catch (ModelParseException e) {
                    if (!strict) {
                        throw e;
                    }
    
                    options.put(ModelProcessor.IS_STRICT, Boolean.FALSE);
    
                    try {
                        model = modelProcessor.read(modelSource.getInputStream(), options);
                    } catch (ModelParseException ne) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sun Mar 30 23:08:08 GMT 2025
    - 55.3K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/helper/PluginHelper.java

                    }
                } catch (final Exception e) {
                    throw new PluginException("Failed to install the artifact " + artifact.getName(), e);
                }
            } else {
                try (final InputStream in = new FileInputStream(url)) {
                    CopyUtil.copy(in, ResourceUtil.getPluginPath(fileName).toFile());
                } catch (final Exception e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Mar 04 15:19:41 GMT 2026
    - 25.1K bytes
    - Click Count (0)
  10. docs/smb3-features/04-directory-leasing-design.md

                        }
                        
                    } catch (Exception e) {
                        if (handle.active) {
                            log.debug("Change notification failed for: " + handle.directoryPath, e);
                            // Retry after delay
                            try {
                                Thread.sleep(5000);
                            } catch (InterruptedException ie) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 36.2K bytes
    - Click Count (0)
Back to Top