ObjectStore *store, SnapMapper *mapper,
OSDriver *osdriver,
ObjectStore::Sequencer *osr,
- coll_t coll, DeletingStateRef dstate) {
+ coll_t coll, DeletingStateRef dstate)
+{
vector<hobject_t> olist;
int64_t num = 0;
ObjectStore::Transaction *t = new ObjectStore::Transaction;
return *_dout << pg->gen_prefix();
}
-void PG::get(const string &tag) {
+void PG::get(const string &tag)
+{
ref.inc();
#ifdef PG_DEBUG_REFS
Mutex::Locker l(_ref_id_lock);
_tag_counts[tag]++;
#endif
}
-void PG::put(const string &tag) {
+
+void PG::put(const string &tag)
+{
#ifdef PG_DEBUG_REFS
{
Mutex::Locker l(_ref_id_lock);
}
#ifdef PG_DEBUG_REFS
-uint64_t PG::get_with_id() {
+uint64_t PG::get_with_id()
+{
ref.inc();
Mutex::Locker l(_ref_id_lock);
uint64_t id = ++_ref_id;
return id;
}
-void PG::put_with_id(uint64_t id) {
+void PG::put_with_id(uint64_t id)
+{
dout(20) << __func__ << ": " << info.pgid << " put id " << id << dendl;
{
Mutex::Locker l(_ref_id_lock);
delete this;
}
-void PG::dump_live_ids() {
+void PG::dump_live_ids()
+{
Mutex::Locker l(_ref_id_lock);
dout(0) << "\t" << __func__ << ": " << info.pgid << " live ids:" << dendl;
for (map<uint64_t, string>::iterator i = _live_ids.begin();
}
}
-void PG::scrub_compare_maps() {
+void PG::scrub_compare_maps()
+{
dout(10) << "scrub_compare_maps has maps, analyzing" << dendl;
// construct authoritative scrub map for type specific scrubbing
_scrub(authmap);
}
-void PG::scrub_process_inconsistent() {
+void PG::scrub_process_inconsistent()
+{
dout(10) << "process_inconsistent() checking authoritative" << dendl;
bool repair = state_test(PG_STATE_REPAIR);
bool deep_scrub = state_test(PG_STATE_DEEP_SCRUB);
}
}
-void PG::scrub_finalize() {
+void PG::scrub_finalize()
+{
lock();
if (deleting) {
unlock();
}
// the part that actually finalizes a scrub
-void PG::scrub_finish() {
+void PG::scrub_finish()
+{
bool repair = state_test(PG_STATE_REPAIR);
bool deep_scrub = state_test(PG_STATE_DEEP_SCRUB);
const char *mode = (repair ? "repair": (deep_scrub ? "deep-scrub" : "scrub"));