Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 255 for Queue (0.02 sec)

  1. 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)
  2. 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)
  3. .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)
  4. 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)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

              val newStream = Http2Stream(streamId, this@Http2Connection, false, inFinished, headers)
              lastGoodStreamId = streamId
              streams[streamId] = newStream
    
              // Use a different task queue for each stream because they should be handled in parallel.
              taskRunner.newQueue().execute("$connectionName[$streamId] onStream") {
                try {
                  listener.onStream(newStream)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. 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)
  7. cmd/sftp-server-driver.go

    	_ = w.r.CloseWithError(err)
    	w.err = err
    }
    
    func (w *writerAt) Close() (err error) {
    	switch {
    	case len(w.buffer) > 0:
    		err = errors.New("some file segments were not flushed from the queue")
    		_ = w.w.CloseWithError(err)
    	case w.err != nil:
    		// No need to close here since both pipes were
    		// closing inside TransferError()
    		err = w.err
    	default:
    		err = w.w.Close()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. go.mod

    	github.com/docker/go-units v0.5.0 // indirect
    	github.com/eapache/go-resiliency v1.7.0 // indirect
    	github.com/eapache/go-xerial-snappy v0.0.0-20230731223053-c322873962e3 // indirect
    	github.com/eapache/queue v1.1.0 // indirect
    	github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f // indirect
    	github.com/fatih/structs v1.1.0 // indirect
    	github.com/felixge/httpsnoop v1.0.4 // indirect
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. docs/en/data/external_links.yml

    I'm Leaving Flask - author: Mike Moritz author_link: https://medium.com/@mike.p.moritz link: https://medium.com/@mike.p.moritz/using-docker-compose-to-deploy-a-lightweight-python-rest-api-with-a-job-queue-37e6072a209b title: Using Docker Compose to deploy a lightweight Python REST API with a job queue - author: '@euri10' author_link: https://gitlab.com/euri10 link: https://gitlab.com/euri10/fastapi_cheatsheet title: A FastAPI and Swagger UI visual cheatsheet - author: Uber Engineering author_link:...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 24 18:39:34 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    	return MetricDescription{
    		Namespace: s3MetricNamespace,
    		Subsystem: requestsSubsystem,
    		Name:      waitingTotal,
    		Help:      "Total number of S3 requests in the waiting queue",
    		Type:      gaugeMetric,
    	}
    }
    
    func getIncomingS3RequestsMD() MetricDescription {
    	return MetricDescription{
    		Namespace: s3MetricNamespace,
    		Subsystem: requestsSubsystem,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top