- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 2,062 for latch (0.06 sec)
-
src/test/java/org/codelibs/fess/helper/DataIndexHelperTest.java
public void test_crawl_withSessionId_emptyConfigList() { try { dataIndexHelper.crawl("test-session"); assertTrue("Should complete quickly with empty config list", true); } catch (Exception e) { assertTrue("Exception handling should be fast", true); } } public void test_crawl_withConfigIdList_emptyList() { try {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 05:35:01 UTC 2025 - 12.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/exception/FessUserNotFoundExceptionTest.java
String username = "nonexistentuser"; try { throw new FessUserNotFoundException(username); } catch (FessUserNotFoundException e) { assertEquals("User is not found: nonexistentuser", e.getMessage()); assertNull(e.getCause()); } catch (Exception e) { fail("Should have caught FessUserNotFoundException"); } }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
throw new CommandExecutionException("The command execution is timeout: " + String.join(" ", commands)); } return exitValue; } catch (final CrawlerSystemException e) { throw e; } catch (final InterruptedException e) { if (mt != null && mt.isTeminated()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 13.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 12.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
bw.flush(); } catch (IOException e) { throw new IORuntimeException(e); } }).execute()) { if (logger.isDebugEnabled()) { logger.debug("Bulk Response:\n{}", response.getContentAsString()); } systemHelper.reloadConfiguration(resetJobs.get()); } catch (final Exception e) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 29.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
this.connectionState.set(2); // connected try { validateNegotiation(transport, sess); } catch (final CIFSException se) { try { transport.disconnect(true); } catch (final IOException e) { log.warn("Failed to disconnect transport", e); se.addSuppressed(e); } throw se;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 30K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt
} catch (ignored: IllegalArgumentException) { } try { builder.connectTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { } try { builder.writeTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { } try { builder.readTimeout(Duration.ofNanos(1)) } catch (ignored: IllegalArgumentException) { }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 13.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java
// endpoint.connect(remoteAddress, 1000); // 1 second timeout state = RdmaConnectionState.CONNECTED; log.debug("DiSNI RDMA connection established to {}", remoteAddress); } catch (Exception e) { state = RdmaConnectionState.ERROR; throw new IOException("DiSNI RDMA connection failed", e); } } @Override
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 10.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
try { trans.ensureConnected(); } catch (final IOException e) { removeTransport(trans); throw e; } return trans.acquire(); } catch (final IOException e) { final String hostAddress = addr.getHostAddress();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
val byteRead = inputStream.read() // OpenJDK behavior: end of stream. assertThat(byteRead).isEqualTo(-1) } catch (e: ProtocolException) { // On Android, HttpURLConnection is implemented by OkHttp v2. OkHttp // treats an incomplete response body as a ProtocolException. } catch (ioe: IOException) { // Change in https://bugs.openjdk.org/browse/JDK-8335135
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 22.3K bytes - Viewed (0)