- Sort Score
- Num 10 results
- Language All
Results 1051 - 1060 of 1,328 for Waited (0.06 seconds)
-
src/main/java/org/codelibs/fess/chat/ChatClient.java
} } } if (!fallbackSucceeded) { // All fallbacks failed - generate no-results response phaseStartTime = System.currentTimeMillis(); callback.onPhaseStart(ChatPhaseCallback.PHASE_ANSWER, "Generating response...");Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 56.6K bytes - Click Count (0) -
cmd/xl-storage.go
for name, tier := range sizeS.tiers { res["tier-size-"+name] = strconv.FormatUint(tier.TotalSize, 10) res["tier-versions-"+name] = strconv.Itoa(tier.NumVersions) } if sizeS.failedCount > 0 { res["repl-failed"] = fmt.Sprintf("%d versions, %d bytes", sizeS.failedCount, sizeS.failedSize) } if sizeS.pendingCount > 0 { res["repl-pending"] = fmt.Sprintf("%d versions, %d bytes", sizeS.pendingCount, sizeS.pendingSize) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
onFailure(e, responseTime); if (e instanceof CIFSException) { throw (CIFSException) e; } throw new CIFSException("Circuit breaker operation failed", e); } } finally { activeRequests.decrementAndGet(); if (semaphoreAcquired) { requestSemaphore.release(); } } }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 33.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
final TestCloseable closeable2 = new TestCloseable("closeable2"); final TestCloseable closeable3 = new TestCloseable("closeable3"); final TestCloseable closeable4 = new TestCloseable("closeable4"); final Waiter waiter = new Waiter(); final CountDownLatch futureCancelled = new CountDownLatch(1); final Exception exception = new Exception(); final Closeable mockCloseable = mock(Closeable.class); @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/synonym/ApiAdminDictSynonymAction.java
return null; }); try (InputStream inputStream = form.synonymFile.getInputStream()) { file.update(inputStream); } catch (final IOException e) { logger.warn("Failed to process a request.", e); throwValidationErrorApi(messages -> messages.addErrorsFailedToUploadProtwordsFile(GLOBAL)); } return asJson(new ApiResult.ApiResponse().status(ApiResult.Status.OK).result());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.3K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.4K bytes - Click Count (1) -
src/test/java/jcifs/SmbTreeTest.java
/** * Test for close() method throwing exception. * Verifies behavior when close throws an exception. */ @Test void testClose_throwsException() { doThrow(new RuntimeException("Failed to close")).when(smbTree).close(); assertThrows(RuntimeException.class, () -> smbTree.close(), "Should propagate exception when close fails"); } /** * Test for AutoCloseable functionality.Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.2K bytes - Click Count (0) -
cmd/storage-rest-client.go
func (client *storageRESTClient) String() string { return client.endpoint.String() } // IsOnline - returns whether client failed to connect or not. func (client *storageRESTClient) IsOnline() bool { return client.restClient.IsOnline() || client.IsOnlineWS() } // IsOnlineWS - returns whether websocket client failed to connect or not. func (client *storageRESTClient) IsOnlineWS() bool { return client.gridConn.State() == grid.StateConnected
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stopwords/AdminDictStopwordsAction.java
try (InputStream inputStream = form.stopwordsFile.getInputStream()) { file.update(inputStream); } catch (final IOException e) { logger.warn("Failed to process a request.", e); throwValidationError(messages -> messages.addErrorsFailedToUploadStopwordsFile(GLOBAL), () -> redirectWith(getClass(), moreUrl("uploadpage/" + form.dictId)));
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 20.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/trans/TransWaitNamedPipeResponseTest.java
int len = testCase[1]; // Act int result = response.readSetupWireFormat(buffer, bufferIndex, len); // Assert assertEquals(0, result, "Failed for bufferIndex=" + bufferIndex + ", len=" + len); } } @Test @DisplayName("readParametersWireFormat should return 0") void testReadParametersWireFormat() { // Arrange
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.1K bytes - Click Count (0)