Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 201 for brokers (0.05 sec)

  1. cmd/bucket-replication.go

    	if (checkOld > 0 && len(p.workers) != checkOld) || n == len(p.workers) || n < 1 {
    		// Either already satisfied or worker count changed while we waited for the lock.
    		return
    	}
    	for len(p.workers) < n {
    		input := make(chan ReplicationWorkerOperation, 10000)
    		p.workers = append(p.workers, input)
    
    		go p.AddWorker(input, &p.activeWorkers)
    	}
    	for len(p.workers) > n {
    		worker := p.workers[len(p.workers)-1]
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  2. src/main/java/jcifs/SmbTransportPool.java

         *
         * @param dc the domain controller address
         * @param tc the CIFS context containing credentials
         * @throws CIFSException if an error occurs during authentication
         * @deprecated functionality is broken and will be removed at some point,
         *             use actual Active Directory authentication instead
         */
        @Deprecated
        void logon(CIFSContext tc, Address dc) throws CIFSException;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  3. cmd/global-heal.go

    	}
    	// allow overriding this value as well..
    	if v := globalHealConfig.GetWorkers(); v > 0 {
    		numHealers = uint64(v)
    	}
    
    	healingLogEvent(ctx, "Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers)
    
    	jt, _ := workers.New(int(numHealers))
    
    	healEntryDone := func(name string) healEntryResult {
    		return healEntryResult{
    			entryDone: true,
    			name:      name,
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  4. docs/es/docs/deployment/concepts.md

    Aquí hay algunas combinaciones y estrategias posibles:
    
    * **Uvicorn** con `--workers`
        * Un administrador de procesos de Uvicorn **escucharía** en la **IP** y **puerto**, y iniciaría **múltiples worker processes de Uvicorn**.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun May 11 13:37:26 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  5. docs/es/docs/deployment/docker.md

    Así que, en este caso, **no** querrías tener múltiples workers en el contenedor, por ejemplo, con la opción de línea de comandos `--workers`. Querrías tener solo un **proceso Uvicorn por contenedor** (pero probablemente múltiples contenedores).
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri May 30 13:15:52 UTC 2025
    - 31K bytes
    - Viewed (0)
  6. cmd/bucket-replication-stats.go

    	sync.RWMutex                 // mutex for Cache
    	mostRecentStatsMu sync.Mutex // mutex for mostRecentStats
    
    	wlock sync.RWMutex // mutex for active workers
    
    	movingAvgTicker *time.Ticker // Ticker for calculating moving averages
    	wTimer          *time.Ticker // ticker for calculating active workers
    	qTimer          *time.Ticker // ticker for calculating queue stats
    }
    
    func (r *ReplicationStats) trackEWMA() {
    	for {
    		select {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  7. doc/next/7-ports.md

    ## Ports {#ports}
    
    ### Windows
    
    <!-- go.dev/issue/71671 -->
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Aug 06 21:28:12 UTC 2025
    - 226 bytes
    - Viewed (0)
  8. cmd/notification.go

    type NotificationGroup struct {
    	workers    *workers.Workers
    	errs       []NotificationPeerErr
    	retryCount int
    }
    
    // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks.
    func WithNPeers(nerrs int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	wk, _ := workers.New(nerrs)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.9K bytes
    - Viewed (0)
  9. ci/README.md

    and deploy TensorFlow. This folder is typically used by continuous integration
    (CI) tools to build and test TensorFlow whenever there is a change to the
    code. This folder is broken into subfolders that represent the level of support
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Tue Jun 06 21:00:01 UTC 2023
    - 825 bytes
    - Viewed (0)
  10. docs/changelogs/changelog_3x.md

        commitment was originally through December 31, 2020; we have since extended it.)
    
     *  **TLSv1 and TLSv1.1 are no longer enabled by default.** Major web browsers are working towards
        removing these versions altogether in early 2020. If your servers aren't ready yet you can
        configure OkHttp 3.13 to allow TLSv1 and TLSv1.1 connections:
    
        ```
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
Back to top