Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 329 for Queues (0.18 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

            validate(form, messages -> {}, this::asIndexHtml);
            verifyToken(this::asIndexHtml);
            searchEngineClient.admin().indices().prepareDelete(//
                    fessConfig.getIndexDocumentCrawlerIndex() + ".queue", //
                    fessConfig.getIndexDocumentCrawlerIndex() + ".data", //
                    fessConfig.getIndexDocumentCrawlerIndex() + ".filter")
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 14K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of AMQP `%s`: %w", id, err)
    		}
    	}
    
    	target := &AMQPTarget{
    		id:         event.TargetID{ID: id, Name: "amqp"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. kotlin-js-store/yarn.lock

        get-caller-file "^2.0.5"
        require-directory "^2.1.1"
        string-width "^4.2.0"
        y18n "^5.0.5"
        yargs-parser "^20.2.2"
    
    yocto-queue@^0.1.0:
      version "0.1.0"
      resolved "https://registry.yarnpkg.com/yocto-queue/-/yocto-queue-0.1.0.tgz#0294eb3dee05028d31ee1a5fa2c556a6aaf10a1b"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  4. docs/contribute/concurrency.md

    #### Per-Connection Locks
    
    Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
    
    The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    					healOnce.Do(func() {
    						globalMRFState.addPartialOp(PartialOperation{
    							Bucket:     bucket,
    							Object:     object,
    							VersionID:  fi.VersionID,
    							Queued:     time.Now(),
    							SetIndex:   er.setIndex,
    							PoolIndex:  er.poolIndex,
    							BitrotScan: errors.Is(err, errFileCorrupt),
    						})
    					})
    					// Healing is triggered and we have written
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(final Service service, State from, State to) {
          checkNotNull(service);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(final Service service, State from, State to) {
          checkNotNull(service);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. src/main/resources/fess_config.properties

    index.document.update.index=fess.update
    index.document.suggest.index=fess
    index.document.crawler.index=fess_crawler
    index.document.crawler.queue.number_of_shards=10
    index.document.crawler.data.number_of_shards=10
    index.document.crawler.filter.number_of_shards=10
    index.document.crawler.queue.number_of_replicas=1
    index.document.crawler.data.number_of_replicas=1
    index.document.crawler.filter.number_of_replicas=1
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Tue Oct 01 14:13:38 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  9. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      // re-use a thread.
      std::vector<std::unique_ptr<DeviceThread>> device_threads_;
      // A cancellation manager to use if the caller does not provide one. When ops
      // are executed asynchronously this must outlive the queued op, so it can't be
      // function-local to Execute.
      mutable std::unique_ptr<CancellationManager> default_cancellation_manager_;
    };
    
    // Contains a tuple of tensors, one on each of the `underlying_devices_` of the
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  10. internal/event/target/postgresql.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of PostgreSQL `%s`: %w", id, err)
    		}
    	}
    
    	target := &PostgreSQLTarget{
    		id:         event.TargetID{ID: id, Name: "postgresql"},
    		args:       args,
    		firstPing:  false,
    		store:      queueStore,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top