- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 201 for brokers (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)