- Sort Score
- Result 10 results
- Languages All
Results 581 - 590 of 778 for process (0.06 sec)
-
android/guava/src/com/google/common/hash/Crc32cHashFunction.java
*/ private int crc0 = INVERSE_COMPUTE_FOR_WORD_OF_ALL_1S; private int crc1 = 0; private int crc2 = 0; private int crc3 = 0; @Override protected void process(ByteBuffer bb) { if (finished) { throw new IllegalStateException( "The behavior of calling any method after calling hash() is undefined."); } while (bb.remaining() >= 16) {Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 28 01:26:26 UTC 2024 - 21.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
*/ @Deprecated @InlineMe( replacement = "Files.asByteSource(file).read(processor)", imports = "com.google.common.io.Files") @CanIgnoreReturnValue // some processors won't return a useful result @ParametricNullness public static <T extends @Nullable Object> T readBytes(File file, ByteProcessor<T> processor) throws IOException { return asByteSource(file).read(processor); }Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/impl/AbstractRuleTest.java
// Initial state assertNull(testRule.getResponseProcessor()); // Set response processor TestResponseProcessor processor = new TestResponseProcessor(); testRule.setResponseProcessor(processor); assertSame(processor, testRule.getResponseProcessor()); // Change response processor TestResponseProcessor newProcessor = new TestResponseProcessor();Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 21.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java
} catch (final Exception e) { throw new CrawlingAccessException("Could not access bucket:" + name, e); } } /** * Processes a storage request with timeout management. * @param uri the URI to process * @param includeContent whether to include the actual content in the response * @return the response data for the request
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17.9K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
logger.warn("Not Found for SearchLog: {}", clickLog); }); } catch (final Exception e) { logger.warn("Failed to process: {}", clickLog, e); } } if (clickLogList.size() >= batchSize) { processClickLog(clickLogList); updateClickFieldInIndex(clickCountMap);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 26.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/ApiResult.java
* Represents an API response for bulk operations, containing a list of processed items. */ public static class ApiBulkResponse extends ApiResponse { /** * Constructs an empty ApiBulkResponse. */ public ApiBulkResponse() { // NOP } /** * The list of items processed in the bulk operation. */Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 24.9K bytes - Viewed (0) -
docs/sts/web-identity.md
publicly/client-accessible endpoint for the MinIO Console. For example `MINIO_BROWSER_REDIRECT_URL=https://console.minio.example.org`. This will ensure that the redirect URL is set to `https://console.minio.example.org/oauth_callback` and the login process should work correctly. For deployments employing DNS round-robin on a single domain to all the MinIO servers, it is possible that after redirection the browser may land on a different MinIO server. For example, the domain `console.minio.example.org`...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.9K bytes - Viewed (0) -
cmd/server-main.go
if err != nil && !errors.Is(err, context.Canceled) { proxyLogIf(GlobalContext, err) } }, }) // On macOS, if a process already listens on LOCALIPADDR:PORT, net.Listen() falls back // to IPv6 address ie minio will start listening on IPv6 address whereas another // (non-)minio process is listening on IPv4 of given port. // To avoid this error situation we check for port availability.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
import org.dbflute.optional.OptionalThing; import org.lastaflute.taglib.function.LaFunctions; import org.lastaflute.web.response.ActionResponse; import org.lastaflute.web.response.StreamResponse; import org.lastaflute.web.ruts.process.ActionRuntime; import org.lastaflute.web.util.LaRequestUtil; import org.lastaflute.web.util.LaServletContextUtil; import org.opensearch.core.common.text.Text; import org.opensearch.search.fetch.subphase.highlight.HighlightField;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 52.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/allcommon/EsAbstractBehavior.java
} results[i] = itemResponse.isFailed() ? 0 : 1; } return results; } // to suppress xacceptUpdateColumnModifiedPropertiesIfNeeds()'s specify process @Override protected UpdateOption<CB> createPlainUpdateOption() { UpdateOption<CB> updateOption = new UpdateOption<CB>(); updateOption.xtoBeCompatibleBatchUpdateDefaultEveryColumn();Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0)