- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for allocate (0.19 sec)
-
cmd/erasure-multipart.go
if err != nil { return pi, toObjectErr(err, bucket, object) } // Fetch buffer for I/O, returns from the pool if not allocates a new one and returns. var buffer []byte switch size := data.Size(); { case size == 0: buffer = make([]byte, 1) // Allocate at least a byte to reach EOF case size == -1: if size := data.ActualSize(); size > 0 && size < fi.Erasure.BlockSize {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMultiset.java
Builder(int estimatedDistinct) { this.contents = ObjectCountHashMap.createWithExpectedSize(estimatedDistinct); } Builder(boolean forSubtype) { // for ImmutableSortedMultiset not to allocate data structures not used there this.contents = null; } /** * Adds {@code element} to the {@code ImmutableMultiset}. * * @param element the element to add
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
allocateAndLeakAllocation(poolApi, c1) awaitGarbageCollection() assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(c1.calls).isEmpty() // Can't allocate once a leak has been detected. assertThat(c1.noNewExchanges).isTrue() } @Test fun interruptStopsThread() { val realTaskRunner = TaskRunner.INSTANCE val pool = factory.newConnectionPool(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { return ObjectInfo{}, toObjectErr(err, minioMetaBucket, key) } // Fetch buffer for I/O, returns from the pool if not allocates a new one and returns. var buffer []byte switch size := data.Size(); { case size == 0: buffer = make([]byte, 1) // Allocate at least a byte to reach EOF case size >= fi.Erasure.BlockSize: buffer = globalBytePoolCap.Load().Get()
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) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* ImmutableSortedMultiset#orderedBy(Comparator)}. */ @SuppressWarnings("unchecked") public Builder(Comparator<? super E> comparator) { super(true); // doesn't allocate hash table in supertype this.comparator = checkNotNull(comparator); this.elements = (E[]) new Object[ImmutableCollection.Builder.DEFAULT_INITIAL_CAPACITY];
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 35.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMap.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 53.2K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
fi.Parts[i].Index = j.PartIndices[i] } } } // fi.Erasure.Checksums - is left empty since we do not have any // whole checksums for many years now, no need to allocate. fi.Metadata = make(map[string]string, len(j.MetaUser)+len(j.MetaSys)) for k, v := range j.MetaUser { // https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1) -
cmd/bucket-replication.go
} resyncStatus := ResyncFailed defer func() { s.markStatus(resyncStatus, opts, objectAPI) globalSiteResyncMetrics.incBucket(opts, resyncStatus) s.workerCh <- struct{}{} }() // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan ObjectInfo) cfg, err := getReplicationConfig(ctx, opts.bucket) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/storage-datatypes.go
} // VersionPurgeStatusKey denotes purge status in metadata const ( VersionPurgeStatusKey = ReservedMetadataPrefixLower + "purgestatus" ) // newFileInfo - initializes new FileInfo, allocates a fresh erasure info. func newFileInfo(object string, dataBlocks, parityBlocks int) (fi FileInfo) { fi.Erasure = ErasureInfo{ Algorithm: erasureAlgorithm, DataBlocks: dataBlocks, ParityBlocks: parityBlocks,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
manifests/charts/istio-cni/values.yaml
# Must be set for any cluster configured with private docker registry. imagePullSecrets: [] # - private-registry-key # Default resources allocated defaultResources: requests: cpu: 100m
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.2K bytes - Viewed (1)