- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 465 for incQ (0.34 sec)
-
cmd/bucket-replication-stats.go
bucketStats := globalNotificationSys.GetClusterBucketStats(GlobalContext, bucket) return r.calculateBucketReplicationStats(bucket, bucketStats) } func (r *ReplicationStats) incQ(bucket string, sz int64, isDeleteRepl bool, opType replication.Type) { r.qCache.Lock() defer r.qCache.Unlock() v, ok := r.qCache.bucketStats[bucket] if !ok { v = newInQueueStats(r.registry, bucket) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
saver := z.serverPools[o.pool].sets[o.set] // Disconnect from call above, but cancel on exit. listCtx, cancel := context.WithCancel(GlobalContext) saveCh := make(chan metaCacheEntry, metacacheBlockSize) inCh := make(chan metaCacheEntry, metacacheBlockSize) outCh := make(chan metaCacheEntry, o.Limit) filteredResults := o.gatherResults(ctx, outCh) mc := o.newMetacache()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
if max < count { max = count dataDir = ddir } } if max >= writeQuorum { return dataDir } return "" } // Returns number of errors that occurred the most (incl. nil) and the // corresponding error value. NB When there is more than one error value that // occurs maximum number of times, the error value returned depends on how
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
// Internal helper methods /** Circularly increment i. */ final int inc(int i) { return (++i == items.length) ? 0 : i; } /** * Inserts element at current put position, advances, and signals. Call only when occupying * monitor. */ private void insert(E x) { items[putIndex] = x; putIndex = inc(putIndex); ++count; } /**
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
// Internal helper methods /** Circularly increment i. */ final int inc(int i) { return (++i == items.length) ? 0 : i; } /** * Inserts element at current put position, advances, and signals. Call only when occupying * monitor. */ private void insert(E x) { items[putIndex] = x; putIndex = inc(putIndex); ++count; } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K bytes - Viewed (0) -
cmd/http-stats.go
hstats.totalS3Canceled.Inc(api) case code >= http.StatusBadRequest: if code >= http.StatusInternalServerError { hstats.totalS35xxErrors.Inc(api) } else { hstats.totalS34xxErrors.Inc(api) } } bh.httpStats[bucket] = hstats } func (bh *bucketHTTPStats) load(bucket string) bucketHTTPAPIStats { if bh == nil { return bucketHTTPAPIStats{ currentS3Requests: &HTTPAPIStats{},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt
/* * Copyright (C) 2020 Square, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 43.9K bytes - Viewed (0) -
cmd/object-api-datatypes.go
{"GREATER_THAN_512_MB", humanize.MiByte * 512, math.MaxInt64}, } // ObjectsHistogramIntervals is the list of all intervals // of object sizes to be included in objects histogram. // Note: this histogram expands 1024B-1MB to incl. 1024B-64KB, 64KB-256KB, 256KB-512KB and 512KB-1MiB var ObjectsHistogramIntervals = [dataUsageBucketLen]objectHistogramInterval{ {"LESS_THAN_1024_B", 0, humanize.KiByte - 1},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0) -
LICENSE
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. org.bouncycastle:bcpg-jdk15on org.bouncycastle:bcprov-jdk15on Copyright (c) 2000 - 2019 The Legion of the Bouncy Castle Inc. (https://www.bouncycastle.org)
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Tue Jan 23 11:07:23 GMT 2024 - 23.1K bytes - Viewed (0)