- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for gr (0.17 sec)
-
cmd/erasure-server-pool-decom.go
!pool.Decommission.Canceled { return true } } return false } func (z *erasureServerPools) decommissionObject(ctx context.Context, bucket string, gr *GetObjectReader) (err error) { objInfo := gr.ObjInfo defer func() { gr.Close() auditLogDecom(ctx, "DecomCopyData", objInfo.Bucket, objInfo.Name, objInfo.VersionID, err) }() actualSize, err := objInfo.GetActualSize() if err != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Mar 20 03:09:59 GMT 2024 - 40.4K bytes - Viewed (1) -
cmd/s3-zip-handlers.go
if _, ok := crypto.IsEncrypted(gr.ObjInfo.UserDefined); ok { objSize, err = gr.ObjInfo.DecryptedSize() if err != nil { return nil, ObjectInfo{}, err } } else { objSize = gr.ObjInfo.Size } files, err := zipindex.ReadDir(b[len(b)-size:], objSize, nil) if err == nil { return files, gr.ObjInfo, nil } var terr zipindex.ErrNeedMoreData
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Oct 12 04:18:17 GMT 2023 - 15.7K bytes - Viewed (0) -
cmd/veeam-sos-api.go
gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts) if gr != nil { gr.Close() return gr.ObjInfo, nil } return ObjectInfo{}, err } func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) { var buf []byte switch object {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
cmd/erasure-object_test.go
}) } } } gr, err := xl.GetObjectNInfo(ctx, bucket, object, nil, nil, opts) if err != nil { if err != toObjectErr(errErasureReadQuorum, bucket, object) { t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err) } } if gr != nil { _, err = io.Copy(io.Discard, gr)
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
if gr.ObjInfo.VersionID != "" && gr.ObjInfo.DeleteMarker { w.Header()[xhttp.AmzVersionID] = []string{gr.ObjInfo.VersionID} w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(gr.ObjInfo.DeleteMarker)} } } writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer gr.Close() srcInfo := gr.ObjInfo actualPartSize, err := srcInfo.GetActualSize()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 12:24:11 GMT 2024 - 38.3K bytes - Viewed (0) -
cmd/object-handlers.go
return } if gr != nil { if !gr.ObjInfo.VersionPurgeStatus.Empty() { // Shows the replication status of a permanent delete of a version w.Header()[xhttp.MinIODeleteReplicationStatus] = []string{string(gr.ObjInfo.VersionPurgeStatus)} } if !gr.ObjInfo.ReplicationStatus.Empty() && gr.ObjInfo.DeleteMarker {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Mar 18 04:19:43 GMT 2024 - 124.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
Object: object, VersionID: versionID, Error: errStr, }) } func (z *erasureServerPools) rebalanceObject(ctx context.Context, bucket string, gr *GetObjectReader) (err error) { 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
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Mar 06 11:43:16 GMT 2024 - 26.5K bytes - Viewed (0) -
cmd/bucket-replication.go
}) logger.LogOnceIf(ctx, fmt.Errorf("unable to read source object %s/%s(%s): %w", bucket, object, objInfo.VersionID, err), object+":"+objInfo.VersionID) } return } defer gr.Close() objInfo := gr.ObjInfo // make sure we have the latest metadata for metrics calculation rinfo.PrevReplicationStatus = objInfo.TargetReplicationStatus(tgt.ARN) size, err := objInfo.GetActualSize()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 01:12:37 GMT 2024 - 111.9K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/net/InternetDomainNameTest.java
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Tue Mar 05 13:16:00 GMT 2024 - 17.3K bytes - Viewed (0) -
cmd/erasure-object.go
if len(oi.Parts) == 1 { var rs *HTTPRangeSpec gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, http.Header{}, oi, opts) if err != nil { return setRestoreHeaderFn(oi, toObjectErr(err, bucket, object)) } defer gr.Close() hashReader, err := hash.NewReader(ctx, gr, gr.ObjInfo.Size, "", "", gr.ObjInfo.Size) if err != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 14 10:38:33 GMT 2024 - 74.4K bytes - Viewed (2)