RGWPutObj_CB cb(this);
int ret = 0;
+ uint64_t obj_size;
int64_t new_ofs, new_end;
new_ofs = fst;
RGWRados::Object op_target(store, copy_source_bucket_info, *static_cast<RGWObjectCtx *>(s->obj_ctx), obj);
RGWRados::Object::Read read_op(&op_target);
-
- ret = read_op.prepare(&new_ofs, &new_end);
+ read_op.params.obj_size = &obj_size;
+ ret = read_op.prepare();
+ if (ret < 0)
+ return ret;
+ ret = read_op.range_to_ofs(obj_size, new_ofs, new_end);
if (ret < 0)
return ret;
off_t fst;
off_t lst;
- uint64_t bucket_size = 0;
- RGWBucketCompressionInfo bucket_size;
int res;
bool compression_enabled;
boost::optional<RGWPutObj_Compress> compressor;
{
return 0;
}
-
+/*
RGWPutObjProcessor *RGWPostObj::select_processor(RGWObjectCtx& obj_ctx)
{
RGWPutObjProcessor *processor;
{
delete processor;
}
-
+*/
void RGWPostObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);