Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 1,269 for Pool (0.15 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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 = false
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 6.1K bytes
    - Click Count (0)
Back to Top