- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for GetActualSize (0.16 sec)
-
cmd/object-api-utils.go
case compressionAlgorithmV1, compressionAlgorithmV2: return true, nil } return true, fmt.Errorf("unknown compression scheme: %s", scheme) } // GetActualSize - returns the actual size of the stored object func (o ObjectInfo) GetActualSize() (int64, error) { if o.ActualSize != nil { return *o.ActualSize, nil } if o.IsCompressed() { sizeStr := o.UserDefined[ReservedMetadataPrefix+"actual-size"]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 37.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMultipartRequestHandler.java
protected void handleSizeLimitExceededException(final HttpServletRequest request, final FileUploadByteCountLimitException e) { final long actual = e.getActualSize(); final long permitted = e.getPermitted(); final String msg = "Exceeded size of the multipart request: actual=" + actual + " permitted=" + permitted;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Oct 23 13:27:21 UTC 2024 - 18.6K bytes - Viewed (0) -
cmd/encryption-v1.go
// we still have to adjust the size and ETag // of SSE-C and SSE-KMS objects. if len(SSES3SinglePartObjects) == 0 { for i := range batch { size, err := batch[i].GetActualSize() if err != nil { return err } batch[i].Size = size if _, ok := crypto.IsEncrypted(batch[i].UserDefined); ok { ETag, err := etag.Parse(batch[i].ETag) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:06:08 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} } writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer gr.Close() srcInfo := gr.ObjInfo actualPartSize, err := srcInfo.GetActualSize() if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if err := enforceBucketQuotaHard(ctx, dstBucket, actualPartSize); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
cmd/object-api-utils_test.go
}, Parts: []ObjectPartInfo{}, Size: 100, }, result: -1, }, } for i, test := range testCases { got, _ := test.objInfo.GetActualSize() if got != test.result { t.Errorf("Test %d - expected %d but received %d", i+1, test.result, got) } } } func TestGetCompressedOffsets(t *testing.T) { testCases := []struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
tm, _ := time.Parse(time.RFC3339Nano, userDefined[ReservedMetadataPrefixLower+ReplicationTimestamp]) rstate := oi.ReplicationState() rstate.ReplicateDecisionStr = dsc.String() asz, _ := oi.GetActualSize() r := ReplicateObjectInfo{ Name: oi.Name, Size: oi.Size, ActualSize: asz, Bucket: oi.Bucket,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
oi := gr.ObjInfo defer func() { gr.Close() auditLogRebalance(ctx, "RebalanceCopyData", oi.Bucket, oi.Name, oi.VersionID, err) }() actualSize, err := oi.GetActualSize() if err != nil { return err } if oi.isMultipart() { res, err := z.NewMultipartUpload(ctx, bucket, oi.Name, ObjectOptions{ VersionID: oi.VersionID, UserDefined: oi.UserDefined,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0) -
cmd/erasure-healing.go
latestMeta.Erasure.ParityBlocks, latestMeta.Erasure.BlockSize) if err != nil { return result, err } } result.ObjectSize, err = latestMeta.ToObjectInfo(bucket, object, true).GetActualSize() if err != nil { return result, err } // Loop to find number of disks with valid data, per-drive // data state and a list of outdated disks on which data needs // to be healed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func NewLifecycleSys() *LifecycleSys { return &LifecycleSys{} } func ilmTrace(startTime time.Time, duration time.Duration, oi ObjectInfo, event string, metadata map[string]string, err string) madmin.TraceInfo { sz, _ := oi.GetActualSize() return madmin.TraceInfo{ TraceType: madmin.TraceILM, Time: startTime, NodeName: globalLocalNodeName, FuncName: event, Duration: duration, Path: pathJoin(oi.Bucket, oi.Name),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
objInfo := gr.ObjInfo defer func() { gr.Close() auditLogDecom(ctx, "DecomCopyData", objInfo.Bucket, objInfo.Name, objInfo.VersionID, err) }() actualSize, err := objInfo.GetActualSize() if err != nil { return err } if objInfo.isMultipart() { res, err := z.NewMultipartUpload(ctx, bucket, objInfo.Name, ObjectOptions{ VersionID: objInfo.VersionID,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (0)