- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for decQ (0.07 sec)
-
cmd/bucket-replication.go
p.stats.decQ(v.Bucket, v.Size, v.DeleteMarker, v.OpType) if opTracker != nil { atomic.AddInt32(opTracker, -1) } case DeletedObjectReplicationInfo: if opTracker != nil { atomic.AddInt32(opTracker, 1) } p.stats.incQ(v.Bucket, 0, true, v.OpType) replicateDelete(p.ctx, v, p.objLayer) p.stats.decQ(v.Bucket, 0, true, v.OpType)Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
docs/debugging/healing-bin/main.go
} buf := bytes.NewBuffer(nil) if _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)); err != nil { return err } dec := json.NewDecoder(buf) // Use number to preserve integers. dec.UseNumber() var htr map[string]any if err = dec.Decode(&htr); err != nil { return err } ht[file.Name] = htr } } b, err := json.MarshalIndent(ht, "", " ")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.1K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
} var buf bytes.Buffer gob.NewEncoder(&buf).Encode(v) encoded := buf.Bytes() b.Log("Size:", buf.Len(), "bytes") b.SetBytes(1) b.ReportAllocs() for b.Loop() { dec := gob.NewDecoder(bytes.NewBuffer(encoded)) err := dec.Decode(&v) if err != nil { b.Fatal(err) } } } func BenchmarkEncodeDiskInfoMsgp(b *testing.B) { v := DiskInfo{ Total: 1000, Free: 1000,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.1K bytes - Viewed (0) -
cmd/data-usage-cache.go
case dataUsageCacheVerV2: // Zstd compressed. dec, err := zstd.NewReader(r, zstd.WithDecoderConcurrency(2)) if err != nil { return err } defer dec.Close() dold := &dataUsageCacheV2{} if err = dold.DecodeMsg(msgp.NewReader(dec)); err != nil { return err } d.Info = dold.Info
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/Smb2EncryptionContext.java
if (keyManager != null) { // Store keys securely String encKeyId = sessionId + "-enc"; String decKeyId = sessionId + "-dec"; keyManager.storeSessionKey(encKeyId, encryptionKey, "AES"); keyManager.storeSessionKey(decKeyId, decryptionKey, "AES"); // Clear local key copies for securityRegistered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 35.5K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
} count++ } } func Benchmark_mergeXLV2Versions(b *testing.B) { data, err := os.ReadFile("testdata/xl.meta-v1.2.zst") if err != nil { b.Fatal(err) } dec, _ := zstd.NewReader(nil) data, err = dec.DecodeAll(data, nil) if err != nil { b.Fatal(err) } var xl xlMetaV2 if err = xl.LoadOrConvert(data); err != nil { b.Fatal(err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37.8K bytes - Viewed (0) -
gradle/libs.versions.toml
bouncycastle-bcprov = { module = "org.bouncycastle:bcprov-jdk15to18", version.ref = "org-bouncycastle" } bouncycastle-bctls = { module = "org.bouncycastle:bctls-jdk15to18", version.ref = "org-bouncycastle" } brotli-dec = "org.brotli:dec:0.1.2" #noinspection UnusedVersionCatalogEntry checkStyle = { module = "com.puppycrawl.tools:checkstyle", version.ref = "checkStyle" } clikt = "com.github.ajalt.clikt:clikt:5.0.3"Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Aug 31 17:41:20 UTC 2025 - 8.3K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} }) if err != nil { return nil, err } } if ndjson { return buf.Bytes(), nil } var msi map[string]any dec := json.NewDecoder(buf) // Use number to preserve integers. dec.UseNumber() err = dec.Decode(&msi) if err != nil { return nil, err } b, err = json.MarshalIndent(msi, "", " ") if err != nil { return nil, err }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 40.3K bytes - Viewed (0) -
cmd/bucket-handlers.go
if name != "file" { if http.CanonicalHeaderKey(name) == http.CanonicalHeaderKey("x-minio-fanout-list") { dec := json.NewDecoder(part) // while the array contains values for dec.More() { var m minio.PutObjectFanOutEntry if err := dec.Decode(&m); err != nil { part.Close() apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
cmd/handler-utils.go
if countBktStat { globalBucketHTTPStats.updateHTTPStats(bucket, api, nil) } globalHTTPStats.currentS3Requests.Inc(api) f.ServeHTTP(w, r) globalHTTPStats.currentS3Requests.Dec(api) tc, _ := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if tc != nil { globalHTTPStats.updateStats(api, tc.ResponseRecorder)Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.3K bytes - Viewed (1)