From: Orit Wasserman Date: Fri, 8 Jan 2016 12:51:50 +0000 (+0100) Subject: rgw: use refrence in read_clear_modified X-Git-Tag: v10.1.0~354^2~85 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=e911e14cab478637042d223f0a5772a8c839e86f;p=ceph.git rgw: use refrence in read_clear_modified Signed-off-by: Orit Wasserman --- diff --git a/src/rgw/rgw_bucket.cc b/src/rgw/rgw_bucket.cc index cb8e90b990a..b1df3f7d9ca 100644 --- a/src/rgw/rgw_bucket.cc +++ b/src/rgw/rgw_bucket.cc @@ -1608,10 +1608,10 @@ void RGWDataChangesLog::mark_modified(int shard_id, rgw_bucket_shard& bs) modified_shards[shard_id].insert(key); } -void RGWDataChangesLog::read_clear_modified(map > *modified) +void RGWDataChangesLog::read_clear_modified(map > &modified) { RWLock::WLocker wl(modified_lock); - modified->swap(modified_shards); + modified.swap(modified_shards); modified_shards.clear(); } diff --git a/src/rgw/rgw_bucket.h b/src/rgw/rgw_bucket.h index a5a6763051a..3ac03e51141 100644 --- a/src/rgw/rgw_bucket.h +++ b/src/rgw/rgw_bucket.h @@ -483,7 +483,7 @@ public: list& entries, LogMarker& marker, bool *ptruncated); void mark_modified(int shard_id, rgw_bucket_shard& bs); - void read_clear_modified(map > *modified); + void read_clear_modified(map > &modified); bool going_down(); }; diff --git a/src/rgw/rgw_metadata.cc b/src/rgw/rgw_metadata.cc index b961aa761b4..9e263e4dbc0 100644 --- a/src/rgw/rgw_metadata.cc +++ b/src/rgw/rgw_metadata.cc @@ -291,10 +291,10 @@ void RGWMetadataLog::mark_modified(int shard_id) modified_shards.insert(shard_id); } -void RGWMetadataLog::read_clear_modified(set *modified) +void RGWMetadataLog::read_clear_modified(set &modified) { RWLock::WLocker wl(lock); - modified->swap(modified_shards); + modified.swap(modified_shards); modified_shards.clear(); } diff --git a/src/rgw/rgw_metadata.h b/src/rgw/rgw_metadata.h index a0bcf463d94..58b1f3922cc 100644 --- a/src/rgw/rgw_metadata.h +++ b/src/rgw/rgw_metadata.h @@ -189,7 +189,7 @@ public: int update_shards(list& shards); - void read_clear_modified(set *modified); + void read_clear_modified(set &modified); }; struct LogStatusDump { diff --git a/src/rgw/rgw_rados.cc b/src/rgw/rgw_rados.cc index 72abdd937be..7f102bbf5d5 100644 --- a/src/rgw/rgw_rados.cc +++ b/src/rgw/rgw_rados.cc @@ -2815,7 +2815,7 @@ int RGWMetaNotifier::process() RGWMetadataLog *log = store->meta_mgr->get_log(); - log->read_clear_modified(&shards); + log->read_clear_modified(shards); if (shards.empty()) { return 0; @@ -2850,7 +2850,7 @@ int RGWDataNotifier::process() map > shards; - store->data_log->read_clear_modified(&shards); + store->data_log->read_clear_modified(shards); if (shards.empty()) { return 0;