From 7e3493f8726cd3a0b4e4db3ebe0756922575a514 Mon Sep 17 00:00:00 2001 From: Yehuda Sadeh Date: Sun, 23 Jun 2013 01:04:24 -0700 Subject: [PATCH] rgw: various object put processor fixes Signed-off-by: Yehuda Sadeh --- src/rgw/rgw_op.cc | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/rgw/rgw_op.cc b/src/rgw/rgw_op.cc index de45845f3630..0ded08a94f40 100644 --- a/src/rgw/rgw_op.cc +++ b/src/rgw/rgw_op.cc @@ -1034,7 +1034,7 @@ protected: int do_complete(string& etag, time_t *mtime, time_t set_mtime, map& attrs); public: - RGWPutObjProcessor_Multipart(uint64_t _p, req_state *_s) : RGWPutObjProcessor_Atomic(s->bucket, s->object_str, _p, s->req_id), s(_s) {} + RGWPutObjProcessor_Multipart(uint64_t _p, req_state *_s) : RGWPutObjProcessor_Atomic(_s->bucket, _s->object_str, _p, _s->req_id), s(_s) {} }; int RGWPutObjProcessor_Multipart::prepare(RGWRados *store, void *obj_ctx) @@ -1250,10 +1250,7 @@ RGWPutObjProcessor *RGWPostObj::select_processor() uint64_t part_size = s->cct->_conf->rgw_obj_stripe_size; - if (s->content_length <= RGW_MAX_CHUNK_SIZE) - processor = new RGWPutObjProcessor_Plain(s->bucket, s->object_str); - else - processor = new RGWPutObjProcessor_Atomic(s->bucket, s->object_str, part_size, s->req_id); + processor = new RGWPutObjProcessor_Atomic(s->bucket, s->object_str, part_size, s->req_id); return processor; } @@ -1288,7 +1285,7 @@ void RGWPostObj::execute() processor = select_processor(); - ret = processor->prepare(store, s); + ret = processor->prepare(store, s->obj_ctx); if (ret < 0) goto done; -- 2.47.3