Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for GetActualSize (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top