modified_shards[shard_id].insert(key);
}
-void RGWDataChangesLog::read_clear_modified(map<int, set<string> > *modified)
+void RGWDataChangesLog::read_clear_modified(map<int, set<string> > &modified)
{
RWLock::WLocker wl(modified_lock);
- modified->swap(modified_shards);
+ modified.swap(modified_shards);
modified_shards.clear();
}
list<rgw_data_change_log_entry>& entries, LogMarker& marker, bool *ptruncated);
void mark_modified(int shard_id, rgw_bucket_shard& bs);
- void read_clear_modified(map<int, set<string> > *modified);
+ void read_clear_modified(map<int, set<string> > &modified);
bool going_down();
};
modified_shards.insert(shard_id);
}
-void RGWMetadataLog::read_clear_modified(set<int> *modified)
+void RGWMetadataLog::read_clear_modified(set<int> &modified)
{
RWLock::WLocker wl(lock);
- modified->swap(modified_shards);
+ modified.swap(modified_shards);
modified_shards.clear();
}
int update_shards(list<int>& shards);
- void read_clear_modified(set<int> *modified);
+ void read_clear_modified(set<int> &modified);
};
struct LogStatusDump {
RGWMetadataLog *log = store->meta_mgr->get_log();
- log->read_clear_modified(&shards);
+ log->read_clear_modified(shards);
if (shards.empty()) {
return 0;
map<int, set<string> > shards;
- store->data_log->read_clear_modified(&shards);
+ store->data_log->read_clear_modified(shards);
if (shards.empty()) {
return 0;