Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 951 - 960 of 2,682 for latch (0.07 seconds)

  1. src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java

                            map.put("lastModified", new Date(Files.getLastModifiedTime(filePath).toMillis()));
                        } catch (final IOException e) {
                            throw new IORuntimeException(e);
                        }
                        logFileItems.add(map);
                    });
                } catch (final Exception e) {
                    throw new FessSystemException("Failed to access log files: logFilePath=" + logFilePath, e);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 23 23:57:26 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/NotificationHelper.java

                        logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(),
                                response.getContentAsString());
                    }
                } catch (final IOException e) {
                    logger.warn("Failed to send {} to {}.", body, url, e);
                }
            }));
        }
    
        /**
         * Converts the discloser to a Slack message format.
         *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/thumbnail/impl/EmptyGeneratorTest.java

            // This will return false because getFessConfig() will fail
            // We verify the method handles the case gracefully
            try {
                emptyGenerator.isTarget(docMap);
            } catch (IllegalStateException e) {
                // Expected when container is not initialized
                assertTrue(e.getMessage().contains("Not initialized"));
            }
        }
    
        @Test
        public void test_getName() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/exception/ScheduledJobExceptionTest.java

            String expectedMessage = "Job execution failed";
            boolean exceptionCaught = false;
    
            try {
                throw new ScheduledJobException(expectedMessage);
            } catch (ScheduledJobException e) {
                exceptionCaught = true;
                assertEquals(expectedMessage, e.getMessage());
            }
    
            assertTrue(exceptionCaught);
        }
    
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/exception/StorageExceptionTest.java

            // Test throwing and catching the exception
            String expectedMessage = "Storage failure";
    
            try {
                throw new StorageException(expectedMessage);
            } catch (StorageException e) {
                assertEquals(expectedMessage, e.getMessage());
                assertNull(e.getCause());
            }
        }
    
        @Test
        public void test_throwAndCatchExceptionWithCause() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/testers/MapMergeTester.java

          fail("Expected NullPointerException or UnsupportedOperationException");
        } catch (NullPointerException | UnsupportedOperationException expected) {
        }
      }
    
      public void testMergeNullFunction() {
        try {
          getMap().merge(k0(), v3(), null);
          fail("Expected NullPointerException or UnsupportedOperationException");
        } catch (NullPointerException | UnsupportedOperationException expected) {
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                () -> {
                  enterLatch.countDown();
                  try {
                    new CountDownLatch(1).await(); // wait forever
                    throw new AssertionError();
                  } catch (InterruptedException e) {
                    interruptedExceptionThrown.set(true);
                    throw e;
                  } finally {
                  }
                });
        assertFalse(task.isDone());
        Thread thread =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/duplicatehost/AdminDuplicatehostAction.java

            getDuplicateHost(form).ifPresent(entity -> {
                try {
                    duplicateHostService.store(entity);
                    saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL));
                } catch (final Exception e) {
                    logger.warn("Failed to process a request.", e);
                    throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)),
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 13:56:35 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt

                    try {
                        projectState.verifyTestFilesCleanup(projectPath, projectPathToLeftoverFiles.getValue(projectPath))
                    } catch (e: Exception) {
                        exceptions.add(e)
                    }
                }
    
            when {
                exceptions.size == 1 -> throw exceptions.first()
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Feb 11 11:05:07 GMT 2026
    - 14.3K bytes
    - Click Count (1)
  10. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                  return task.toString();
                }
              };
          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
Back to Top