Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1041 - 1050 of 2,682 for latch (0.11 seconds)

  1. src/test/java/org/codelibs/fess/job/CrawlJobTest.java

                    return 5;
                }
            });
    
            try {
                crawlJob.execute();
                fail("Should throw JobProcessingException");
            } catch (JobProcessingException e) {
                assertTrue(e.getMessage().contains("10 crawler processes are running"));
                assertTrue(e.getMessage().contains("Max processes are 5"));
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 25K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/collect/ImmutableListCopyOfConcurrentlyModifiedInputTest.java

                try {
                  Object returnValue = method.invoke(delegate, args);
                  mutateDelegate();
                  return returnValue;
                } catch (InvocationTargetException e) {
                  throw e.getCause();
                } catch (IllegalAccessException e) {
                  throw new AssertionError(e);
                }
              }
    
              private void mutateDelegate() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. src/main/java/jcifs/netbios/Lmhosts.java

                        try (FileReader r = new FileReader(f)) {
                            populate(r, tc);
                        }
                    }
                    result = this.table.get(name);
                }
            } catch (final IOException fnfe) {
                log.error("Could not read lmhosts " + tc.getConfig().getLmHostsFileName(), fnfe); //$NON-NLS-1$
            }
            return result;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb1/com/SmbComSessionSetupAndXTest.java

        private static Object getField(Object target, String name) {
            try {
                var f = target.getClass().getDeclaredField(name);
                f.setAccessible(true);
                return f.get(target);
            } catch (Exception e) {
                fail("access field " + name, e);
                return null;
            }
        }
    
        private static int invokeProtectedInt(Object target, String name, Object... params) {
            try {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  5. src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java

                        .forEach(path -> {
                            try {
                                Files.delete(path);
                            } catch (IOException e) {
                                // Ignore cleanup errors
                            }
                        });
            }
        }
    
        @Test
        public void testRequestDurableHandle() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/reflect/ClassPath.java

          try {
            try {
              urls.add(new File(entry).toURI().toURL());
            } catch (SecurityException e) { // File.toURI checks to see if the file is a directory
              urls.add(new URL("file", null, new File(entry).getAbsolutePath()));
            }
          } catch (MalformedURLException e) {
            logger.log(WARNING, "malformed classpath entry: " + entry, e);
          }
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 24.8K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/curl/io/ContentCacheTest.java

        }
    
        @Test
        public void testMemoryBasedCacheConstructorWithNull() {
            try {
                new ContentCache((byte[]) null);
                fail("Expected IllegalArgumentException");
            } catch (IllegalArgumentException e) {
                assertTrue(e.getMessage().contains("data must not be null"));
            }
        }
    
        @Test
        public void testMemoryBasedCacheDefensiveCopy() throws IOException {
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 15.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/hash/Striped64.java

        static {
          try {
            UNSAFE = getUnsafe();
            Class<?> ak = Cell.class;
            VALUE_OFFSET = UNSAFE.objectFieldOffset(ak.getDeclaredField("value"));
          } catch (Exception e) {
            throw new Error(e);
          }
        }
      }
    
      /**
       * ThreadLocal holding a single-slot int array holding hash code. Unlike the JDK8 version of this
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 15 22:17:15 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java

                }
                return new SuggestItem(wordsList.toArray(String[]::new), readingList.toArray(String[][]::new), fields, 0, score, -1, tags,
                        roles, langs, SuggestItem.Kind.QUERY);
            } catch (final IOException e) {
                throw new SuggesterException("Failed to create SuggestItem from search words.", e);
            }
        }
    
        @Override
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 15.2K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/info/GlobalBuildInfoPlugin.java

            try {
                List<String> versionLines = IOUtils.readLines(new FileInputStream(versionsFile), "UTF-8");
                return new BwcVersions(versionLines);
            } catch (IOException e) {
                throw new IllegalStateException("Unable to resolve to resolve bwc versions from versionsFile.", e);
            }
        }
    
        private void logGlobalBuildInfo() {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Aug 17 10:02:58 GMT 2021
    - 18.1K bytes
    - Click Count (0)
Back to Top