Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 257 for processed_ (0.06 sec)

  1. docs/es/docs/deployment/server-workers.md

    Como viste en el capítulo anterior sobre [Conceptos de Despliegue](concepts.md){.internal-link target=_blank}, hay múltiples estrategias que puedes usar.
    
    Aquí te mostraré cómo usar **Uvicorn** con **worker processes** usando el comando `fastapi` o el comando `uvicorn` directamente.
    
    /// info | Información
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

                    ist.interrupt();
                }
            }
            return -1; // Indicate failure
        }
    
        /**
         * Timer task for destroying processes that exceed their timeout.
         * Handles graceful and forceful termination of thumbnail generation processes.
         */
        protected static class ProcessDestroyer extends TimerTask {
    
            /** The process to monitor and destroy. */
            private final Process p;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Fri Jul 18 14:34:06 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/PermissionHelper.java

         */
        public PermissionHelper() {
            // Default constructor
        }
    
        /**
         * Encodes a permission string into a search role format.
         * Processes user, group, and role prefixes along with allow/deny prefixes.
         *
         * @param value the permission string to encode
         * @return the encoded permission string, or null if the input is blank or invalid
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

          }
          readControlFrame()
        }
      }
    
      /**
       * Reads a message body into across one or more frames. Control frames that occur between
       * fragments will be processed. If the message payload is masked this will unmask as it's being
       * processed.
       */
      @Throws(IOException::class)
      private fun readMessage() {
        while (true) {
          if (closed) throw IOException("closed")
    
          if (frameLength > 0L) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/trans/TransCallNamedPipeResponse.java

    import jcifs.internal.SMBProtocolDecodingException;
    
    /**
     * Response for SMB1 TRANS_CALL_NAMED_PIPE transaction.
     *
     * This response contains the data returned from the named pipe
     * after a call transaction has been processed by the server.
     */
    public class TransCallNamedPipeResponse extends SmbComTransactionResponse {
    
        private final byte[] outputBuffer;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/query/TermRangeQueryCommandTest.java

            QueryBuilder builder = queryCommand.convertTermRangeQuery(context, query, 1.0f);
            assertNotNull(builder);
            assertTrue(builder instanceof RangeQueryBuilder);
    
            // Query was processed successfully
            RangeQueryBuilder rqb = (RangeQueryBuilder) builder;
            assertEquals("title", rqb.fieldName());
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                }
            }
            writeJsonResponse(HttpServletResponse.SC_METHOD_NOT_ALLOWED, escapeJsonKeyValue(MESSAGE_FIELD, method + " is not allowed."));
            return false;
        }
    
        /**
         * Processes a scroll search request.
         * @param request The HTTP request.
         * @param response The HTTP response.
         * @param chain The filter chain.
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
  8. src/test/java/org/codelibs/fess/util/OptionalUtilTest.java

            assertTrue(result.isPresent());
    
            // Test that we can chain operations
            String processed = result.map(s -> s.toLowerCase()).orElse("default");
    
            assertEquals("hello world", processed);
    
            // Test with null value
            String nullValue = null;
            OptionalEntity<String> emptyResult = OptionalUtil.ofNullable(nullValue);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 13K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

    import org.codelibs.fess.crawler.util.CrawlingParameterUtil;
    
    import jakarta.annotation.Resource;
    
    /**
     * <p>
     * {@link DefaultResponseProcessor} is a default implementation of {@link ResponseProcessor}.
     * It processes the response data based on the HTTP status code and configured transformer.
     * </p>
     *
     * <p>
     * It handles successful responses by transforming the data using a {@link Transformer}
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/SearchLogHelper.java

                        logger.debug("Failed to access UserInfo cache.", e);
                    }
                }
            }
            return OptionalEntity.empty();
        }
    
        /**
         * Processes the search log queue.
         *
         * @param queue The search log queue.
         */
        protected void processSearchLogQueue(final Queue<SearchLog> queue) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 26.3K bytes
    - Viewed (0)
Back to top