- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 334 for Queues (0.05 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
}); saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL)); return redirect(getClass()); } /** * Clears all crawler indices including queue, data, and filter indices. * * @param form the action form (validated but not used for configuration) * @return HTML response redirecting to the maintenance page */ @Execute
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 18K bytes - Viewed (0) -
cmd/metacache-server-pool.go
skip = act.Delete() && !act.DeleteRestored() } } fiv, err := obj.fileInfoVersions(o.Bucket) if err != nil { return } // Expire all versions if needed, if not attempt to queue for replication. for _, version := range fiv.Versions { objInfo := version.ToObjectInfo(o.Bucket, obj.name, versioned) if o.Lifecycle != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.9K bytes - Viewed (0) -
docs/de/docs/tutorial/background-tasks.md
Sie erfordern in der Regel komplexere Konfigurationen und einen Nachrichten-/Job-Queue-Manager wie RabbitMQ oder Redis, ermöglichen Ihnen jedoch die Ausführung von Hintergrundtasks in mehreren Prozessen und insbesondere auf mehreren Servern.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 5.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.NavigableMap; import java.util.NavigableSet; import java.util.Optional; import java.util.OptionalDouble; import java.util.OptionalInt; import java.util.OptionalLong; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.UUID; import java.util.concurrent.BlockingDeque;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 21.4K bytes - Viewed (0) -
cmd/bucket-replication.go
EventName: eventName, BucketName: bucket, Object: objInfo, UserAgent: "Internal: [Replication]", Host: globalLocalNodeName, }) // re-queue failures once more - keep a retry count to avoid flooding the queue if // the target site is down. Leave it to scanner to catch up instead. if rinfos.ReplicationStatus() != replication.Completed { ri.OpType = replication.HealReplicationType
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
docs/es/docs/advanced/openapi-callbacks.md
Observa que no estás pasando el router en sí (`invoices_callback_router`) a `callback=`, sino el atributo `.routes`, como en `invoices_callback_router.routes`. /// ### Revisa la documentación Ahora puedes iniciar tu aplicación e ir a <a href="http://127.0.0.1:8000/docs" class="external-link" target="_blank">http://127.0.0.1:8000/docs</a>.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
/** Available send credits for flow control */ protected final AtomicInteger sendCredits; /** Available receive credits for flow control */ protected final AtomicInteger receiveCredits; /** Queue of pending RDMA work requests */ protected final BlockingQueue<RdmaWorkRequest> pendingRequests; // Connection state /** Current connection state */ protected volatile RdmaConnectionState state;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 8.2K bytes - Viewed (0) -
docs/de/docs/project-generation.md
GitHub: <a href="https://github.com/tiangolo/full-stack-fastapi-couchbase" class="external-link" target="_blank">https://github.com/tiangolo/full-stack-fastapi-couchbase</a> ⚠️ **WARNUNG** ⚠️ Wenn Sie ein neues Projekt von Grund auf starten, prüfen Sie die Alternativen hier.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 6.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
* executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently. */ class Dispatcher() { /** * The maximum number of requests to execute concurrently. Above this requests queue in memory, * waiting for the running calls to complete. * * If more than [maxRequests] requests are in flight when this is invoked, those requests will * remain in flight. */ @get:Synchronized
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 8.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
} } /** * Stores a failure URL with error information for later analysis. * * @param crawlerContext the crawler context * @param urlQueue the URL queue containing the failed URL * @param errorName the name/type of the error * @param e the throwable that caused the failure * @return the stored FailureUrl entity */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 8.2K bytes - Viewed (0)