- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 1,269 for Pool (0.15 seconds)
-
internal/bpool/bpool_test.go
t.Fatalf("bytepool length invalid: got %v want %v", len(b), width) } if cap(b) != capWidth { t.Fatalf("bytepool cap invalid: got %v want %v", cap(b), capWidth) } bp.Put(b) // Fill the pool beyond the capped pool size. for i := uint64(0); i < size*2; i++ { bp.Put(make([]byte, bp.w, bp.wcap)) } b = bp.Get() if len(b) != width { t.Fatalf("bytepool length invalid: got %v want %v", len(b), width) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.7K bytes - Click Count (0) -
docs/distributed/CONFIG.md
``` ### Things to know - Fields such as `version` and `pools` are mandatory, however all other fields are optional. - Each pool expects a minimum of 2 nodes per pool, and unique non-repeating hosts for each argument. - Each pool expects each host in this pool has the same number of drives specified as any other host.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jun 25 02:30:18 GMT 2024 - 4.2K bytes - Click Count (0) -
cmd/handler-api.go
staleUploadsExpiry time.Duration staleUploadsCleanupInterval time.Duration deleteCleanupInterval time.Duration enableODirect bool gzipObjects bool rootAccess bool syncEvents bool objectMaxVersions int64 } const ( cgroupV1MemLimitFile = "/sys/fs/cgroup/memory/memory.limit_in_bytes"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.4K bytes - Click Count (0) -
internal/event/target/redis.go
} // Close - releases the resources used by the pool. func (target *RedisTarget) Close() error { close(target.quitCh) if target.pool != nil { return target.pool.Close() } return nil } func (target *RedisTarget) init() error { return target.initOnce.Do(target.initRedis) } func (target *RedisTarget) initRedis() error { conn := target.pool.Get() defer conn.Close()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
* be unique to the built instance of the ThreadFactory and will be assigned sequentially. For * example, {@code "rpc-pool-%d"} will generate thread names like {@code "rpc-pool-0"}, {@code * "rpc-pool-1"}, {@code "rpc-pool-2"}, etc. * @return this for the builder pattern */ @CanIgnoreReturnValue public ThreadFactoryBuilder setNameFormat(String nameFormat) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 29 17:36:00 GMT 2025 - 9.2K bytes - Click Count (0) -
ci/official/containers/ml_build/builder.devtoolset/build_devtoolset.sh
wget "http://old-releases.ubuntu.com/ubuntu/pool/main/e/eglibc/libc6_2.12.1-0ubuntu6_amd64.deb" && \ unar "libc6_2.12.1-0ubuntu6_amd64.deb" && \ tar -C "${TARGET}" -xvzf "libc6_2.12.1-0ubuntu6_amd64/data.tar.gz" && \ rm -rf "libc6_2.12.1-0ubuntu6_amd64.deb" "libc6_2.12.1-0ubuntu6_amd64" # Download binary glibc 2.12 development library release.
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Fri Jan 16 21:51:13 GMT 2026 - 8K bytes - Click Count (0) -
docs/features/connections.md
1. It uses the URL and configured OkHttpClient to create an **address**. This address specifies how we'll connect to the webserver. 2. It attempts to retrieve a connection with that address from the **connection pool**. 3. If it doesn't find a connection in the pool, it selects a **route** to attempt. This usually means making a DNS request to get the server's IP addresses. It then selects a TLS version and proxy server if necessary.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 5.4K bytes - Click Count (0) -
interfaces.go
type Plugin interface { Name() string Initialize(*DB) error } type ParamsFilter interface { ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{}) } // ConnPool db conns pool interface type ConnPool interface { PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Aug 19 13:33:31 GMT 2023 - 2.2K bytes - Click Count (0) -
cmd/metacache-set_gen.go
case "StopDiskAtLimit": z.StopDiskAtLimit, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "StopDiskAtLimit") return } case "pool": z.pool, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "pool") return } case "set": z.set, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "set") return } default:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
val id: Int, ) : RoutePlanner.Plan { var planningThrowable: Throwable? = null var canceled = false var connectState = ConnectState.READY val connection = factory.newConnection( pool = pool, route = factory.newRoute(address), idleAtNanos = defaultConnectionIdleAtNanos, ) var retry: FakePlan? = null var retryTaken = false var yieldBeforePlanReturns = falseCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 6.1K bytes - Click Count (0)