Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 334 for Queues (0.36 sec)

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