Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 343 for queues (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. docs/pt/docs/tutorial/cors.md

    É possível declarar uma lista com `"*"` (um "curinga") para dizer que tudo está permitido.
    
    Mas isso só permitirá certos tipos de comunicação, excluindo tudo que envolva credenciais: cookies, cabeçalhos de autorização como aqueles usados ​​com Bearer Tokens, etc.
    
    Então, para que tudo funcione corretamente, é melhor especificar explicitamente as origens permitidas.
    
    ## Usar `CORSMiddleware`
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. .teamcity/src/main/kotlin/common/extensions.kt

            }
            skipConditionally(buildType)
        }
    }
    
    fun BuildStep.onlyRunOnGitHubMergeQueueBranch() {
        conditions {
            matches("teamcity.build.branch", "(pre-test/.*)|(gh-readonly-queue/.*)")
        }
    }
    
    fun BuildStep.skipConditionally(buildType: BuildType? = null) {
        // we need to run CompileALl unconditionally because of artifact dependency
        if (buildType !is CompileAll) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 10 03:25:26 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. internal/event/target/mysql.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 MySQL `%s`: %w", id, err)
    		}
    	}
    
    	if args.DSN == "" {
    		config := mysql.Config{
    			User:                 args.User,
    			Passwd:               args.Password,
    			Net:                  "tcp",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top