Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1051 - 1060 of 1,328 for Waited (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/main/java/jcifs/smb/SmbFileHandleImpl.java

                    // Note: Some fields may be final and cannot be nulled
    
                    // Clear any other mutable state would go here
                }
            } catch (Exception e) {
                log.error("Failed to perform emergency file handle cleanup", e);
            }
        }
    
        /**
         * @return a file handle with increased usage count
         */
        public SmbFileHandleImpl acquire() {
    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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top