Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 2,062 for latch (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

                        response.setHeader("Content-Type", responseContentType);
                    }
                    CopyUtil.copy(in, out);
                } catch (final ClientAbortException e) {
                    logger.debug("Client aborts this request.", e);
                }
            } catch (final Exception e) {
                if (!(e.getCause() instanceof ClientAbortException)) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top