- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 247 for InterruptedException (0.27 sec)
-
src/main/java/jcifs/smb1/util/transport/Transport.java
try { disconnect(true); } catch (final IOException ioe2) { ioe2.printStackTrace(log); } throw ioe; } catch (final InterruptedException ie) { throw new TransportException(ie); } finally { response_map.remove(request); } } private void loop() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.3K bytes - Viewed (0) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) { try { Thread.sleep(50); } catch (InterruptedException e) { Thread.currentThread().interrupt(); break; } } assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 12.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt
@Throws(IOException::class) override fun onResponse( call: Call, response: Response, ) { try { Thread.sleep(500) } catch (e: InterruptedException) { throw AssertionError() } assertFailsWith<IOException> { response.body.source().readUtf8() }.also { expected -> exceptionRef.set(expected)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 10.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
public abstract class Dispatcher : Closeable { /** * Returns a response to satisfy `request`. This method may block (for instance, to wait on * a CountdownLatch). */ @Throws(InterruptedException::class) public abstract fun dispatch(request: RecordedRequest): MockResponse /** * Returns an early guess of the next response, used for policy on how an incoming request should
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 1.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/exec/CrawlerTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 30.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
return; } try { session.transport.wait(); } catch (final InterruptedException ie) { throw new SmbException(ie.getMessage(), ie); } } connectionState = 1; // trying ... try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 8.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
long pollInterval = Math.min(MAX_POLL_INTERVAL, BASE_POLL_INTERVAL + (registration.getHeartbeatFailures() * 500)); Thread.sleep(pollInterval); } catch (InterruptedException e) { log.debug("Async notification monitoring interrupted for {}", registrationId); Thread.currentThread().interrupt(); break;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 20.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackTest.java
public void store(DataStoreParams paramMap, Map<String, Object> dataMap) { try { Thread.sleep(10); // Simulate processing time } catch (InterruptedException e) { // Ignore } totalTime = System.currentTimeMillis() - startTime; } @Override public long getDocumentSize() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.4K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbTreeTest.java
SmbTree tree = new SmbTree(session, "testShare", "testService"); // Mock transport.connect() to throw RuntimeException wrapping InterruptedException doThrow(new RuntimeException(new InterruptedException("Interrupted"))).when(transport).connect(); // Should throw exception due to interrupted wait assertThrows(RuntimeException.class, () -> tree.treeConnect(null, null));
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 10.2K bytes - Viewed (0)