- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 691 for pool (0.19 sec)
-
schema/pool.go
package schema import ( "reflect" "sync" ) // sync pools var ( normalPool sync.Map poolInitializer = func(reflectType reflect.Type) FieldNewValuePool { v, _ := normalPool.LoadOrStore(reflectType, &sync.Pool{ New: func() interface{} { return reflect.New(reflectType).Interface() }, }) return v.(FieldNewValuePool) }
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Mon Apr 11 13:37:44 GMT 2022 - 345 bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
for i, pool := range nmeta2.Pools { if i == 0 { nmeta2.Pools[i] = PoolStatus{ CmdLine: pool.CmdLine, ID: i, LastUpdate: UTCNow(), Decommission: &PoolDecommissionInfo{ Complete: false, }, } } } testCases := []struct { meta poolMeta pools []*erasureSets expectedUpdate bool expectedErr bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 03 16:47:40 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/bpool/bpool.go
} select { case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w } // WidthCap returns the cap width of the byte arrays in this pool. func (bp *BytePoolCap) WidthCap() (n int) { if bp == nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
docs/distributed/CONFIG.md
console-address: ':9001' certs-dir: '/home/user/.minio/certs/' pools: # Specify the nodes and drives with pools - - 'https://server-example-pool1:9000/mnt/disk{1...4}/' - 'https://server{1...2}-pool1:9000/mnt/disk{1...4}/' - 'https://server3-pool1:9000/mnt/disk{1...4}/' - 'https://server4-pool1:9000/mnt/disk{1...4}/' - - 'https://server-example-pool2:9000/mnt/disk{1...4}/' - 'https://server{1...2}-pool2:9000/mnt/disk{1...4}/'
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.4K bytes - Viewed (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()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/InternersTest.java
String not = new String("a"); Interner<String> pool = Interners.newStrongInterner(); assertSame(canonical, pool.intern(canonical)); assertSame(canonical, pool.intern(not)); } public void testStrong_null() { Interner<String> pool = Interners.newStrongInterner(); assertThrows(NullPointerException.class, () -> pool.intern(null)); } public void testStrong_builder() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4K bytes - Viewed (0) -
docs/distributed/DECOMMISSION.md
# Decommissioning Decommissiong is a mechanism in MinIO to drain older pools (usually with old hardware) and migrate the content from such pools to a newer pools (usually better hardware). Decommissioning spreads the data across all pools - for example, if you decommission `pool1`, all the data from `pool1` spreads across `pool2` and `pool3`. ## Features
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 11 14:59:49 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/InternersTest.java
String not = new String("a"); Interner<String> pool = Interners.newStrongInterner(); assertSame(canonical, pool.intern(canonical)); assertSame(canonical, pool.intern(not)); } public void testStrong_null() { Interner<String> pool = Interners.newStrongInterner(); assertThrows(NullPointerException.class, () -> pool.intern(null)); } public void testStrong_builder() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4K bytes - Viewed (0) -
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) } bufPool.Put(b) // Fill the pool beyond the capped pool size. for i := uint64(0); i < size*2; i++ { bufPool.Put(make([]byte, bufPool.w)) } b = bufPool.Get() if len(b) != width { t.Fatalf("bytepool length invalid: got %v want %v", len(b), width) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 19:13:27 GMT 2024 - 2.6K bytes - Viewed (0) -
buildscripts/verify-build.sh
sleep 15 } function start_minio_pool_erasure_sets() { export MINIO_ROOT_USER=$ACCESS_KEY export MINIO_ROOT_PASSWORD=$SECRET_KEY export MINIO_ENDPOINTS="http://127.0.0.1:9000${WORK_DIR}/pool-disk-sets{1...4} http://127.0.0.1:9001${WORK_DIR}/pool-disk-sets{5...8}" "${MINIO[@]}" server --address ":9000" >"$WORK_DIR/pool-minio-9000.log" 2>&1 & "${MINIO[@]}" server --address ":9001" >"$WORK_DIR/pool-minio-9001.log" 2>&1 & sleep 40 }
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 6.5K bytes - Viewed (0)