RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-22 10:37:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

rgw: remove RGWPutObj::select_processor

Browse Source 
Signed-off-by: Casey Bodley <cbodley@redhat.com>
This commit is contained in:
Casey Bodley 2018-10-10 15:54:34 -04:00
parent 8e030b35f1
commit cdbc18254d
2 changed files with 0 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/rgw/rgw_op.cc
View File

@ -3388,34 +3388,6 @@ int RGWPutObjProcessor_Multipart::do_complete(size_t accounted_size,
return r;
}
RGWPutObjProcessor *RGWPutObj::select_processor(RGWObjectCtx& obj_ctx, bool *is_multipart)
{
RGWPutObjProcessor *processor;
bool multipart = s->info.args.exists("uploadId");
uint64_t part_size = s->cct->_conf->rgw_obj_stripe_size;
if (!multipart) {
processor = new RGWPutObjProcessor_Atomic(obj_ctx, s->bucket_info, s->bucket, s->object.name, part_size, s->req_id, s->bucket_info.versioning_enabled());
(static_cast<RGWPutObjProcessor_Atomic *>(processor))->set_olh_epoch(olh_epoch);
(static_cast<RGWPutObjProcessor_Atomic *>(processor))->set_version_id(version_id);
} else {
processor = new RGWPutObjProcessor_Multipart(obj_ctx, s->bucket_info, part_size, s);
}
if (is_multipart) {
*is_multipart = multipart;
}
return processor;
}
void RGWPutObj::dispose_processor(RGWPutObjDataProcessor *processor)
{
delete processor;
}
void RGWPutObj::pre_exec()
{
rgw_bucket_object_pre_exec(s);

5
src/rgw/rgw_op.h
View File

@ -995,9 +995,6 @@ struct RGWSLOInfo {
WRITE_CLASS_ENCODER(RGWSLOInfo)
class RGWPutObj : public RGWOp {
friend class RGWPutObjProcessor;
protected:
seed torrent;
off_t ofs;
@ -1061,8 +1058,6 @@ public:
attrs.emplace(std::move(key), std::move(bl)); /* key and bl are r-value refs */
}
virtual RGWPutObjProcessor *select_processor(RGWObjectCtx& obj_ctx, bool *is_multipart);
void dispose_processor(RGWPutObjDataProcessor *processor);
int verify_permission() override;
void pre_exec() override;
void execute() override;