From: Soumya Koduri Date: Thu, 8 Jul 2021 10:10:34 +0000 (+0530) Subject: rgw/dbstore: Use dpp for logging X-Git-Tag: v17.1.0~1246^2~2 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=2a3e3be238698b191f0e89ed7c3f527335e88375;p=ceph-ci.git rgw/dbstore: Use dpp for logging Aligning with other Ceph RGW modules, use dpp for logging. A default dpp is defined for DBStore to be used for unit-tests. Signed-off-by: Soumya Koduri --- diff --git a/src/rgw/rgw_sal.cc b/src/rgw/rgw_sal.cc index 5559ae9dc21..bdd2adc3be5 100644 --- a/src/rgw/rgw_sal.cc +++ b/src/rgw/rgw_sal.cc @@ -78,7 +78,7 @@ rgw::sal::Store* StoreManager::init_storage_provider(const DoutPrefixProvider* d if (svc.compare("dbstore") == 0) { #ifdef WITH_RADOSGW_DBSTORE - store = newRGWDBStore(cct); + rgw::sal::Store* store = newRGWDBStore(cct); /* Initialize the dbstore with cct & dpp */ DBStore *db = static_cast(store)->getDBStore(); diff --git a/src/rgw/rgw_sal_dbstore.cc b/src/rgw/rgw_sal_dbstore.cc index 3d5ad098aac..fb2e668c0ab 100644 --- a/src/rgw/rgw_sal_dbstore.cc +++ b/src/rgw/rgw_sal_dbstore.cc @@ -39,7 +39,7 @@ namespace rgw::sal { int ret; buckets.clear(); - ret = store->getDBStore()->list_buckets(info.user_id, marker, end_marker, max, + ret = store->getDBStore()->list_buckets(dpp, info.user_id, marker, end_marker, max, need_stats, &ulist, &is_truncated); if (ret < 0) return ret; @@ -61,7 +61,7 @@ namespace rgw::sal { int DBUser::read_attrs(const DoutPrefixProvider* dpp, optional_yield y) { int ret; - ret = store->getDBStore()->get_user(string("user_id"), "", info, &attrs, + ret = store->getDBStore()->get_user(dpp, string("user_id"), "", info, &attrs, &objv_tracker); return ret; } @@ -101,7 +101,7 @@ namespace rgw::sal { { int ret = 0; - ret = store->getDBStore()->get_user(string("user_id"), "", info, &attrs, + ret = store->getDBStore()->get_user(dpp, string("user_id"), "", info, &attrs, &objv_tracker); return ret; @@ -111,7 +111,7 @@ namespace rgw::sal { { int ret = 0; - ret = store->getDBStore()->store_user(info, exclusive, &attrs, &objv_tracker, old_info); + ret = store->getDBStore()->store_user(dpp, info, exclusive, &attrs, &objv_tracker, old_info); return ret; } @@ -120,7 +120,7 @@ namespace rgw::sal { { int ret = 0; - ret = store->getDBStore()->remove_user(info, &objv_tracker); + ret = store->getDBStore()->remove_user(dpp, info, &objv_tracker); return ret; } @@ -140,7 +140,7 @@ namespace rgw::sal { /* XXX: handle delete_children */ - ret = store->getDBStore()->remove_bucket(info); + ret = store->getDBStore()->remove_bucket(dpp, info); return ret; } @@ -149,7 +149,7 @@ namespace rgw::sal { { int ret = 0; - ret = store->getDBStore()->get_bucket_info(string("name"), "", info, &attrs, + ret = store->getDBStore()->get_bucket_info(dpp, string("name"), "", info, &attrs, &mtime, &bucket_version); return ret; @@ -193,7 +193,7 @@ namespace rgw::sal { { int ret; - ret = store->getDBStore()->update_bucket("owner", info, false, &(new_user->get_id()), nullptr, nullptr, nullptr); + ret = store->getDBStore()->update_bucket(dpp, "owner", info, false, &(new_user->get_id()), nullptr, nullptr, nullptr); /* XXX: Update policies of all the bucket->objects with new user */ return ret; @@ -203,7 +203,7 @@ namespace rgw::sal { { int ret; - ret = store->getDBStore()->update_bucket("info", info, exclusive, nullptr, nullptr, &_mtime, &info.objv_tracker); + ret = store->getDBStore()->update_bucket(dpp, "info", info, exclusive, nullptr, nullptr, &_mtime, &info.objv_tracker); return ret; @@ -214,7 +214,7 @@ namespace rgw::sal { /* XXX: same as DBBUcket::remove_bucket() but should return error if there are objects * in that bucket. */ - int ret = store->getDBStore()->remove_bucket(info); + int ret = store->getDBStore()->remove_bucket(dpp, info); return ret; } @@ -244,7 +244,7 @@ namespace rgw::sal { /* XXX: handle has_instance_obj like in set_bucket_instance_attrs() */ - ret = store->getDBStore()->update_bucket("attrs", info, false, nullptr, &attrs, nullptr, &get_info().objv_tracker); + ret = store->getDBStore()->update_bucket(dpp, "attrs", info, false, nullptr, &attrs, nullptr, &get_info().objv_tracker); return ret; } @@ -253,7 +253,7 @@ namespace rgw::sal { { int ret = 0; - ret = store->getDBStore()->get_bucket_info(string("name"), "", info, &attrs, + ret = store->getDBStore()->get_bucket_info(dpp, string("name"), "", info, &attrs, pmtime, &bucket_version); return ret; @@ -319,7 +319,7 @@ namespace rgw::sal { Attrs attrs = get_attrs(); attrs[RGW_ATTR_ACL] = aclbl; - ret = store->getDBStore()->update_bucket("attrs", info, false, &(acl.get_owner().get_id()), &attrs, nullptr, nullptr); + ret = store->getDBStore()->update_bucket(dpp, "attrs", info, false, &(acl.get_owner().get_id()), &attrs, nullptr, nullptr); return ret; } @@ -449,7 +449,7 @@ namespace rgw::sal { int ret = 0; RGWObjVersionTracker objv_tracker; - ret = getDBStore()->get_user(string("access_key"), key, uinfo, nullptr, + ret = getDBStore()->get_user(dpp, string("access_key"), key, uinfo, nullptr, &objv_tracker); if (ret < 0) @@ -473,7 +473,7 @@ namespace rgw::sal { int ret = 0; RGWObjVersionTracker objv_tracker; - ret = getDBStore()->get_user(string("email"), email, uinfo, nullptr, + ret = getDBStore()->get_user(dpp, string("email"), email, uinfo, nullptr, &objv_tracker); if (ret < 0) @@ -618,11 +618,10 @@ namespace rgw::sal { } else { /* XXX: We may not need to send all these params. Cleanup the unused ones */ - ret = getDBStore()->create_bucket(u->get_info(), bucket->get_key(), + ret = getDBStore()->create_bucket(dpp, u->get_info(), bucket->get_key(), zid, placement_rule, swift_ver_location, pquota_info, attrs, info, pobjv, &ep_objv, creation_time, - pmaster_bucket, pmaster_num_shards, y, dpp, - exclusive); + pmaster_bucket, pmaster_num_shards, y, exclusive); if (ret == -EEXIST) { *existed = true; ret = 0; @@ -684,7 +683,7 @@ namespace rgw::sal { std::unique_ptr RGWDBStore::get_notification(rgw::sal::Object* obj, struct req_state* s, - rgw::notify::EventType event_type) + rgw::notify::EventType event_type, const std::string* object_name) { return 0; } @@ -759,7 +758,7 @@ namespace rgw::sal { RGWBucketInfo info; map attrs; - int r = getDBStore()->get_bucket_info(string("name"), "", info, &attrs, + int r = getDBStore()->get_bucket_info(dpp, string("name"), "", info, &attrs, nullptr, nullptr); if (r < 0) { ldpp_dout(dpp, 0) << "NOTICE: get_bucket_info on bucket=" << bucket.name << " returned err=" << r << ", skipping bucket" << dendl; @@ -772,7 +771,7 @@ namespace rgw::sal { info.flags |= BUCKET_SUSPENDED; } - r = getDBStore()->update_bucket("info", info, false, nullptr, &attrs, nullptr, &info.objv_tracker); + r = getDBStore()->update_bucket(dpp, "info", info, false, nullptr, &attrs, nullptr, &info.objv_tracker); if (r < 0) { ldpp_dout(dpp, 0) << "NOTICE: put_bucket_info on bucket=" << bucket.name << " returned err=" << r << ", skipping bucket" << dendl; ret = r; diff --git a/src/rgw/rgw_sal_dbstore.h b/src/rgw/rgw_sal_dbstore.h index 818752fcca2..8a68a4b26a5 100644 --- a/src/rgw/rgw_sal_dbstore.h +++ b/src/rgw/rgw_sal_dbstore.h @@ -285,7 +285,8 @@ namespace rgw { namespace sal { virtual int cluster_stat(RGWClusterStat& stats) override; virtual std::unique_ptr get_lifecycle(void) override; virtual std::unique_ptr get_completions(void) override; - virtual std::unique_ptr get_notification(rgw::sal::Object* obj, struct req_state* s, rgw::notify::EventType event_type) override; + virtual std::unique_ptr get_notification(rgw::sal::Object* obj, struct req_state* s, + rgw::notify::EventType event_type, const std::string* object_name=nullptr) override; virtual std::unique_ptr get_gc_chain(rgw::sal::Object* obj) override; virtual std::unique_ptr get_writer(Aio *aio, rgw::sal::Bucket* bucket, RGWObjectCtx& obj_ctx, std::unique_ptr _head_obj, diff --git a/src/rgw/store/dbstore/common/dbstore.cc b/src/rgw/store/dbstore/common/dbstore.cc index 0587c6fdbb2..230c9ca75be 100644 --- a/src/rgw/store/dbstore/common/dbstore.cc +++ b/src/rgw/store/dbstore/common/dbstore.cc @@ -14,6 +14,7 @@ map DBStore::getObjectMap() { int DBStore::Initialize(string logfile, int loglevel) { int ret = -1; + const DoutPrefixProvider *dpp = get_def_dpp(); if (!cct) { cout << "Failed to Initialize. No ceph Context \n"; @@ -29,100 +30,100 @@ int DBStore::Initialize(string logfile, int loglevel) } - db = openDB(); + db = openDB(dpp); if (!db) { - dbout(cct, 0) <<"Failed to open database " << dbendl; + ldpp_dout(dpp, 0) <<"Failed to open database " << dendl; return ret; } - ret = LockInit(); + ret = LockInit(dpp); if (ret) { - dbout(cct, 0) <<"Error: mutex is NULL " << dbendl; - closeDB(); + ldpp_dout(dpp, 0) <<"Error: mutex is NULL " << dendl; + closeDB(dpp); db = NULL; return ret; } - ret = InitializeDBOps(); + ret = InitializeDBOps(dpp); if (ret) { - dbout(cct, 0) <<"InitializeDBOps failed " << dbendl; - LockDestroy(); - closeDB(); + ldpp_dout(dpp, 0) <<"InitializeDBOps failed " << dendl; + LockDestroy(dpp); + closeDB(dpp); db = NULL; return ret; } - dbout(cct, 0) << "DBStore successfully initialized - name:" \ - << db_name << "" << dbendl; + ldpp_dout(dpp, 0) << "DBStore successfully initialized - name:" \ + << db_name << "" << dendl; return ret; } -int DBStore::Destroy() +int DBStore::Destroy(const DoutPrefixProvider *dpp) { if (!db) return 0; - closeDB(); + closeDB(dpp); - LockDestroy(); + LockDestroy(dpp); - FreeDBOps(); + FreeDBOps(dpp); - dbout(cct, 20)<<"DBStore successfully destroyed - name:" \ - <op.bucket.info.bucket.name); if (iter == DBStore::objectmap.end()) { - dbout(cct, 30)<<"No objectmap found for bucket: " \ - <op.bucket.info.bucket.name << dbendl; + ldpp_dout(dpp, 30)<<"No objectmap found for bucket: " \ + <op.bucket.info.bucket.name << dendl; /* not found */ return NULL; } @@ -172,7 +173,7 @@ DBOp * DBStore::getDBOp(string Op, struct DBOpParams *params) return NULL; } -int DBStore::objectmapInsert(string bucket, void *ptr) +int DBStore::objectmapInsert(const DoutPrefixProvider *dpp, string bucket, void *ptr) { map::iterator iter; class ObjectOp *Ob; @@ -184,20 +185,20 @@ int DBStore::objectmapInsert(string bucket, void *ptr) // return success or replace it or // return error ? // return success for now - dbout(cct, 20)<<"Objectmap entry already exists for bucket("\ - <InitializeObjectOps(); + Ob->InitializeObjectOps(dpp); DBStore::objectmap.insert(pair(bucket, Ob)); return 0; } -int DBStore::objectmapDelete(string bucket) +int DBStore::objectmapDelete(const DoutPrefixProvider *dpp, string bucket) { map::iterator iter; class ObjectOp *Ob; @@ -208,20 +209,20 @@ int DBStore::objectmapDelete(string bucket) // entry doesn't exist // return success or return error ? // return success for now - dbout(cct, 20)<<"Objectmap entry for bucket("<second); - Ob->FreeObjectOps(); + Ob->FreeObjectOps(dpp); DBStore::objectmap.erase(iter); return 0; } -int DBStore::InitializeParams(string Op, DBOpParams *params) +int DBStore::InitializeParams(const DoutPrefixProvider *dpp, string Op, DBOpParams *params) { int ret = -1; @@ -239,33 +240,34 @@ out: return ret; } -int DBStore::ProcessOp(string Op, struct DBOpParams *params) { +int DBStore::ProcessOp(const DoutPrefixProvider *dpp, string Op, struct DBOpParams *params) { int ret = -1; class DBOp *db_op; - Lock(); - db_op = getDBOp(Op, params); + Lock(dpp); + db_op = getDBOp(dpp, Op, params); if (!db_op) { - dbout(cct, 0)<<"No db_op found for Op("<Execute(params); + ret = db_op->Execute(dpp, params); - Unlock(); + Unlock(dpp); if (ret) { - dbout(cct, 0)<<"In Process op Execute failed for fop(" \ - < *pattrs, RGWObjVersionTracker *pobjv_tracker) { int ret = 0; @@ -277,7 +279,7 @@ int DBStore::get_user(const std::string& query_str, const std::string& query_str } DBOpParams params = {}; - InitializeParams("GetUser", ¶ms); + InitializeParams(dpp, "GetUser", ¶ms); params.op.query_str = query_str; @@ -294,11 +296,11 @@ int DBStore::get_user(const std::string& query_str, const std::string& query_str } else if (query_str == "user_id") { params.op.user.uinfo.user_id = uinfo.user_id; } else { - dbout(cct, 0)<<"In GetUser Invalid query string :" < *pattrs, +int DBStore::store_user(const DoutPrefixProvider *dpp, + RGWUserInfo& uinfo, bool exclusive, map *pattrs, RGWObjVersionTracker *pobjv, RGWUserInfo* pold_info) { DBOpParams params = {}; - InitializeParams("CreateUser", ¶ms); + InitializeParams(dpp, "CreateUser", ¶ms); int ret = 0; /* Check if the user already exists and return the old info, caller will have a use for it */ @@ -330,7 +333,7 @@ int DBStore::store_user(RGWUserInfo& uinfo, bool exclusive, mapread_version.ver != obj_ver.ver)) { /* Object version mismatch.. return ECANCELED */ ret = -ECANCELED; - dbout(cct, 0)<<"User Read version mismatch err:(" <read_version.ver != objv_tracker.read_version.ver)) { /* Object version mismatch.. return ECANCELED */ ret = -ECANCELED; - dbout(cct, 0)<<"User Read version mismatch err:(" <read_version.ver != bucket_version.ver) { - dbout(cct, 0)<<"Read version mismatch err:(" <quota_table.c_str()); - dbout(params->cct, 0) << "Incorrect table type("<cct, 0) << "Incorrect table type("< *pattrs, RGWObjVersionTracker *pobjv_tracker); - int store_user(RGWUserInfo& uinfo, bool exclusive, map *pattrs, + int store_user(const DoutPrefixProvider *dpp, + RGWUserInfo& uinfo, bool exclusive, map *pattrs, RGWObjVersionTracker *pobjv_tracker, RGWUserInfo* pold_info); - int remove_user(RGWUserInfo& uinfo, RGWObjVersionTracker *pobjv_tracker); - int get_bucket_info(const std::string& query_str, + int remove_user(const DoutPrefixProvider *dpp, + RGWUserInfo& uinfo, RGWObjVersionTracker *pobjv_tracker); + int get_bucket_info(const DoutPrefixProvider *dpp, const std::string& query_str, const std::string& query_str_val, RGWBucketInfo& info, rgw::sal::Attrs* pattrs, ceph::real_time* pmtime, obj_version* pbucket_version); - int create_bucket(const RGWUserInfo& owner, rgw_bucket& bucket, + int create_bucket(const DoutPrefixProvider *dpp, + const RGWUserInfo& owner, rgw_bucket& bucket, const string& zonegroup_id, const rgw_placement_rule& placement_rule, const string& swift_ver_location, @@ -844,20 +853,20 @@ class DBStore { rgw_bucket *pmaster_bucket, uint32_t *pmaster_num_shards, optional_yield y, - const DoutPrefixProvider *dpp, bool exclusive); int next_bucket_id() { return ++max_bucket_id; }; - int remove_bucket(const RGWBucketInfo info); - int list_buckets(const rgw_user& user, + int remove_bucket(const DoutPrefixProvider *dpp, const RGWBucketInfo info); + int list_buckets(const DoutPrefixProvider *dpp, const rgw_user& user, const string& marker, const string& end_marker, uint64_t max, bool need_stats, RGWUserBuckets *buckets, bool *is_truncated); - int update_bucket(const std::string& query_str, RGWBucketInfo& info, bool exclusive, + int update_bucket(const DoutPrefixProvider *dpp, const std::string& query_str, + RGWBucketInfo& info, bool exclusive, const rgw_user* powner_id, map* pattrs, ceph::real_time* pmtime, RGWObjVersionTracker* pobjv); }; diff --git a/src/rgw/store/dbstore/common/dbstore_log.h b/src/rgw/store/dbstore/common/dbstore_log.h index fec41f0c02a..9bd4a227480 100644 --- a/src/rgw/store/dbstore/common/dbstore_log.h +++ b/src/rgw/store/dbstore/common/dbstore_log.h @@ -18,10 +18,4 @@ using namespace std; #undef dout_prefix #define dout_prefix *_dout << "rgw dbstore: " -#define dbout_prefix(cct, v) dout_impl(cct, dout_subsys, v) dout_prefix -#define dbendl_impl dendl - -#define dbout(cct, v) dbout_prefix(cct, v) -#define dbendl dbendl_impl - #endif diff --git a/src/rgw/store/dbstore/dbstore_main.cc b/src/rgw/store/dbstore/dbstore_main.cc index c2f09f16dd9..ad6bab7eecd 100644 --- a/src/rgw/store/dbstore/dbstore_main.cc +++ b/src/rgw/store/dbstore/dbstore_main.cc @@ -37,8 +37,9 @@ void* process(void *arg) string objectc2 = "cns"; struct DBOpParams params = {}; + const DoutPrefixProvider *dpp = db->get_def_dpp(); - db->InitializeParams("InsertUser", ¶ms); + db->InitializeParams(dpp, "InsertUser", ¶ms); params.op.user.uinfo.display_name = user1; params.op.user.uinfo.user_id.tenant = "tenant"; @@ -54,15 +55,15 @@ void* process(void *arg) params.op.user.uinfo.access_keys.insert(make_pair("key1", k1)); params.op.user.uinfo.access_keys.insert(make_pair("key2", k2)); - ret = db->ProcessOp("InsertUser", ¶ms); + ret = db->ProcessOp(dpp, "InsertUser", ¶ms); cout << "InsertUser return value: " << ret << "\n"; struct DBOpParams params2 = {}; params.op.user.uinfo.user_id.tenant = "tenant2"; - db->InitializeParams("GetUser", ¶ms2); + db->InitializeParams(dpp, "GetUser", ¶ms2); params2.op.user.uinfo.display_name = user1; - ret = db->ProcessOp("GetUser", ¶ms2); + ret = db->ProcessOp(dpp, "GetUser", ¶ms2); cout << "GetUser return value: " << ret << "\n"; @@ -87,30 +88,30 @@ void* process(void *arg) } params.op.bucket.info.bucket.name = bucketa; - db->ProcessOp("InsertBucket", ¶ms); + db->ProcessOp(dpp, "InsertBucket", ¶ms); params.op.user.uinfo.display_name = user2; params.op.user.uinfo.user_id.id = user2; - db->ProcessOp("InsertUser", ¶ms); + db->ProcessOp(dpp, "InsertUser", ¶ms); params.op.bucket.info.bucket.name = bucketb; - db->ProcessOp("InsertBucket", ¶ms); + db->ProcessOp(dpp, "InsertBucket", ¶ms); - db->ProcessOp("GetUser", ¶ms); - db->ProcessOp("GetBucket", ¶ms); + db->ProcessOp(dpp, "GetUser", ¶ms); + db->ProcessOp(dpp, "GetBucket", ¶ms); - db->ListAllUsers(¶ms); - db->ListAllBuckets(¶ms); + db->ListAllUsers(dpp, ¶ms); + db->ListAllBuckets(dpp, ¶ms); params.op.bucket.info.bucket.name = bucketb; - db->ProcessOp("RemoveBucket", ¶ms); + db->ProcessOp(dpp, "RemoveBucket", ¶ms); params.op.user.uinfo.user_id.id = user2; - db->ProcessOp("RemoveUser", ¶ms); + db->ProcessOp(dpp, "RemoveUser", ¶ms); - db->ListAllUsers(¶ms); - db->ListAllBuckets(¶ms); + db->ListAllUsers(dpp, ¶ms); + db->ListAllBuckets(dpp, ¶ms); cout<<"Exiting thread:"<second; DBStoreHandles.erase(iter); - dbs->Destroy(); + dbs->Destroy(dbs->get_def_dpp()); delete dbs; return; @@ -115,7 +115,7 @@ void DBStoreManager::destroyAllHandles(){ for (iter = DBStoreHandles.begin(); iter != DBStoreHandles.end(); ++iter) { dbs = iter->second; - dbs->Destroy(); + dbs->Destroy(dbs->get_def_dpp()); delete dbs; } diff --git a/src/rgw/store/dbstore/dbstore_mgr.h b/src/rgw/store/dbstore/dbstore_mgr.h index 307efd8ba9e..9744b4f0239 100644 --- a/src/rgw/store/dbstore/dbstore_mgr.h +++ b/src/rgw/store/dbstore/dbstore_mgr.h @@ -33,9 +33,10 @@ public: default_dbstore = createDBStore(default_tenant); }; DBStoreManager(string logfile, int loglevel): DBStoreHandles() { + /* No ceph context. Create one with log args provided */ vector args; cct = global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT, - CODE_ENVIRONMENT_UTILITY, 1)->get(); + CODE_ENVIRONMENT_DAEMON, CINIT_FLAG_NO_MON_CONFIG, 1)->get(); cct->_log->set_log_file(logfile); cct->_log->reopen_log_file(); cct->_conf->subsys.set_log_level(dout_subsys, loglevel); diff --git a/src/rgw/store/dbstore/sqlite/sqliteDB.cc b/src/rgw/store/dbstore/sqlite/sqliteDB.cc index 136aa17f78f..5ed710b1da2 100644 --- a/src/rgw/store/dbstore/sqlite/sqliteDB.cc +++ b/src/rgw/store/dbstore/sqlite/sqliteDB.cc @@ -3,138 +3,138 @@ #include "sqliteDB.h" -#define SQL_PREPARE(cct, params, sdb, stmt, ret, Op) \ +#define SQL_PREPARE(dpp, params, sdb, stmt, ret, Op) \ do { \ string schema; \ schema = Schema(params); \ sqlite3_prepare_v2 (*sdb, schema.c_str(), \ -1, &stmt , NULL); \ if (!stmt) { \ - dbout(cct, 0) <<"failed to prepare statement " \ + ldpp_dout(dpp, 0) <<"failed to prepare statement " \ <<"for Op("<(blob), blob_len); \ \ decode(param, b); \ }while(0); -#define SQL_EXECUTE(params, stmt, cbk, args...) \ +#define SQL_EXECUTE(dpp, params, stmt, cbk, args...) \ do{ \ if (!stmt) { \ - ret = Prepare(params); \ + ret = Prepare(dpp, params); \ } \ \ if (!stmt) { \ - dbout(cct, 0) <<"No prepared statement "<< dbendl; \ + ldpp_dout(dpp, 0) <<"No prepared statement "<< dendl; \ goto out; \ } \ \ - ret = Bind(params); \ + ret = Bind(dpp, params); \ if (ret) { \ - dbout(cct, 0) <<"Bind parameters failed for stmt(" <op, stmt, cbk); \ + ret = Step(dpp, params->op, stmt, cbk); \ \ - Reset(stmt); \ + Reset(dpp, stmt); \ \ if (ret) { \ - dbout(cct, 0) <<"Execution failed for stmt(" <db, cct); dbops.RemoveUser = new SQLRemoveUser(&this->db, cct); dbops.GetUser = new SQLGetUser(&this->db, cct); @@ -394,7 +394,7 @@ int SQLiteDB::InitializeDBOps() return 0; } -int SQLiteDB::FreeDBOps() +int SQLiteDB::FreeDBOps(const DoutPrefixProvider *dpp) { delete dbops.InsertUser; delete dbops.RemoveUser; @@ -408,14 +408,14 @@ int SQLiteDB::FreeDBOps() return 0; } -void *SQLiteDB::openDB() +void *SQLiteDB::openDB(const DoutPrefixProvider *dpp) { string dbname; int rc = 0; dbname = getDBname(); if (dbname.empty()) { - dbout(cct, 0)<<"dbname is NULL" << dbendl; + ldpp_dout(dpp, 0)<<"dbname is NULL" << dendl; goto out; } @@ -426,19 +426,19 @@ void *SQLiteDB::openDB() NULL); if (rc) { - dbout(cct, 0) <<"Cant open "<user_table); - ret = exec(schema.c_str(), NULL); + ret = exec(dpp, schema.c_str(), NULL); if (ret) - dbout(cct, 0)<<"DeleteUserTable failed " << dbendl; + ldpp_dout(dpp, 0)<<"DeleteUserTable failed " << dendl; - dbout(cct, 20)<<"DeleteUserTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"DeleteUserTable suceeded " << dendl; return ret; } -int SQLiteDB::DeleteBucketTable(DBOpParams *params) +int SQLiteDB::DeleteBucketTable(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; schema = DeleteTableSchema(params->bucket_table); - ret = exec(schema.c_str(), NULL); + ret = exec(dpp, schema.c_str(), NULL); if (ret) - dbout(cct, 0)<<"DeletebucketTable failed " << dbendl; + ldpp_dout(dpp, 0)<<"DeletebucketTable failed " << dendl; - dbout(cct, 20)<<"DeletebucketTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"DeletebucketTable suceeded " << dendl; return ret; } -int SQLiteDB::DeleteObjectTable(DBOpParams *params) +int SQLiteDB::DeleteObjectTable(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; schema = DeleteTableSchema(params->object_table); - ret = exec(schema.c_str(), NULL); + ret = exec(dpp, schema.c_str(), NULL); if (ret) - dbout(cct, 0)<<"DeleteObjectTable failed " << dbendl; + ldpp_dout(dpp, 0)<<"DeleteObjectTable failed " << dendl; - dbout(cct, 20)<<"DeleteObjectTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"DeleteObjectTable suceeded " << dendl; return ret; } -int SQLiteDB::DeleteObjectDataTable(DBOpParams *params) +int SQLiteDB::DeleteObjectDataTable(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; schema = DeleteTableSchema(params->objectdata_table); - ret = exec(schema.c_str(), NULL); + ret = exec(dpp, schema.c_str(), NULL); if (ret) - dbout(cct, 0)<<"DeleteObjectDataTable failed " << dbendl; + ldpp_dout(dpp, 0)<<"DeleteObjectDataTable failed " << dendl; - dbout(cct, 20)<<"DeleteObjectDataTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"DeleteObjectDataTable suceeded " << dendl; return ret; } -int SQLiteDB::ListAllUsers(DBOpParams *params) +int SQLiteDB::ListAllUsers(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; schema = ListTableSchema(params->user_table); - // cout<<"########### Listing all Users #############" << dbendl; - ret = exec(schema.c_str(), &list_callback); + // cout<<"########### Listing all Users #############" << dendl; + ret = exec(dpp, schema.c_str(), &list_callback); if (ret) - dbout(cct, 0)<<"GetUsertable failed " << dbendl; + ldpp_dout(dpp, 0)<<"GetUsertable failed " << dendl; - dbout(cct, 20)<<"GetUserTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"GetUserTable suceeded " << dendl; return ret; } -int SQLiteDB::ListAllBuckets(DBOpParams *params) +int SQLiteDB::ListAllBuckets(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; schema = ListTableSchema(params->bucket_table); -// cout<<"########### Listing all Buckets #############" << dbendl; - ret = exec(schema.c_str(), &list_callback); +// cout<<"########### Listing all Buckets #############" << dendl; + ret = exec(dpp, schema.c_str(), &list_callback); if (ret) - dbout(cct, 0)<<"Listbuckettable failed " << dbendl; + ldpp_dout(dpp, 0)<<"Listbuckettable failed " << dendl; - dbout(cct, 20)<<"ListbucketTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"ListbucketTable suceeded " << dendl; return ret; } -int SQLiteDB::ListAllObjects(DBOpParams *params) +int SQLiteDB::ListAllObjects(const DoutPrefixProvider *dpp, DBOpParams *params) { int ret = -1; string schema; @@ -730,12 +730,12 @@ int SQLiteDB::ListAllObjects(DBOpParams *params) map objectmap; string bucket; - //cout<<"########### Listing all Objects #############" << dbendl; + //cout<<"########### Listing all Objects #############" << dendl; objectmap = getObjectMap(); if (objectmap.empty()) - dbout(cct, 20)<<"objectmap empty " << dbendl; + ldpp_dout(dpp, 20)<<"objectmap empty " << dendl; for (iter = objectmap.begin(); iter != objectmap.end(); ++iter) { bucket = iter->first; @@ -743,17 +743,17 @@ int SQLiteDB::ListAllObjects(DBOpParams *params) ".object.table"; schema = ListTableSchema(params->object_table); - ret = exec(schema.c_str(), &list_callback); + ret = exec(dpp, schema.c_str(), &list_callback); if (ret) - dbout(cct, 0)<<"ListObjecttable failed " << dbendl; + ldpp_dout(dpp, 0)<<"ListObjecttable failed " << dendl; - dbout(cct, 20)<<"ListObjectTable suceeded " << dbendl; + ldpp_dout(dpp, 20)<<"ListObjectTable suceeded " << dendl; } return ret; } -int SQLObjectOp::InitializeObjectOps() +int SQLObjectOp::InitializeObjectOps(const DoutPrefixProvider *dpp) { InsertObject = new SQLInsertObject(sdb, cct); RemoveObject = new SQLRemoveObject(sdb, cct); @@ -765,7 +765,7 @@ int SQLObjectOp::InitializeObjectOps() return 0; } -int SQLObjectOp::FreeObjectOps() +int SQLObjectOp::FreeObjectOps(const DoutPrefixProvider *dpp) { delete InsertObject; delete RemoveObject; @@ -777,43 +777,43 @@ int SQLObjectOp::FreeObjectOps() return 0; } -int SQLInsertUser::Prepare(struct DBOpParams *params) +int SQLInsertUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLInsertUser - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLInsertUser - no db" << dendl; goto out; } p_params.user_table = params->user_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertUser"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertUser"); out: return ret; } -int SQLInsertUser::Bind(struct DBOpParams *params) +int SQLInsertUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.tenant.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.tenant.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.ns.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.ns.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.display_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.display_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.display_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.display_name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_email.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_email.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_email.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_email.c_str(), sdb); if (!params->op.user.uinfo.access_keys.empty()) { string access_key; @@ -824,135 +824,135 @@ int SQLInsertUser::Bind(struct DBOpParams *params) access_key = k.id; key = k.key; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, access_key.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, access_key.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys_secret.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, key.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys_secret.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, key.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.access_keys.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.access_keys, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.access_keys.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.access_keys, sdb); } - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.swift_keys.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.swift_keys, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.swift_keys.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.swift_keys, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.subusers.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.subusers, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.subusers.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.subusers, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.suspended.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.suspended, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.suspended.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.suspended, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.max_buckets.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.max_buckets, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.max_buckets.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.max_buckets, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.op_mask.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.op_mask, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.op_mask.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.op_mask, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_caps.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.caps, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_caps.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.caps, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.admin.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.admin, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.admin.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.admin, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.system.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.system, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.system.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.system, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.default_placement.name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.default_placement.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_storage_class.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.default_placement.storage_class.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_storage_class.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.default_placement.storage_class.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.placement_tags.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.placement_tags, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.placement_tags.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.placement_tags, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.bucket_quota.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.bucket_quota, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.bucket_quota.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.bucket_quota, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.temp_url_keys.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.temp_url_keys, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.temp_url_keys.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.temp_url_keys, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_quota.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.user_quota, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_quota.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.user_quota, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.type.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.uinfo.type, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.type.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.uinfo.type, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.mfa_ids.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.uinfo.mfa_ids, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.mfa_ids.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.uinfo.mfa_ids, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.assumed_role_arn.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.assumed_role_arn.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.assumed_role_arn.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.assumed_role_arn.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_attrs.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.user.user_attrs, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_attrs.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.user.user_attrs, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_ver.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.user.user_version.ver, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_ver.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.user.user_version.ver, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_ver_tag.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.user_version.tag.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_ver_tag.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.user_version.tag.c_str(), sdb); out: return rc; } -int SQLInsertUser::Execute(struct DBOpParams *params) +int SQLInsertUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLRemoveUser::Prepare(struct DBOpParams *params) +int SQLRemoveUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLRemoveUser - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLRemoveUser - no db" << dendl; goto out; } p_params.user_table = params->user_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveUser"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveUser"); out: return ret; } -int SQLRemoveUser::Bind(struct DBOpParams *params) +int SQLRemoveUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); out: return rc; } -int SQLRemoveUser::Execute(struct DBOpParams *params) +int SQLRemoveUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLGetUser::Prepare(struct DBOpParams *params) +int SQLGetUser::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLGetUser - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLGetUser - no db" << dendl; goto out; } @@ -960,27 +960,27 @@ int SQLGetUser::Prepare(struct DBOpParams *params) p_params.op.query_str = params->op.query_str; if (params->op.query_str == "email") { - SQL_PREPARE(ctx(), p_params, sdb, email_stmt, ret, "PrepareGetUser"); + SQL_PREPARE(dpp, p_params, sdb, email_stmt, ret, "PrepareGetUser"); } else if (params->op.query_str == "access_key") { - SQL_PREPARE(ctx(), p_params, sdb, ak_stmt, ret, "PrepareGetUser"); + SQL_PREPARE(dpp, p_params, sdb, ak_stmt, ret, "PrepareGetUser"); } else if (params->op.query_str == "user_id") { - SQL_PREPARE(ctx(), p_params, sdb, userid_stmt, ret, "PrepareGetUser"); + SQL_PREPARE(dpp, p_params, sdb, userid_stmt, ret, "PrepareGetUser"); } else { // by default by userid - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetUser"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetUser"); } out: return ret; } -int SQLGetUser::Bind(struct DBOpParams *params) +int SQLGetUser::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; if (params->op.query_str == "email") { - SQL_BIND_INDEX(ctx(), email_stmt, index, p_params.op.user.user_email.c_str(), sdb); - SQL_BIND_TEXT(ctx(), email_stmt, index, params->op.user.uinfo.user_email.c_str(), sdb); + SQL_BIND_INDEX(dpp, email_stmt, index, p_params.op.user.user_email.c_str(), sdb); + SQL_BIND_TEXT(dpp, email_stmt, index, params->op.user.uinfo.user_email.c_str(), sdb); } else if (params->op.query_str == "access_key") { if (!params->op.user.uinfo.access_keys.empty()) { string access_key; @@ -989,158 +989,158 @@ int SQLGetUser::Bind(struct DBOpParams *params) const RGWAccessKey& k = it->second; access_key = k.id; - SQL_BIND_INDEX(ctx(), ak_stmt, index, p_params.op.user.access_keys_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), ak_stmt, index, access_key.c_str(), sdb); + SQL_BIND_INDEX(dpp, ak_stmt, index, p_params.op.user.access_keys_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, ak_stmt, index, access_key.c_str(), sdb); } } else if (params->op.query_str == "user_id") { - SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.tenant.c_str(), sdb); - SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb); + SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.tenant.c_str(), sdb); + SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.tenant.c_str(), sdb); - SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), userid_stmt, index, p_params.op.user.ns.c_str(), sdb); - SQL_BIND_TEXT(ctx(), userid_stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb); + SQL_BIND_INDEX(dpp, userid_stmt, index, p_params.op.user.ns.c_str(), sdb); + SQL_BIND_TEXT(dpp, userid_stmt, index, params->op.user.uinfo.user_id.ns.c_str(), sdb); } else { // by default by userid - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); } out: return rc; } -int SQLGetUser::Execute(struct DBOpParams *params) +int SQLGetUser::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; if (params->op.query_str == "email") { - SQL_EXECUTE(params, email_stmt, list_user); + SQL_EXECUTE(dpp, params, email_stmt, list_user); } else if (params->op.query_str == "access_key") { - SQL_EXECUTE(params, ak_stmt, list_user); + SQL_EXECUTE(dpp, params, ak_stmt, list_user); } else if (params->op.query_str == "user_id") { - SQL_EXECUTE(params, userid_stmt, list_user); + SQL_EXECUTE(dpp, params, userid_stmt, list_user); } else { // by default by userid - SQL_EXECUTE(params, stmt, list_user); + SQL_EXECUTE(dpp, params, stmt, list_user); } out: return ret; } -int SQLInsertBucket::Prepare(struct DBOpParams *params) +int SQLInsertBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLInsertBucket - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLInsertBucket - no db" << dendl; goto out; } p_params.bucket_table = params->bucket_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertBucket"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertBucket"); out: return ret; } -int SQLInsertBucket::Bind(struct DBOpParams *params) +int SQLInsertBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.tenant.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.tenant.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.marker.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.marker.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.size.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.size, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.size.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.size, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.size_rounded.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.size_rounded, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.size_rounded.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.size_rounded, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.creation_time, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.creation_time, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.count.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.ent.count, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.count.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.ent.count, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.placement_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.placement_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.flags.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.flags, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.flags.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.flags, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.has_instance_obj, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.has_instance_obj, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.quota.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.quota, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.quota.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.quota, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.requester_pays, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.requester_pays, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.has_website.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.has_website, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.has_website.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.has_website, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.website_conf.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.website_conf, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.website_conf.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.website_conf, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.info.swift_versioning, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.info.swift_versioning, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.mdsearch_config, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.mdsearch_config, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.obj_lock, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.obj_lock, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.info.sync_policy, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.info.sync_policy, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.bucket_attrs, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.bucket_attrs, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.bucket.bucket_version.ver, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.bucket.bucket_version.ver, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_ver_tag.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.bucket_version.tag.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_ver_tag.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.bucket_version.tag.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.mtime.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), stmt, index, params->op.bucket.mtime, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.mtime.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, stmt, index, params->op.bucket.mtime, sdb); out: return rc; } -int SQLInsertBucket::Execute(struct DBOpParams *params) +int SQLInsertBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; class SQLObjectOp *ObPtr = NULL; @@ -1148,24 +1148,24 @@ int SQLInsertBucket::Execute(struct DBOpParams *params) ObPtr = new SQLObjectOp(sdb, ctx()); - objectmapInsert(bucket_name, ObPtr); + objectmapInsert(dpp, bucket_name, ObPtr); params->object_table = bucket_name + ".object.table"; - (void)createObjectTable(params); + (void)createObjectTable(dpp, params); - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLUpdateBucket::Prepare(struct DBOpParams *params) +int SQLUpdateBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLUpdateBucket - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLUpdateBucket - no db" << dendl; goto out; } @@ -1173,14 +1173,14 @@ int SQLUpdateBucket::Prepare(struct DBOpParams *params) p_params.bucket_table = params->bucket_table; if (params->op.query_str == "attrs") { - SQL_PREPARE(ctx(), p_params, sdb, attrs_stmt, ret, "PrepareUpdateBucket"); + SQL_PREPARE(dpp, p_params, sdb, attrs_stmt, ret, "PrepareUpdateBucket"); } else if (params->op.query_str == "owner") { - SQL_PREPARE(ctx(), p_params, sdb, owner_stmt, ret, "PrepareUpdateBucket"); + SQL_PREPARE(dpp, p_params, sdb, owner_stmt, ret, "PrepareUpdateBucket"); } else if (params->op.query_str == "info") { - SQL_PREPARE(ctx(), p_params, sdb, info_stmt, ret, "PrepareUpdateBucket"); + SQL_PREPARE(dpp, p_params, sdb, info_stmt, ret, "PrepareUpdateBucket"); } else { - dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" << - params->op.query_str << "" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" << + params->op.query_str << "" << dendl; goto out; } @@ -1188,7 +1188,7 @@ out: return ret; } -int SQLUpdateBucket::Bind(struct DBOpParams *params) +int SQLUpdateBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; @@ -1203,96 +1203,96 @@ int SQLUpdateBucket::Bind(struct DBOpParams *params) } else if (params->op.query_str == "info") { stmt = &info_stmt; } else { - dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" << - params->op.query_str << "" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" << + params->op.query_str << "" << dendl; goto out; } if (params->op.query_str == "attrs") { - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.bucket_attrs, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_attrs.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.bucket_attrs, sdb); } else if (params->op.query_str == "owner") { - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.creation_time, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.creation_time, sdb); } else if (params->op.query_str == "info") { - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.tenant.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.tenant.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.tenant.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.marker.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.marker.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.marker.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.bucket_id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.creation_time, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.creation_time.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.creation_time, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.count.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.ent.count, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.count.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.ent.count, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.placement_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.placement_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.placement_rule.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.placement_storage_class.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.placement_rule.storage_class.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.flags.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.flags, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.flags.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.flags, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.zonegroup.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.zonegroup.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.has_instance_obj, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.has_instance_obj.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.has_instance_obj, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.quota.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.quota, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.quota.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.quota, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.requester_pays, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.requester_pays.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.requester_pays, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.has_website.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.has_website, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.has_website.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.has_website, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.website_conf.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.website_conf, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.website_conf.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.website_conf, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.info.swift_versioning, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.swift_versioning.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.info.swift_versioning, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.swift_ver_location.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.swift_ver_location.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.mdsearch_config, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.mdsearch_config.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.mdsearch_config, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.new_bucket_instance_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.new_bucket_instance_id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.obj_lock, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.obj_lock.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.obj_lock, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.info.sync_policy, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.sync_policy_info_groups.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.info.sync_policy, sdb); } - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), *stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_TEXT(dpp, *stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb); - SQL_BIND_INT(ctx(), *stmt, index, params->op.bucket.bucket_version.ver, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.bucket_ver.c_str(), sdb); + SQL_BIND_INT(dpp, *stmt, index, params->op.bucket.bucket_version.ver, sdb); - SQL_BIND_INDEX(ctx(), *stmt, index, p_params.op.bucket.mtime.c_str(), sdb); - SQL_ENCODE_BLOB_PARAM(ctx(), *stmt, index, params->op.bucket.mtime, sdb); + SQL_BIND_INDEX(dpp, *stmt, index, p_params.op.bucket.mtime.c_str(), sdb); + SQL_ENCODE_BLOB_PARAM(dpp, *stmt, index, params->op.bucket.mtime, sdb); out: return rc; } -int SQLUpdateBucket::Execute(struct DBOpParams *params) +int SQLUpdateBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; sqlite3_stmt** stmt = NULL; // Prepared statement @@ -1304,149 +1304,149 @@ int SQLUpdateBucket::Execute(struct DBOpParams *params) } else if (params->op.query_str == "info") { stmt = &info_stmt; } else { - dbout(cct, 0)<<"In SQLUpdateBucket invalid query_str:" << - params->op.query_str << "" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLUpdateBucket invalid query_str:" << + params->op.query_str << "" << dendl; goto out; } - SQL_EXECUTE(params, *stmt, NULL); + SQL_EXECUTE(dpp, params, *stmt, NULL); out: return ret; } -int SQLRemoveBucket::Prepare(struct DBOpParams *params) +int SQLRemoveBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLRemoveBucket - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLRemoveBucket - no db" << dendl; goto out; } p_params.bucket_table = params->bucket_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveBucket"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveBucket"); out: return ret; } -int SQLRemoveBucket::Bind(struct DBOpParams *params) +int SQLRemoveBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLRemoveBucket::Execute(struct DBOpParams *params) +int SQLRemoveBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - objectmapDelete(params->op.bucket.info.bucket.name); + objectmapDelete(dpp, params->op.bucket.info.bucket.name); - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLGetBucket::Prepare(struct DBOpParams *params) +int SQLGetBucket::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLGetBucket - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLGetBucket - no db" << dendl; goto out; } p_params.bucket_table = params->bucket_table; p_params.user_table = params->user_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetBucket"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetBucket"); out: return ret; } -int SQLGetBucket::Bind(struct DBOpParams *params) +int SQLGetBucket::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLGetBucket::Execute(struct DBOpParams *params) +int SQLGetBucket::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; params->op.name = "GetBucket"; - SQL_EXECUTE(params, stmt, list_bucket); + SQL_EXECUTE(dpp, params, stmt, list_bucket); out: return ret; } -int SQLListUserBuckets::Prepare(struct DBOpParams *params) +int SQLListUserBuckets::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; if (!*sdb) { - dbout(cct, 0)<<"In SQLListUserBuckets - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLListUserBuckets - no db" << dendl; goto out; } p_params.bucket_table = params->bucket_table; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareListUserBuckets"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareListUserBuckets"); out: return ret; } -int SQLListUserBuckets::Bind(struct DBOpParams *params) +int SQLListUserBuckets::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.user.user_id.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.user.user_id.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.user.uinfo.user_id.id.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.min_marker.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.min_marker.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.min_marker.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.min_marker.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.list_max_count.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->op.list_max_count, sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.list_max_count.c_str(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->op.list_max_count, sdb); out: return rc; } -int SQLListUserBuckets::Execute(struct DBOpParams *params) +int SQLListUserBuckets::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, list_bucket); + SQL_EXECUTE(dpp, params, stmt, list_bucket); out: return ret; } -int SQLInsertObject::Prepare(struct DBOpParams *params) +int SQLInsertObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1454,47 +1454,47 @@ int SQLInsertObject::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLInsertObject - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLInsertObject - no db" << dendl; goto out; } bucket_name = params->op.bucket.info.bucket.name; p_params.object_table = bucket_name + ".object.table"; - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareInsertObject"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareInsertObject"); out: return ret; } -int SQLInsertObject::Bind(struct DBOpParams *params) +int SQLInsertObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLInsertObject::Execute(struct DBOpParams *params) +int SQLInsertObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLRemoveObject::Prepare(struct DBOpParams *params) +int SQLRemoveObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1502,7 +1502,7 @@ int SQLRemoveObject::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLRemoveObject - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLRemoveObject - no db" << dendl; goto out; } @@ -1510,42 +1510,42 @@ int SQLRemoveObject::Prepare(struct DBOpParams *params) p_params.object_table = bucket_name + ".object.table"; copy.object_table = bucket_name + ".object.table"; - (void)createObjectTable(©); + (void)createObjectTable(dpp, ©); - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareRemoveObject"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareRemoveObject"); out: return ret; } -int SQLRemoveObject::Bind(struct DBOpParams *params) +int SQLRemoveObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLRemoveObject::Execute(struct DBOpParams *params) +int SQLRemoveObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLListObject::Prepare(struct DBOpParams *params) +int SQLListObject::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1553,7 +1553,7 @@ int SQLListObject::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLListObject - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLListObject - no db" << dendl; goto out; } @@ -1561,43 +1561,43 @@ int SQLListObject::Prepare(struct DBOpParams *params) p_params.object_table = bucket_name + ".object.table"; copy.object_table = bucket_name + ".object.table"; - (void)createObjectTable(©); + (void)createObjectTable(dpp, ©); - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareListObject"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareListObject"); out: return ret; } -int SQLListObject::Bind(struct DBOpParams *params) +int SQLListObject::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLListObject::Execute(struct DBOpParams *params) +int SQLListObject::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, list_object); + SQL_EXECUTE(dpp, params, stmt, list_object); out: return ret; } -int SQLPutObjectData::Prepare(struct DBOpParams *params) +int SQLPutObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1605,7 +1605,7 @@ int SQLPutObjectData::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLPutObjectData - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLPutObjectData - no db" << dendl; goto out; } @@ -1615,54 +1615,54 @@ int SQLPutObjectData::Prepare(struct DBOpParams *params) copy.object_table = bucket_name + ".object.table"; copy.objectdata_table = bucket_name + ".objectdata.table"; - (void)createObjectDataTable(©); + (void)createObjectDataTable(dpp, ©); - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PreparePutObjectData"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PreparePutObjectData"); out: return ret; } -int SQLPutObjectData::Bind(struct DBOpParams *params) +int SQLPutObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.offset.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.offset.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, 3, params->offset, sdb); + SQL_BIND_INT(dpp, stmt, 3, params->offset, sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.data.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.data.c_str(), sdb); - SQL_BIND_BLOB(ctx(), stmt, index, params->data.c_str(), params->data.length(), sdb); + SQL_BIND_BLOB(dpp, stmt, index, params->data.c_str(), params->data.length(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.datalen.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.datalen.c_str(), sdb); - SQL_BIND_INT(ctx(), stmt, index, params->data.length(), sdb); + SQL_BIND_INT(dpp, stmt, index, params->data.length(), sdb); out: return rc; } -int SQLPutObjectData::Execute(struct DBOpParams *params) +int SQLPutObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } -int SQLGetObjectData::Prepare(struct DBOpParams *params) +int SQLGetObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1670,7 +1670,7 @@ int SQLGetObjectData::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLGetObjectData - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLGetObjectData - no db" << dendl; goto out; } @@ -1680,41 +1680,41 @@ int SQLGetObjectData::Prepare(struct DBOpParams *params) copy.object_table = bucket_name + ".object.table"; copy.objectdata_table = bucket_name + ".objectdata.table"; - (void)createObjectDataTable(©); + (void)createObjectDataTable(dpp, ©); - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareGetObjectData"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareGetObjectData"); out: return ret; } -int SQLGetObjectData::Bind(struct DBOpParams *params) +int SQLGetObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLGetObjectData::Execute(struct DBOpParams *params) +int SQLGetObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, get_objectdata); + SQL_EXECUTE(dpp, params, stmt, get_objectdata); out: return ret; } -int SQLDeleteObjectData::Prepare(struct DBOpParams *params) +int SQLDeleteObjectData::Prepare(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; struct DBOpPrepareParams p_params = PrepareParams; @@ -1722,7 +1722,7 @@ int SQLDeleteObjectData::Prepare(struct DBOpParams *params) string bucket_name; if (!*sdb) { - dbout(cct, 0)<<"In SQLDeleteObjectData - no db" << dbendl; + ldpp_dout(dpp, 0)<<"In SQLDeleteObjectData - no db" << dendl; goto out; } @@ -1732,36 +1732,36 @@ int SQLDeleteObjectData::Prepare(struct DBOpParams *params) copy.object_table = bucket_name + ".object.table"; copy.objectdata_table = bucket_name + ".objectdata.table"; - (void)createObjectDataTable(©); + (void)createObjectDataTable(dpp, ©); - SQL_PREPARE(ctx(), p_params, sdb, stmt, ret, "PrepareDeleteObjectData"); + SQL_PREPARE(dpp, p_params, sdb, stmt, ret, "PrepareDeleteObjectData"); out: return ret; } -int SQLDeleteObjectData::Bind(struct DBOpParams *params) +int SQLDeleteObjectData::Bind(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int index = -1; int rc = 0; struct DBOpPrepareParams p_params = PrepareParams; - SQL_BIND_INDEX(ctx(), stmt, index, p_params.object.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.object.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->object.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->object.c_str(), sdb); - SQL_BIND_INDEX(ctx(), stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); + SQL_BIND_INDEX(dpp, stmt, index, p_params.op.bucket.bucket_name.c_str(), sdb); - SQL_BIND_TEXT(ctx(), stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); + SQL_BIND_TEXT(dpp, stmt, index, params->op.bucket.info.bucket.name.c_str(), sdb); out: return rc; } -int SQLDeleteObjectData::Execute(struct DBOpParams *params) +int SQLDeleteObjectData::Execute(const DoutPrefixProvider *dpp, struct DBOpParams *params) { int ret = -1; - SQL_EXECUTE(params, stmt, NULL); + SQL_EXECUTE(dpp, params, stmt, NULL); out: return ret; } diff --git a/src/rgw/store/dbstore/sqlite/sqliteDB.h b/src/rgw/store/dbstore/sqlite/sqliteDB.h index 828595ce0b4..27d6523723e 100644 --- a/src/rgw/store/dbstore/sqlite/sqliteDB.h +++ b/src/rgw/store/dbstore/sqlite/sqliteDB.h @@ -23,44 +23,44 @@ class SQLiteDB : public DBStore, public DBOp{ sqlite3_stmt *stmt = NULL; DBOpPrepareParams PrepareParams; - SQLiteDB(string db_name, CephContext *_cct) : DBStore(db_name, _cct) { - cct = _cct; - InitPrepareParams(PrepareParams); + SQLiteDB(string db_name, CephContext *_cct) : DBStore(db_name, _cct), cct(_cct) { + InitPrepareParams(get_def_dpp(), PrepareParams); } - SQLiteDB(sqlite3 *dbi, CephContext *_cct) : DBStore(_cct) { + SQLiteDB(sqlite3 *dbi, CephContext *_cct) : DBStore(_cct), cct(_cct) { db = (void*)dbi; - cct = _cct; - InitPrepareParams(PrepareParams); + InitPrepareParams(get_def_dpp(), PrepareParams); } ~SQLiteDB() {} - int exec(const char *schema, + void *openDB(const DoutPrefixProvider *dpp) override; + int closeDB(const DoutPrefixProvider *dpp) override; + int InitializeDBOps(const DoutPrefixProvider *dpp) override; + int FreeDBOps(const DoutPrefixProvider *dpp) override; + + int InitPrepareParams(const DoutPrefixProvider *dpp, DBOpPrepareParams ¶ms) override { return 0; } + + int exec(const DoutPrefixProvider *dpp, const char *schema, int (*callback)(void*,int,char**,char**)); - void *openDB(); - int closeDB(); - int Step(DBOpInfo &op, sqlite3_stmt *stmt, - int (*cbk)(CephContext *cct, DBOpInfo &op, sqlite3_stmt *stmt)); - int Reset(sqlite3_stmt *stmt); - int InitializeDBOps(); - int FreeDBOps(); + int Step(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt, + int (*cbk)(const DoutPrefixProvider *dpp, DBOpInfo &op, sqlite3_stmt *stmt)); + int Reset(const DoutPrefixProvider *dpp, sqlite3_stmt *stmt); /* default value matches with sqliteDB style */ - int InitPrepareParams(DBOpPrepareParams ¶ms) { return 0; } - - int createTables(); - int createBucketTable(DBOpParams *params); - int createUserTable(DBOpParams *params); - int createObjectTable(DBOpParams *params); - int createObjectDataTable(DBOpParams *params); - int createQuotaTable(DBOpParams *params); - - int DeleteBucketTable(DBOpParams *params); - int DeleteUserTable(DBOpParams *params); - int DeleteObjectTable(DBOpParams *params); - int DeleteObjectDataTable(DBOpParams *params); - - int ListAllBuckets(DBOpParams *params); - int ListAllUsers(DBOpParams *params); - int ListAllObjects(DBOpParams *params); + + int createTables(const DoutPrefixProvider *dpp); + int createBucketTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int createUserTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int createObjectTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int createObjectDataTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int createQuotaTable(const DoutPrefixProvider *dpp, DBOpParams *params); + + int DeleteBucketTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int DeleteUserTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int DeleteObjectTable(const DoutPrefixProvider *dpp, DBOpParams *params); + int DeleteObjectDataTable(const DoutPrefixProvider *dpp, DBOpParams *params); + + int ListAllBuckets(const DoutPrefixProvider *dpp, DBOpParams *params) override; + int ListAllUsers(const DoutPrefixProvider *dpp, DBOpParams *params) override; + int ListAllObjects(const DoutPrefixProvider *dpp, DBOpParams *params) override; }; class SQLObjectOp : public ObjectOp { @@ -72,8 +72,8 @@ class SQLObjectOp : public ObjectOp { SQLObjectOp(sqlite3 **sdbi, CephContext *_cct) : sdb(sdbi), cct(_cct) {}; ~SQLObjectOp() {} - int InitializeObjectOps(); - int FreeObjectOps(); + int InitializeObjectOps(const DoutPrefixProvider *dpp); + int FreeObjectOps(const DoutPrefixProvider *dpp); }; class SQLInsertUser : public SQLiteDB, public InsertUserOp { @@ -87,9 +87,9 @@ class SQLInsertUser : public SQLiteDB, public InsertUserOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLRemoveUser : public SQLiteDB, public RemoveUserOp { @@ -103,9 +103,9 @@ class SQLRemoveUser : public SQLiteDB, public RemoveUserOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLGetUser : public SQLiteDB, public GetUserOp { @@ -128,9 +128,9 @@ class SQLGetUser : public SQLiteDB, public GetUserOp { if (userid_stmt) sqlite3_finalize(userid_stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLInsertBucket : public SQLiteDB, public InsertBucketOp { @@ -144,9 +144,9 @@ class SQLInsertBucket : public SQLiteDB, public InsertBucketOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLUpdateBucket : public SQLiteDB, public UpdateBucketOp { @@ -166,9 +166,9 @@ class SQLUpdateBucket : public SQLiteDB, public UpdateBucketOp { if (owner_stmt) sqlite3_finalize(owner_stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLRemoveBucket : public SQLiteDB, public RemoveBucketOp { @@ -182,9 +182,9 @@ class SQLRemoveBucket : public SQLiteDB, public RemoveBucketOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLGetBucket : public SQLiteDB, public GetBucketOp { @@ -198,9 +198,9 @@ class SQLGetBucket : public SQLiteDB, public GetBucketOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLListUserBuckets : public SQLiteDB, public ListUserBucketsOp { @@ -214,9 +214,9 @@ class SQLListUserBuckets : public SQLiteDB, public ListUserBucketsOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLInsertObject : public SQLiteDB, public InsertObjectOp { @@ -232,9 +232,9 @@ class SQLInsertObject : public SQLiteDB, public InsertObjectOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLRemoveObject : public SQLiteDB, public RemoveObjectOp { @@ -250,9 +250,9 @@ class SQLRemoveObject : public SQLiteDB, public RemoveObjectOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLListObject : public SQLiteDB, public ListObjectOp { @@ -268,9 +268,9 @@ class SQLListObject : public SQLiteDB, public ListObjectOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLPutObjectData : public SQLiteDB, public PutObjectDataOp { @@ -286,9 +286,9 @@ class SQLPutObjectData : public SQLiteDB, public PutObjectDataOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLGetObjectData : public SQLiteDB, public GetObjectDataOp { @@ -304,9 +304,9 @@ class SQLGetObjectData : public SQLiteDB, public GetObjectDataOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; class SQLDeleteObjectData : public SQLiteDB, public DeleteObjectDataOp { @@ -322,8 +322,8 @@ class SQLDeleteObjectData : public SQLiteDB, public DeleteObjectDataOp { if (stmt) sqlite3_finalize(stmt); } - int Prepare(DBOpParams *params); - int Execute(DBOpParams *params); - int Bind(DBOpParams *params); + int Prepare(const DoutPrefixProvider *dpp, DBOpParams *params); + int Execute(const DoutPrefixProvider *dpp, DBOpParams *params); + int Bind(const DoutPrefixProvider *dpp, DBOpParams *params); }; #endif diff --git a/src/rgw/store/dbstore/tests/dbstore_tests.cc b/src/rgw/store/dbstore/tests/dbstore_tests.cc index 187d364fca0..1cb0657d912 100644 --- a/src/rgw/store/dbstore/tests/dbstore_tests.cc +++ b/src/rgw/store/dbstore/tests/dbstore_tests.cc @@ -12,8 +12,6 @@ using namespace std; vector args; -CephContext *cct; - namespace gtest { class Environment* env; @@ -30,7 +28,7 @@ namespace gtest { void SetUp() override { cct = global_init(NULL, args, CEPH_ENTITY_TYPE_CLIENT, - CODE_ENVIRONMENT_UTILITY, 1)->get(); + CODE_ENVIRONMENT_DAEMON, CINIT_FLAG_NO_MON_CONFIG, 1)->get(); if (!db_type.compare("SQLite")) { db = new SQLiteDB(tenant, cct); ASSERT_TRUE(db != nullptr); @@ -42,7 +40,7 @@ namespace gtest { void TearDown() override { if (!db) return; - db->Destroy(); + db->Destroy(db->get_def_dpp()); delete db; } @@ -52,6 +50,7 @@ namespace gtest { int ret; string logfile = "rgw_dbstore_tests.log"; int loglevel = 30; + CephContext *cct; }; } @@ -70,11 +69,14 @@ namespace { string object1 = "object1"; string data = "Hello World"; DBOpParams GlobalParams = {}; + const DoutPrefixProvider *dpp; DBStoreBaseTest() {} void SetUp() { db = gtest::env->db; ASSERT_TRUE(db != nullptr); + dpp = db->get_def_dpp(); + ASSERT_TRUE(dpp != nullptr); GlobalParams.op.user.uinfo.display_name = user1; GlobalParams.op.user.uinfo.user_id.id = user_id1; @@ -88,7 +90,7 @@ namespace { * special based on fop. Hence its okay to do * global initialization once. */ - ret = db->InitializeParams("", &GlobalParams); + ret = db->InitializeParams(dpp, "", &GlobalParams); ASSERT_EQ(ret, 0); } @@ -114,7 +116,7 @@ TEST_F(DBStoreBaseTest, InsertUser) { params.op.user.user_version.ver = 1; params.op.user.user_version.tag = "UserTAG"; - ret = db->ProcessOp("InsertUser", ¶ms); + ret = db->ProcessOp(dpp, "InsertUser", ¶ms); ASSERT_EQ(ret, 0); } @@ -122,7 +124,7 @@ TEST_F(DBStoreBaseTest, GetUser) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("GetUser", ¶ms); + ret = db->ProcessOp(dpp, "GetUser", ¶ms); ASSERT_EQ(ret, 0); ASSERT_EQ(params.op.user.uinfo.user_id.tenant, "tenant"); ASSERT_EQ(params.op.user.uinfo.user_email, "user1@dbstore.com"); @@ -150,7 +152,7 @@ TEST_F(DBStoreBaseTest, GetUserQuery) { params.op.query_str = "email"; params.op.user.uinfo.user_email = "user1@dbstore.com"; - ret = db->ProcessOp("GetUser", ¶ms); + ret = db->ProcessOp(dpp, "GetUser", ¶ms); ASSERT_EQ(ret, 0); ASSERT_EQ(params.op.user.uinfo.user_id.tenant, "tenant"); ASSERT_EQ(params.op.user.uinfo.user_email, "user1@dbstore.com"); @@ -178,7 +180,7 @@ TEST_F(DBStoreBaseTest, GetUserQueryByEmail) { map attrs; RGWObjVersionTracker objv; - ret = db->get_user("email", email, uinfo, &attrs, &objv); + ret = db->get_user(dpp, "email", email, uinfo, &attrs, &objv); ASSERT_EQ(ret, 0); ASSERT_EQ(uinfo.user_id.tenant, "tenant"); ASSERT_EQ(uinfo.user_email, "user1@dbstore.com"); @@ -204,7 +206,7 @@ TEST_F(DBStoreBaseTest, GetUserQueryByAccessKey) { RGWUserInfo uinfo; string key = "id1"; - ret = db->get_user("access_key", key, uinfo, nullptr, nullptr); + ret = db->get_user(dpp, "access_key", key, uinfo, nullptr, nullptr); ASSERT_EQ(ret, 0); ASSERT_EQ(uinfo.user_id.tenant, "tenant"); ASSERT_EQ(uinfo.user_email, "user1@dbstore.com"); @@ -250,7 +252,7 @@ TEST_F(DBStoreBaseTest, StoreUser) { uinfo.access_keys["id2"] = k2; /* non exclusive create..should create new one */ - ret = db->store_user(uinfo, true, &attrs, &objv_tracker, &old_uinfo); + ret = db->store_user(dpp, uinfo, true, &attrs, &objv_tracker, &old_uinfo); ASSERT_EQ(ret, 0); ASSERT_EQ(old_uinfo.user_email, ""); ASSERT_EQ(objv_tracker.read_version.ver, 1); @@ -258,7 +260,7 @@ TEST_F(DBStoreBaseTest, StoreUser) { /* invalid version number */ objv_tracker.read_version.ver = 4; - ret = db->store_user(uinfo, true, &attrs, &objv_tracker, &old_uinfo); + ret = db->store_user(dpp, uinfo, true, &attrs, &objv_tracker, &old_uinfo); ASSERT_EQ(ret, -125); /* returns ECANCELED */ ASSERT_EQ(old_uinfo.user_id.id, uinfo.user_id.id); ASSERT_EQ(old_uinfo.user_email, uinfo.user_email); @@ -266,12 +268,12 @@ TEST_F(DBStoreBaseTest, StoreUser) { /* exclusive create..should not create new one */ uinfo.user_email = "user2_new@dbstore.com"; objv_tracker.read_version.ver = 1; - ret = db->store_user(uinfo, true, &attrs, &objv_tracker, &old_uinfo); + ret = db->store_user(dpp, uinfo, true, &attrs, &objv_tracker, &old_uinfo); ASSERT_EQ(ret, 0); ASSERT_EQ(old_uinfo.user_email, "user2@dbstore.com"); ASSERT_EQ(objv_tracker.read_version.ver, 1); - ret = db->store_user(uinfo, false, &attrs, &objv_tracker, &old_uinfo); + ret = db->store_user(dpp, uinfo, false, &attrs, &objv_tracker, &old_uinfo); ASSERT_EQ(ret, 0); ASSERT_EQ(old_uinfo.user_email, "user2@dbstore.com"); ASSERT_EQ(objv_tracker.read_version.ver, 2); @@ -287,7 +289,7 @@ TEST_F(DBStoreBaseTest, GetUserQueryByUserID) { uinfo.user_id.tenant = "tenant"; uinfo.user_id.id = "user_id2"; - ret = db->get_user("user_id", "", uinfo, &attrs, &objv); + ret = db->get_user(dpp, "user_id", "", uinfo, &attrs, &objv); ASSERT_EQ(ret, 0); ASSERT_EQ(uinfo.user_id.tenant, "tenant"); ASSERT_EQ(uinfo.user_email, "user2_new@dbstore.com"); @@ -324,7 +326,7 @@ TEST_F(DBStoreBaseTest, ListAllUsers) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ListAllUsers(¶ms); + ret = db->ListAllUsers(dpp, ¶ms); ASSERT_EQ(ret, 0); } @@ -344,7 +346,7 @@ TEST_F(DBStoreBaseTest, InsertBucket) { params.op.bucket.mtime = bucket_mtime; - ret = db->ProcessOp("InsertBucket", ¶ms); + ret = db->ProcessOp(dpp, "InsertBucket", ¶ms); ASSERT_EQ(ret, 0); } @@ -364,12 +366,12 @@ TEST_F(DBStoreBaseTest, UpdateBucketAttrs) { /* invalid version number */ objv.read_version.ver = 4; - ret = db->update_bucket("attrs", info, false, nullptr, &attrs, &bucket_mtime, &objv); + ret = db->update_bucket(dpp, "attrs", info, false, nullptr, &attrs, &bucket_mtime, &objv); ASSERT_EQ(ret, -125); /* returns ECANCELED */ /* right version number */ objv.read_version.ver = 1; - ret = db->update_bucket("attrs", info, false, nullptr, &attrs, &bucket_mtime, &objv); + ret = db->update_bucket(dpp, "attrs", info, false, nullptr, &attrs, &bucket_mtime, &objv); ASSERT_EQ(ret, 0); ASSERT_EQ(objv.read_version.ver, 2); } @@ -382,7 +384,7 @@ TEST_F(DBStoreBaseTest, BucketChown) { info.bucket.name = "bucket1"; - ret = db->update_bucket("owner", info, false, &user, nullptr, &bucket_mtime, nullptr); + ret = db->update_bucket(dpp, "owner", info, false, &user, nullptr, &bucket_mtime, nullptr); ASSERT_EQ(ret, 0); ASSERT_EQ(info.objv_tracker.read_version.ver, 3); } @@ -394,13 +396,13 @@ TEST_F(DBStoreBaseTest, UpdateBucketInfo) { params.op.bucket.info.bucket.name = "bucket1"; - ret = db->ProcessOp("GetBucket", ¶ms); + ret = db->ProcessOp(dpp, "GetBucket", ¶ms); ASSERT_EQ(ret, 0); info = params.op.bucket.info; info.bucket.marker = "marker2"; - ret = db->update_bucket("info", info, false, nullptr, nullptr, &bucket_mtime, nullptr); + ret = db->update_bucket(dpp, "info", info, false, nullptr, nullptr, &bucket_mtime, nullptr); ASSERT_EQ(ret, 0); ASSERT_EQ(info.objv_tracker.read_version.ver, 4); } @@ -409,7 +411,7 @@ TEST_F(DBStoreBaseTest, GetBucket) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("GetBucket", ¶ms); + ret = db->ProcessOp(dpp, "GetBucket", ¶ms); ASSERT_EQ(ret, 0); ASSERT_EQ(params.op.bucket.info.bucket.name, "bucket1"); ASSERT_EQ(params.op.bucket.info.bucket.tenant, "tenant"); @@ -440,7 +442,7 @@ TEST_F(DBStoreBaseTest, RemoveBucketAPI) { info.bucket.name = "bucket1"; - ret = db->remove_bucket(info); + ret = db->remove_bucket(dpp, info); ASSERT_EQ(ret, 0); } @@ -454,12 +456,12 @@ TEST_F(DBStoreBaseTest, RemoveUserAPI) { /* invalid version number...should fail */ objv.read_version.ver = 4; - ret = db->remove_user(uinfo, &objv); + ret = db->remove_user(dpp, uinfo, &objv); ASSERT_EQ(ret, -125); /* invalid version number...should fail */ objv.read_version.ver = 2; - ret = db->remove_user(uinfo, &objv); + ret = db->remove_user(dpp, uinfo, &objv); ASSERT_EQ(ret, 0); } @@ -483,29 +485,29 @@ TEST_F(DBStoreBaseTest, CreateBucket) { rule.name = "rule1"; rule.storage_class = "sc1"; - ret = db->create_bucket(owner, bucket, "zid", rule, "swift_ver", NULL, + ret = db->create_bucket(dpp, owner, bucket, "zid", rule, "swift_ver", NULL, attrs, info, &objv, NULL, bucket_mtime, NULL, NULL, - null_yield, NULL, false); + null_yield, false); ASSERT_EQ(ret, 0); bucket.name = "bucket2"; - ret = db->create_bucket(owner, bucket, "zid", rule, "swift_ver", NULL, + ret = db->create_bucket(dpp, owner, bucket, "zid", rule, "swift_ver", NULL, attrs, info, &objv, NULL, bucket_mtime, NULL, NULL, - null_yield, NULL, false); + null_yield, false); ASSERT_EQ(ret, 0); bucket.name = "bucket3"; - ret = db->create_bucket(owner, bucket, "zid", rule, "swift_ver", NULL, + ret = db->create_bucket(dpp, owner, bucket, "zid", rule, "swift_ver", NULL, attrs, info, &objv, NULL, bucket_mtime, NULL, NULL, - null_yield, NULL, false); + null_yield, false); ASSERT_EQ(ret, 0); bucket.name = "bucket4"; - ret = db->create_bucket(owner, bucket, "zid", rule, "swift_ver", NULL, + ret = db->create_bucket(dpp, owner, bucket, "zid", rule, "swift_ver", NULL, attrs, info, &objv, NULL, bucket_mtime, NULL, NULL, - null_yield, NULL, false); + null_yield, false); ASSERT_EQ(ret, 0); bucket.name = "bucket5"; - ret = db->create_bucket(owner, bucket, "zid", rule, "swift_ver", NULL, + ret = db->create_bucket(dpp, owner, bucket, "zid", rule, "swift_ver", NULL, attrs, info, &objv, NULL, bucket_mtime, NULL, NULL, - null_yield, NULL, false); + null_yield, false); ASSERT_EQ(ret, 0); } @@ -517,7 +519,7 @@ TEST_F(DBStoreBaseTest, GetBucketQueryByName) { ceph::real_time mtime; obj_version objv; - ret = db->get_bucket_info("name", "", binfo, &attrs, &mtime, &objv); + ret = db->get_bucket_info(dpp, "name", "", binfo, &attrs, &mtime, &objv); ASSERT_EQ(ret, 0); ASSERT_EQ(binfo.bucket.name, "bucket2"); ASSERT_EQ(binfo.bucket.tenant, "tenant"); @@ -548,7 +550,7 @@ TEST_F(DBStoreBaseTest, ListUserBuckets) { marker1 = ""; do { is_truncated = false; - ret = db->list_buckets(owner, marker1, "", max, need_stats, &ulist, &is_truncated); + ret = db->list_buckets(dpp, owner, marker1, "", max, need_stats, &ulist, &is_truncated); ASSERT_EQ(ret, 0); cout << "marker1 :" << marker1 << "\n"; @@ -574,7 +576,7 @@ TEST_F(DBStoreBaseTest, ListAllBuckets) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ListAllBuckets(¶ms); + ret = db->ListAllBuckets(dpp, ¶ms); ASSERT_EQ(ret, 0); } @@ -582,7 +584,7 @@ TEST_F(DBStoreBaseTest, InsertObject) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("InsertObject", ¶ms); + ret = db->ProcessOp(dpp, "InsertObject", ¶ms); ASSERT_EQ(ret, 0); } @@ -590,7 +592,7 @@ TEST_F(DBStoreBaseTest, ListObject) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("ListObject", ¶ms); + ret = db->ProcessOp(dpp, "ListObject", ¶ms); ASSERT_EQ(ret, 0); } @@ -598,7 +600,7 @@ TEST_F(DBStoreBaseTest, ListAllObjects) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ListAllObjects(¶ms); + ret = db->ListAllObjects(dpp, ¶ms); ASSERT_EQ(ret, 0); } @@ -606,7 +608,7 @@ TEST_F(DBStoreBaseTest, PutObjectData) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("PutObjectData", ¶ms); + ret = db->ProcessOp(dpp, "PutObjectData", ¶ms); ASSERT_EQ(ret, 0); } @@ -614,7 +616,7 @@ TEST_F(DBStoreBaseTest, GetObjectData) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("GetObjectData", ¶ms); + ret = db->ProcessOp(dpp, "GetObjectData", ¶ms); ASSERT_EQ(ret, 0); } @@ -622,7 +624,7 @@ TEST_F(DBStoreBaseTest, DeleteObjectData) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("DeleteObjectData", ¶ms); + ret = db->ProcessOp(dpp, "DeleteObjectData", ¶ms); ASSERT_EQ(ret, 0); } @@ -630,7 +632,7 @@ TEST_F(DBStoreBaseTest, RemoveObject) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("RemoveObject", ¶ms); + ret = db->ProcessOp(dpp, "RemoveObject", ¶ms); ASSERT_EQ(ret, 0); } @@ -638,7 +640,7 @@ TEST_F(DBStoreBaseTest, RemoveBucket) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("RemoveBucket", ¶ms); + ret = db->ProcessOp(dpp, "RemoveBucket", ¶ms); ASSERT_EQ(ret, 0); } @@ -646,7 +648,7 @@ TEST_F(DBStoreBaseTest, RemoveUser) { struct DBOpParams params = GlobalParams; int ret = -1; - ret = db->ProcessOp("RemoveUser", ¶ms); + ret = db->ProcessOp(dpp, "RemoveUser", ¶ms); ASSERT_EQ(ret, 0); } @@ -663,7 +665,7 @@ TEST_F(DBStoreBaseTest, InsertTestIDUser) { params.op.user.user_version.ver = 1; params.op.user.user_version.tag = "UserTAG"; - ret = db->ProcessOp("InsertUser", ¶ms); + ret = db->ProcessOp(dpp, "InsertUser", ¶ms); ASSERT_EQ(ret, 0); }