Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,355 for pool (0.06 sec)

  1. 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() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. buildscripts/verify-build.sh

    	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 &
    
    	"${WORK_DIR}/mc" ready verify
    }
    
    function start_minio_pool_erasure_sets_ipv6() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 19:28:51 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. docs/distributed/DESIGN.md

            // choose when we reach this many
            choose := rand.Uint64() % total
            atTotal := uint64(0)
            for _, pool := range serverPools {
                    atTotal += pool.Available
                    if atTotal > choose && pool.Available > 0 {
                            return pool.Index
                    }
            }
            // Should not happen, but print values just in case.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 8K bytes
    - Viewed (0)
  5. 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()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. internal/handlers/forwarder.go

    	}
    
    	return f
    }
    
    type bufPool struct {
    	sz   int
    	pool sync.Pool
    }
    
    func (b *bufPool) Put(buf []byte) {
    	if cap(buf) < b.sz || cap(buf) > b.sz*2 {
    		// Buffer too small or will likely leak memory after being expanded.
    		// Drop it.
    		return
    	}
    	b.pool.Put(&buf)
    }
    
    func (b *bufPool) Get() []byte {
    	bufp := b.pool.Get().(*[]byte)
    	return (*bufp)[:b.sz]
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  7. docs/contribute/concurrency.md

    ## Connection Pool
    
    A primary responsibility for any HTTP client is to efficiently manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. internal/jwt/parser.go

    	return HashBorrower{pool: &s.HasherPool, borrowed: make([]hash.Hash, 0, 2)}
    }
    
    // HashBorrower keeps track of borrowed hashers and allows to return them all.
    type HashBorrower struct {
    	pool     *sync.Pool
    	borrowed []hash.Hash
    }
    
    // Borrow a single hasher.
    func (h *HashBorrower) Borrow() hash.Hash {
    	hasher := h.pool.Get().(hash.Hash)
    	h.borrowed = append(h.borrowed, hasher)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. 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)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. 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:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:23:12 UTC 2024
    - 13.8K bytes
    - Viewed (0)
Back to top