- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 149 for processAces (0.05 sec)
-
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
return new StatsObject(); } }); } /** * Cleanup method called when the helper is being destroyed. * Logs cache statistics and processes any remaining statistics * objects in the cache before shutdown. */ @PreDestroy public void destroy() { if (logger.isDebugEnabled()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 17.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/webconfig/AdminWebconfigAction.java
default: break; } return OptionalEntity.empty(); } /** * Converts a form to a WebConfig entity with proper user and timestamp information. * Also processes permissions and virtual hosts from form fields. * * @param form the form containing the web config data * @return an optional WebConfig entity with updated metadata */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 21K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
}); }); } /** * Upload a new stemmer override dictionary file. * Processes the uploaded file and updates the dictionary. * * @param form The upload form containing the file and dictionary ID * @return HTML response redirecting to the list page on success */ @Execute
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 23.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/thumbnail/impl/CommandGeneratorTest.java
} // Test ProcessDestroyer inner class public void test_processDestroyer_creation() throws Exception { // We can't directly test ProcessDestroyer without creating actual processes, // but we can test that the class exists and basic functionality try { // Use reflection to verify ProcessDestroyer class exists
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Aug 31 08:19:00 UTC 2025 - 16.4K bytes - Viewed (0) -
docs/config/README.md
MINIO_ETCD_COMMENT (sentence) optionally add a comment to this setting ``` ### API By default, there is no limitation on the number of concurrent requests that a server/cluster processes at the same time. However, it is possible to impose such limitation using the API subsystem. Read more about throttling limitation in MinIO server [here](https://github.com/minio/minio/blob/master/docs/throttle/README.md). ```
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.1K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
if (StringUtil.isNotBlank(url)) { urlSet.add(RequestDataBuilder.newRequestData().get().url(url).build()); } } return urlSet; } /** * Processes the response data from a crawled URL, including failure handling. * This method extends the base response processing to handle Fess-specific failure * URL tracking when certain HTTP status codes are encountered. *
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 19.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java
throw new SsoLoginException("Failed to initialize SPNEGO.", e); } } /** * Attempts to obtain login credentials using SPNEGO authentication. * * This method processes the HTTP request to extract and validate SPNEGO * authentication tokens. It handles the SPNEGO handshake process and * extracts the user principal from successful authentication. *
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 17.2K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
} } // incrementBytes add bytes reported for a bucket/target. func (m *rateMeasurement) incrementBytes(bytes uint64) { atomic.AddUint64(&m.bytesSinceLastWindow, bytes) } // updateExponentialMovingAverage processes the measurements captured so far. func (m *rateMeasurement) updateExponentialMovingAverage(endTime time.Time) { // Calculate aggregate avg bandwidth and exp window avg m.lock.Lock() defer func() { m.startTime = endTime
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 14.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
// Create a mock JavaPropertiesResult java.util.Properties props = new java.util.Properties(); props.setProperty("job.max.crawler.processes", "5"); props.setProperty("java.command.path", "java"); org.dbflute.helper.jprop.JavaPropertiesReader reader =
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 31.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
) : WebSocket, WebSocketReader.FrameCallback, Lockable { private val key: String /** Non-null for client web sockets. These can be canceled. */ internal var call: Call? = null /** This task processes the outgoing queues. Call [runWriter] to after enqueueing. */ private var writerTask: Task? = null /** Null until this web socket is connected. Only accessed by the reader thread. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0)