- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,392 for pool (0.26 sec)
-
cmd/erasure-multipart.go
toEncode := io.Reader(data) if data.Size() > bigFileThreshold { // Add input readahead. // 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 Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-component-api/1.0-alpha-32/plexus-component-api-1.0-alpha-32.pom
<link>http://jakarta.apache.org/commons/httpclient/apidocs/</link> <link>http://jakarta.apache.org/commons/logging/apidocs/</link> <link>http://jakarta.apache.org/commons/pool/apidocs/</link> <link>http://www.junit.org/junit/javadoc/</link> <link>http://logging.apache.org/log4j/docs/api/</link> <link>http://jakarta.apache.org/regexp/apidocs/</link>
Plain Text - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* the interrupting thread doesn't interrupt the _next_ thing to run on this thread. * * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread * pool thread, the thread pool will reset it for us. Otherwise, the interrupted bit may have * been intended for something else, so don't clear it. */ boolean restoreInterruptedBit = false; int spinCount = 0;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
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) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/codehaus/plexus/plexus-component-api/1.0-alpha-32/plexus-component-api-1.0-alpha-32.pom
<link>http://jakarta.apache.org/commons/httpclient/apidocs/</link> <link>http://jakarta.apache.org/commons/logging/apidocs/</link> <link>http://jakarta.apache.org/commons/pool/apidocs/</link> <link>http://www.junit.org/junit/javadoc/</link> <link>http://logging.apache.org/log4j/docs/api/</link> <link>http://jakarta.apache.org/regexp/apidocs/</link>
Plain Text - Registered: Sun Mar 31 03:35:09 GMT 2024 - Last Modified: Sat Nov 09 12:45:14 GMT 2019 - 2.3K bytes - Viewed (0) -
.github/workflows/run-mint.sh
docker volume prune -f || true docker volume rm $(docker volume ls -q -f dangling=true) || true # Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2 [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6 docker run --rm --net=mint_default \ --name="mint-${MODE}-${JOB_NAME}" \
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Oct 01 03:29:45 GMT 2023 - 1.2K 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) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
) taskFaker.assertNoMoreTasks() } /** * This test causes two connections to become available simultaneously, one from a TCP connect and * one from the pool. We must take the pooled connection because by taking it from the pool, we've * fully acquired it. * * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In * particular, we set up this sequence of events:
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
src/main/java/jcifs/CIFSContext.java
*/ NameServiceClient getNameServiceClient (); /** * @return the buffer cache */ BufferCache getBufferCache (); /** * @return the transport pool */ SmbTransportPool getTransportPool (); /** * @return the DFS instance for this context */ DfsResolver getDfs (); /**
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 3.7K bytes - Viewed (0) -
internal/grid/grid.go
// Used if no deadline is provided on context. defaultSingleRequestTimeout = time.Minute ) var internalByteBuffer = sync.Pool{ New: func() any { m := make([]byte, 0, defaultBufferSize) return &m }, } var internal32KByteBuffer = sync.Pool{ New: func() any { m := make([]byte, 0, biggerBufMin) return &m }, } // GetByteBuffer can be replaced with a function that returns a small
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0)