Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for processor (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top