- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for processor (0.08 sec)
-
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
* @param index the index name * @param id the document ID * @param condition the search condition * @param searchResult the result processor * @return the processed result */ protected <T> T get(final String index, final String id, final SearchCondition<GetRequestBuilder> condition,
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 121.9K bytes - Viewed (0) -
cmd/bucket-replication.go
maxLWorkers: maxLWorkers, } pool.ResizeLrgWorkers(maxLWorkers, 0) pool.ResizeWorkers(workers, 0) pool.ResizeFailedWorkers(failedWorkers) go pool.resyncer.PersistToDisk(ctx, o) go pool.processMRF() go pool.persistMRF() return pool } // AddMRFWorker adds a pending/failed replication worker to handle requests that could not be queued // to the other workers
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/action/FessMessages.java
/** The key of the message: It may have been processed before this request. Please try again. */ public static final String ERRORS_APP_DOUBLE_SUBMIT_REQUEST = "{errors.app.double.submit.request}"; /** The key of the message: Invalid username or password. */ public static final String ERRORS_login_error = "{errors.login_error}"; /** The key of the message: SSO login process failed. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 02:36:47 UTC 2025 - 119.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
} @Test @Disabled fun postBodiesRetransmittedOnAuthProblems() { fail("TODO") } @Test @Disabled fun cookiesAndTrailers() { // Do cookie headers get processed too many times? fail("TODO") } @Test fun emptyRequestHeaderValueIsAllowed() { server.enqueue( MockResponse(body = "body"), ) val response =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
enableProtocol(Protocol.HTTP_2) canceledBeforeResponseReadSignalsOnFailure() } /** * There's a race condition where the cancel may apply after the stream has already been * processed. */ @Test fun canceledAfterResponseIsDeliveredBreaksStreamButSignalsOnce() { server.enqueue(MockResponse(body = "A")) val latch = CountDownLatch(1) val bodyRef = AtomicReference<String?>()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.5.md
*...
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 136.4K bytes - Viewed (0)