- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for poll (0.33 sec)
-
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
} } @GuardedBy("this") void drainKeyReferenceQueue(ReferenceQueue<K> keyReferenceQueue) { Reference<? extends K> ref; int i = 0; while ((ref = keyReferenceQueue.poll()) != null) { @SuppressWarnings("unchecked") E entry = (E) ref; map.reclaimKey(entry); if (++i == DRAIN_MAX) { break; } } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Synchronized.java
public E peek() { synchronized (mutex) { return delegate().peek(); } } @Override @CheckForNull public E poll() { synchronized (mutex) { return delegate().poll(); } } @Override public E remove() { synchronized (mutex) { return delegate().remove(); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 53.4K bytes - Viewed (0) -
cmd/iam.go
logger.Info("IAM expired STS purge took %.2fs", took) } } // The following actions are performed about once in 4 times that // IAM is refreshed: if r.Intn(4) == 0 { // Poll and remove accounts for those users who were removed // from LDAP/OpenID. if sys.LDAPConfig.Enabled() { sys.purgeExpiredCredentialsForLDAP(ctx) sys.updateGroupMembershipsForLDAP(ctx) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/erasure-server-pool.go
for _, pool := range pools { if opts.SkipDecommissioned && z.IsSuspended(pool.Index) { continue } // Skip object if it's from pools participating in a rebalance operation. if opts.SkipRebalancing && z.IsPoolRebalancing(pool.Index) { continue } if isErrReadQuorum(pool.Err) || pool.Err == nil { errs = append(errs, poolErrs{Err: pool.Err, Index: pool.Index}) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
common/scripts/metallb-native.yaml
allocation for a pool. type: boolean avoidBuggyIPs: default: false description: AvoidBuggyIPs prevents addresses ending with .0 and .255 to be used by a pool. type: boolean serviceAllocation: description: AllocateTo makes ip pool allocation to specific namespace
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Feb 23 23:56:31 GMT 2024 - 63.9K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-dashboard.json
"expr": "minio_cluster_health_status{job=~\"$scrape_jobs\"}", "fullMetaSearch": false, "includeNullMetadata": true, "interval": "", "legendFormat": "Pool: {{pool}} Set: {{set}}", "range": true, "refId": "A", "useBackend": false } ], "title": "Cluster Health Status", "type": "stat" }, {
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 10:03:01 GMT 2024 - 93K bytes - Viewed (2) -
cmd/erasure-object.go
} toEncode := io.Reader(data) if data.Size() >= bigFileThreshold { // We use 2 buffers, so we always have a full buffer of input. pool := globalBytePoolCap.Load() bufA := pool.Get() bufB := pool.Get() defer pool.Put(bufA) defer pool.Put(bufB) ra, err := readahead.NewReaderBuffer(data, [][]byte{bufA[:fi.Erasure.BlockSize], bufB[:fi.Erasure.BlockSize]}) if err == nil { toEncode = ra
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* also cause future calls to the client to be rejected. * * ```java * client.dispatcher().executorService().shutdown(); * ``` * * Clear the connection pool with [evictAll()][ConnectionPool.evictAll]. Note that the connection * pool's daemon thread may not exit immediately. * * ```java * client.connectionPool().evictAll(); * ``` *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
* **There is no longer a global singleton connection pool.** In OkHttp 2.x, all `OkHttpClient` instances shared a common connection pool by default. In OkHttp 3.x, each new `OkHttpClient` gets its own private connection pool. Applications should avoid creating many connection pools as doing so prevents connection reuse. Each connection pool holds its own set of
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
cmd/batch-handlers.go
VersionID: versionID, // Since we are preserving a delete marker, we have to make sure this is always true. // regardless of the current configuration of the bucket we must preserve all versions // on the pool being batch replicated from source. Versioned: true, MTime: srcObjInfo.ModTime, DeleteMarker: srcObjInfo.DeleteMarker, ReplicationRequest: true, }) return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0)