diff options
author | Loic Dachary <loic@dachary.org> | 2013-08-12 17:45:44 +0200 |
---|---|---|
committer | Loic Dachary <loic@dachary.org> | 2013-08-22 02:10:58 +0200 |
commit | ff70e764dc5da8dfc13ab541f20b057ff7db6d0d (patch) | |
tree | e31efee1f9a861d04c0bcd44874b8e7e9f55bb5e | |
parent | 7e85c6320c212c383ed000639f2133423cd3d40f (diff) | |
download | ceph-ff70e764dc5da8dfc13ab541f20b057ff7db6d0d.tar.gz |
ReplicatedPG: ObjectContext * becomes ObjectContextRef
The map of hobject_t to ObjectContext is made a
SharedPtrRegistry owned by ReplicatedPG
- map<hobject_t, ObjectContext*> object_contexts;
+ SharedPtrRegistry<hobject_t, ObjectContext> object_contexts;
All ObjectContext pointers are changed into ObjectContextRef, i.e.
shared_ptr.
In Watch.h std::tr1::shared_ptr<ObjectContext> is used instead
of ObjectContextRef because Watch.h is included before it is
defined.
http://tracker.ceph.com/issues/5510 refs #5510
Signed-off-by: Loic Dachary <loic@dachary.org>
-rw-r--r-- | src/osd/ReplicatedPG.cc | 101 | ||||
-rw-r--r-- | src/osd/ReplicatedPG.h | 68 | ||||
-rw-r--r-- | src/osd/Watch.cc | 18 | ||||
-rw-r--r-- | src/osd/Watch.h | 10 |
4 files changed, 98 insertions, 99 deletions
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc index 9af47403ab5..5927ed29c4e 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -4,6 +4,9 @@ * Ceph - scalable distributed file system * * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net> + * Copyright (C) 2013 Cloudwatt <libre.licensing@cloudwatt.com> + * + * Author: Loic Dachary <loic@dachary.org> * * This is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public @@ -695,7 +698,7 @@ void ReplicatedPG::do_op(OpRequestRef op) return; } - ObjectContext *obc; + ObjectContextRef obc; bool can_create = op->may_write(); snapid_t snapid; int r = find_object_context( @@ -775,7 +778,7 @@ void ReplicatedPG::do_op(OpRequestRef op) } // src_oids - map<hobject_t,ObjectContext*> src_obc; + map<hobject_t,ObjectContextRef> src_obc; for (vector<OSDOp>::iterator p = m->ops.begin(); p != m->ops.end(); ++p) { OSDOp& osd_op = *p; @@ -796,7 +799,7 @@ void ReplicatedPG::do_op(OpRequestRef op) hobject_t src_oid(osd_op.soid, src_oloc.key, m->get_pg().ps(), info.pgid.pool(), m->get_object_locator().nspace); if (!src_obc.count(src_oid)) { - ObjectContext *sobc; + ObjectContextRef sobc; snapid_t ssnapid; int r = find_object_context(src_oid, &sobc, false, &ssnapid); @@ -854,7 +857,7 @@ void ReplicatedPG::do_op(OpRequestRef op) hobject_t clone_oid = obc->obs.oi.soid; clone_oid.snap = *p; if (!src_obc.count(clone_oid)) { - ObjectContext *sobc; + ObjectContextRef sobc; snapid_t ssnapid; int r = find_object_context(clone_oid, &sobc, false, &ssnapid); @@ -972,7 +975,7 @@ void ReplicatedPG::do_op(OpRequestRef op) dout(10) << " taking ondisk_read_lock" << dendl; obc->ondisk_read_lock(); } - for (map<hobject_t,ObjectContext*>::iterator p = src_obc.begin(); p != src_obc.end(); ++p) { + for (map<hobject_t,ObjectContextRef>::iterator p = src_obc.begin(); p != src_obc.end(); ++p) { dout(10) << " taking ondisk_read_lock for src " << p->first << dendl; p->second->ondisk_read_lock(); } @@ -983,7 +986,7 @@ void ReplicatedPG::do_op(OpRequestRef op) dout(10) << " dropping ondisk_read_lock" << dendl; obc->ondisk_read_unlock(); } - for (map<hobject_t,ObjectContext*>::iterator p = src_obc.begin(); p != src_obc.end(); ++p) { + for (map<hobject_t,ObjectContextRef>::iterator p = src_obc.begin(); p != src_obc.end(); ++p) { dout(10) << " dropping ondisk_read_lock for src " << p->first << dendl; p->second->ondisk_read_unlock(); } @@ -1468,7 +1471,7 @@ ReplicatedPG::RepGather *ReplicatedPG::trim_object(const hobject_t &coid) { // load clone info bufferlist bl; - ObjectContext *obc = 0; + ObjectContextRef obc; int r = find_object_context(coid, &obc, false, NULL); if (r == -ENOENT || coid.snap != obc->obs.oi.soid.snap) { derr << __func__ << "could not find coid " << coid << dendl; @@ -2068,7 +2071,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops) ctx->user_modify = true; } - ObjectContext *src_obc = 0; + ObjectContextRef src_obc; if (ceph_osd_op_type_multi(op.op)) { MOSDOp *m = static_cast<MOSDOp *>(ctx->op->request); object_locator_t src_oloc; @@ -2486,7 +2489,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops) hobject_t clone_oid = soid; clone_oid.snap = *clone_iter; - ObjectContext *clone_obc = ctx->src_obc[clone_oid]; + ObjectContextRef clone_obc = ctx->src_obc[clone_oid]; assert(clone_obc); for (vector<snapid_t>::reverse_iterator p = clone_obc->obs.oi.snaps.rbegin(); p != clone_obc->obs.oi.snaps.rend(); @@ -2827,9 +2830,9 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops) uint64_t cookie = op.watch.cookie; bool do_watch = op.watch.flag & 1; entity_name_t entity = ctx->reqid.name; - ObjectContext *obc = ctx->obc; + ObjectContextRef obc = ctx->obc; - dout(10) << "watch: ctx->obc=" << (void *)obc << " cookie=" << cookie + dout(10) << "watch: ctx->obc=" << (void *)obc.get() << " cookie=" << cookie << " oi.version=" << oi.version.version << " ctx->at_version=" << ctx->at_version << dendl; dout(10) << "watch: oi.user_version=" << oi.user_version.version << dendl; dout(10) << "watch: peer_addr=" @@ -3430,7 +3433,7 @@ int ReplicatedPG::_rollback_to(OpContext *ctx, ceph_osd_op& op) dout(10) << "_rollback_to " << soid << " snapid " << snapid << dendl; - ObjectContext *rollback_to; + ObjectContextRef rollback_to; int ret = find_object_context( hobject_t(soid.oid, soid.get_key(), snapid, soid.hash, info.pgid.pool(), soid.get_namespace()), &rollback_to, false, &cloneid); @@ -3981,16 +3984,16 @@ void ReplicatedPG::op_applied(RepGather *repop) if (repop->ctx->clone_obc) { put_object_context(repop->ctx->clone_obc); - repop->ctx->clone_obc = 0; + repop->ctx->clone_obc = ObjectContextRef(); } if (repop->ctx->snapset_obc) { - put_object_context(repop->ctx->snapset_obc); - repop->ctx->snapset_obc = 0; + repop->ctx->snapset_obc = ObjectContextRef(); } put_object_context(repop->obc); put_object_contexts(repop->src_obc); - repop->obc = 0; + repop->src_obc.clear(); + repop->obc = ObjectContextRef(); if (!repop->aborted) { assert(repop->waitfor_ack.count(whoami) || @@ -4266,7 +4269,7 @@ void ReplicatedPG::issue_repop(RepGather *repop, utime_t now, } } -ReplicatedPG::RepGather *ReplicatedPG::new_repop(OpContext *ctx, ObjectContext *obc, +ReplicatedPG::RepGather *ReplicatedPG::new_repop(OpContext *ctx, ObjectContextRef obc, tid_t rep_tid) { if (ctx->op) @@ -4360,7 +4363,7 @@ void ReplicatedPG::get_watchers(list<obj_watch_item_t> &pg_watchers) } } -void ReplicatedPG::get_obc_watchers(ObjectContext *obc, list<obj_watch_item_t> &pg_watchers) +void ReplicatedPG::get_obc_watchers(ObjectContextRef obc, list<obj_watch_item_t> &pg_watchers) { for (map<pair<uint64_t, entity_name_t>, WatchRef>::iterator j = obc->watchers.begin(); @@ -4393,7 +4396,7 @@ void ReplicatedPG::check_blacklisted_watchers() } } -void ReplicatedPG::check_blacklisted_obc_watchers(ObjectContext *obc) +void ReplicatedPG::check_blacklisted_obc_watchers(ObjectContextRef obc) { dout(20) << "ReplicatedPG::check_blacklisted_obc_watchers for obc " << obc->obs.oi.soid << dendl; for (map<pair<uint64_t, entity_name_t>, WatchRef>::iterator k = @@ -4413,7 +4416,7 @@ void ReplicatedPG::check_blacklisted_obc_watchers(ObjectContext *obc) } } -void ReplicatedPG::populate_obc_watchers(ObjectContext *obc) +void ReplicatedPG::populate_obc_watchers(ObjectContextRef obc) { assert(is_active()); assert(!is_missing_object(obc->obs.oi.soid) || @@ -4449,7 +4452,7 @@ void ReplicatedPG::populate_obc_watchers(ObjectContext *obc) void ReplicatedPG::handle_watch_timeout(WatchRef watch) { - ObjectContext *obc = watch->get_obc(); // handle_watch_timeout owns this ref + ObjectContextRef obc = watch->get_obc(); // handle_watch_timeout owns this ref dout(10) << "handle_watch_timeout obc " << obc << dendl; if (is_degraded_object(obc->obs.oi.soid)) { @@ -4526,8 +4529,8 @@ ObjectContext *ReplicatedPG::_lookup_object_context(const hobject_t& oid) return NULL; } -ObjectContext *ReplicatedPG::create_object_context(const object_info_t& oi, - SnapSetContext *ssc) +ObjectContextRef ReplicatedPG::create_object_context(const object_info_t& oi, + SnapSetContext *ssc) { ObjectContext *obc = new ObjectContext(oi, false, ssc); dout(10) << "create_object_context " << obc << " " << oi.soid << " " << obc->ref << dendl; @@ -4537,8 +4540,8 @@ ObjectContext *ReplicatedPG::create_object_context(const object_info_t& oi, return obc; } -ObjectContext *ReplicatedPG::get_object_context(const hobject_t& soid, - bool can_create) +ObjectContextRef ReplicatedPG::get_object_context(const hobject_t& soid, + bool can_create) { map<hobject_t, ObjectContext*>::iterator p = object_contexts.find(soid); ObjectContext *obc; @@ -4552,7 +4555,7 @@ ObjectContext *ReplicatedPG::get_object_context(const hobject_t& soid, int r = osd->store->getattr(coll, soid, OI_ATTR, bv); if (r < 0) { if (!can_create) - return NULL; // -ENOENT! + return ObjectContextRef(); // -ENOENT! // new object. object_info_t oi(soid); @@ -4606,7 +4609,7 @@ void ReplicatedPG::context_registry_on_change() int ReplicatedPG::find_object_context(const hobject_t& oid, - ObjectContext **pobc, + ObjectContextRef *pobc, bool can_create, snapid_t *psnapid) { @@ -4618,11 +4621,11 @@ int ReplicatedPG::find_object_context(const hobject_t& oid, // want the snapdir? if (oid.snap == CEPH_SNAPDIR) { // return head or snapdir, whichever exists. - ObjectContext *obc = get_object_context(head, can_create); + ObjectContextRef obc = get_object_context(head, can_create); if (obc && !obc->obs.exists) { // ignore it if the obc exists but the object doesn't put_object_context(obc); - obc = NULL; + obc = ObjectContextRef(); } if (!obc) { obc = get_object_context(snapdir, can_create); @@ -4640,7 +4643,7 @@ int ReplicatedPG::find_object_context(const hobject_t& oid, // want the head? if (oid.snap == CEPH_NOSNAP) { - ObjectContext *obc = get_object_context(head, can_create); + ObjectContextRef obc = get_object_context(head, can_create); if (!obc) return -ENOENT; dout(10) << "find_object_context " << oid << " @" << oid.snap << dendl; @@ -4663,7 +4666,7 @@ int ReplicatedPG::find_object_context(const hobject_t& oid, // head? if (oid.snap > ssc->snapset.seq) { if (ssc->snapset.head_exists) { - ObjectContext *obc = get_object_context(head, false); + ObjectContextRef obc = get_object_context(head, false); dout(10) << "find_object_context " << head << " want " << oid.snap << " > snapset seq " << ssc->snapset.seq << " -- HIT " << obc->obs @@ -4708,7 +4711,7 @@ int ReplicatedPG::find_object_context(const hobject_t& oid, return -EAGAIN; } - ObjectContext *obc = get_object_context(soid, false); + ObjectContextRef obc = get_object_context(soid, false); assert(obc); // clone @@ -5099,7 +5102,7 @@ void ReplicatedPG::sub_op_modify_reply(OpRequestRef op) // =========================================================== -void ReplicatedPG::calc_head_subsets(ObjectContext *obc, SnapSet& snapset, const hobject_t& head, +void ReplicatedPG::calc_head_subsets(ObjectContextRef obc, SnapSet& snapset, const hobject_t& head, pg_missing_t& missing, const hobject_t &last_backfill, interval_set<uint64_t>& data_subset, @@ -5384,7 +5387,7 @@ void ReplicatedPG::send_remove_op(const hobject_t& oid, eversion_t v, int peer) * clones/heads and dup data ranges where possible. */ void ReplicatedPG::prep_push_to_replica( - ObjectContext *obc, const hobject_t& soid, int peer, + ObjectContextRef obc, const hobject_t& soid, int peer, int prio, PushOp *pop) { @@ -5438,7 +5441,7 @@ void ReplicatedPG::prep_push_to_replica( } void ReplicatedPG::prep_push(int prio, - ObjectContext *obc, + ObjectContextRef obc, const hobject_t& soid, int peer, PushOp *pop) { @@ -5454,7 +5457,7 @@ void ReplicatedPG::prep_push(int prio, void ReplicatedPG::prep_push( int prio, - ObjectContext *obc, + ObjectContextRef obc, const hobject_t& soid, int peer, eversion_t version, interval_set<uint64_t> &data_subset, @@ -5745,7 +5748,7 @@ bool ReplicatedPG::handle_pull_response( hoid.get_namespace()); assert(ssc); } - ObjectContext *obc = create_object_context(pi.recovery_info.oi, ssc); + ObjectContextRef obc = create_object_context(pi.recovery_info.oi, ssc); obc->obs.exists = true; obc->ondisk_write_lock(); @@ -6150,7 +6153,7 @@ void ReplicatedPG::finish_degraded_object(const hobject_t& oid) j != i->second->blocking.end(); i->second->blocking.erase(j++)) { dout(10) << " no longer blocking writes for " << (*j)->obs.oi.soid << dendl; - (*j)->blocked_by = NULL; + (*j)->blocked_by = ObjectContextRef(); put_object_context(*j); put_object_context(i->second); } @@ -6259,7 +6262,7 @@ void ReplicatedPG::_committed_pushed_object( unlock(); } -void ReplicatedPG::_applied_recovered_object(ObjectContext *obc) +void ReplicatedPG::_applied_recovered_object(ObjectContextRef obc) { lock(); dout(10) << "_applied_recovered_object " << *obc << dendl; @@ -6469,7 +6472,7 @@ eversion_t ReplicatedPG::pick_newest_available(const hobject_t& oid) /* Mark an object as lost */ -ObjectContext *ReplicatedPG::mark_object_lost(ObjectStore::Transaction *t, +ObjectContextRef ReplicatedPG::mark_object_lost(ObjectStore::Transaction *t, const hobject_t &oid, eversion_t version, utime_t mtime, int what) { @@ -6486,7 +6489,7 @@ ObjectContext *ReplicatedPG::mark_object_lost(ObjectStore::Transaction *t, pg_log_entry_t e(what, oid, info.last_update, version, osd_reqid_t(), mtime); pg_log.add(e); - ObjectContext *obc = get_object_context(oid, true); + ObjectContextRef obc = get_object_context(oid, true); obc->ondisk_write_lock(); @@ -6503,7 +6506,7 @@ ObjectContext *ReplicatedPG::mark_object_lost(ObjectStore::Transaction *t, struct C_PG_MarkUnfoundLost : public Context { ReplicatedPGRef pg; - list<ObjectContext*> obcs; + list<ObjectContextRef> obcs; C_PG_MarkUnfoundLost(ReplicatedPG *p) : pg(p) {} void finish(int r) { pg->_finish_mark_all_unfound_lost(obcs); @@ -6536,7 +6539,7 @@ void ReplicatedPG::mark_all_unfound_lost(int what) continue; } - ObjectContext *obc = NULL; + ObjectContextRef obc; eversion_t prev; switch (what) { @@ -6612,7 +6615,7 @@ void ReplicatedPG::mark_all_unfound_lost(int what) osd->queue_for_recovery(this); } -void ReplicatedPG::_finish_mark_all_unfound_lost(list<ObjectContext*>& obcs) +void ReplicatedPG::_finish_mark_all_unfound_lost(list<ObjectContextRef>& obcs) { lock(); dout(10) << "_finish_mark_all_unfound_lost " << dendl; @@ -7086,7 +7089,7 @@ int ReplicatedPG::recover_primary(int max, ThreadPool::TPHandle &handle) case pg_log_entry_t::LOST_REVERT: { if (item.have == latest->reverting_to) { - ObjectContext *obc = get_object_context(soid, true); + ObjectContextRef obc = get_object_context(soid, true); if (obc->obs.oi.version == latest->version) { // I'm already reverting @@ -7186,7 +7189,7 @@ int ReplicatedPG::prep_object_replica_pushes( dout(10) << __func__ << ": on " << soid << dendl; // NOTE: we know we will get a valid oloc off of disk here. - ObjectContext *obc = get_object_context(soid, false); + ObjectContextRef obc = get_object_context(soid, false); if (!obc) { pg_log.missing_add(soid, v, eversion_t()); bool uhoh = true; @@ -7433,7 +7436,7 @@ int ReplicatedPG::recover_backfill( for (set<hobject_t>::iterator i = add_to_stat.begin(); i != add_to_stat.end(); ++i) { - ObjectContext *obc = get_object_context(*i, false); + ObjectContextRef obc = get_object_context(*i, false); pg_stat_t stat; add_object_context_to_pg_stat(obc, &stat); pending_backfill_updates[*i] = stat; @@ -7508,7 +7511,7 @@ void ReplicatedPG::prep_backfill_object_push( if (!pushing.count(oid)) start_recovery_op(oid); - ObjectContext *obc = get_object_context(oid, false); + ObjectContextRef obc = get_object_context(oid, false); obc->ondisk_read_lock(); (*pushes)[peer].push_back(PushOp()); prep_push_to_replica(obc, oid, peer, g_conf->osd_recovery_op_priority, @@ -7536,7 +7539,7 @@ void ReplicatedPG::scan_range( for (vector<hobject_t>::iterator p = ls.begin(); p != ls.end(); ++p) { handle.reset_tp_timeout(); - ObjectContext *obc = NULL; + ObjectContextRef obc; if (is_primary()) obc = _lookup_object_context(*p); if (obc) { diff --git a/src/osd/ReplicatedPG.h b/src/osd/ReplicatedPG.h index 884da991f70..17a36d4ed69 100644 --- a/src/osd/ReplicatedPG.h +++ b/src/osd/ReplicatedPG.h @@ -3,6 +3,9 @@ * Ceph - scalable distributed file system * * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net> + * Copyright (C) 2013 Cloudwatt <libre.licensing@cloudwatt.com> + * + * Author: Loic Dachary <loic@dachary.org> * * This is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public @@ -27,6 +30,9 @@ #include "messages/MOSDOp.h" #include "messages/MOSDOpReply.h" #include "messages/MOSDSubOp.h" + +#include "common/sharedptr_registry.hpp" + class MOSDSubOpReply; class ReplicatedPG; @@ -124,10 +130,10 @@ public: vector<pg_log_entry_t> log; interval_set<uint64_t> modified_ranges; - ObjectContext *obc; // For ref counting purposes - map<hobject_t,ObjectContext*> src_obc; - ObjectContext *clone_obc; // if we created a clone - ObjectContext *snapset_obc; // if we created/deleted a snapdir + ObjectContextRef obc; + map<hobject_t,ObjectContextRef> src_obc; + ObjectContextRef clone_obc; // if we created a clone + ObjectContextRef snapset_obc; // if we created/deleted a snapdir int data_off; // FIXME: we may want to kill this msgr hint off at some point! @@ -150,7 +156,7 @@ public: modify(false), user_modify(false), bytes_written(0), bytes_read(0), current_osd_subop_num(0), - obc(0), clone_obc(0), snapset_obc(0), data_off(0), reply(NULL), pg(_pg), + data_off(0), reply(NULL), pg(_pg), num_read(0), num_write(0) { if (_ssc) { @@ -176,8 +182,8 @@ public: eversion_t v; OpContext *ctx; - ObjectContext *obc; - map<hobject_t,ObjectContext*> src_obc; + ObjectContextRef obc; + map<hobject_t,ObjectContextRef> src_obc; tid_t rep_tid; @@ -197,7 +203,7 @@ public: list<ObjectStore::Transaction*> tls; bool queue_snap_trimmer; - RepGather(OpContext *c, ObjectContext *pi, tid_t rt, + RepGather(OpContext *c, ObjectContextRef pi, tid_t rt, eversion_t lc) : queue_item(this), nref(1), @@ -240,7 +246,7 @@ protected: void eval_repop(RepGather*); void issue_repop(RepGather *repop, utime_t now, eversion_t old_last_update, bool old_exists, uint64_t old_size, eversion_t old_version); - RepGather *new_repop(OpContext *ctx, ObjectContext *obc, tid_t rep_tid); + RepGather *new_repop(OpContext *ctx, ObjectContextRef obc, tid_t rep_tid); void remove_repop(RepGather *repop); void repop_ack(RepGather *repop, int result, int ack_type, @@ -276,18 +282,18 @@ protected: friend struct C_OnPushCommit; // projected object info - map<hobject_t, ObjectContext*> object_contexts; + SharedPtrRegistry<hobject_t, ObjectContext> object_contexts; map<object_t, SnapSetContext*> snapset_contexts; Mutex snapset_contexts_lock; // debug order that client ops are applied map<hobject_t, map<client_t, tid_t> > debug_op_order; - void populate_obc_watchers(ObjectContext *obc); - void check_blacklisted_obc_watchers(ObjectContext *); + void populate_obc_watchers(ObjectContextRef obc); + void check_blacklisted_obc_watchers(ObjectContextRef obc); void check_blacklisted_watchers(); void get_watchers(list<obj_watch_item_t> &pg_watchers); - void get_obc_watchers(ObjectContext *obc, list<obj_watch_item_t> &pg_watchers); + void get_obc_watchers(ObjectContextRef obc, list<obj_watch_item_t> &pg_watchers); public: void handle_watch_timeout(WatchRef watch); protected: @@ -301,8 +307,8 @@ protected: return NULL; } ObjectContext *_lookup_object_context(const hobject_t& oid); - ObjectContext *create_object_context(const object_info_t& oi, SnapSetContext *ssc); - ObjectContext *get_object_context(const hobject_t& soid, bool can_create); + ObjectContextRef create_object_context(const object_info_t& oi, SnapSetContext *ssc); + ObjectContextRef get_object_context(const hobject_t& soid, bool can_create); void register_object_context(ObjectContext *obc) { if (!obc->registered) { assert(object_contexts.count(obc->obs.oi.soid) == 0); @@ -317,10 +323,10 @@ protected: void put_object_context(ObjectContext *obc); void put_object_contexts(map<hobject_t,ObjectContext*>& obcv); int find_object_context(const hobject_t& oid, - ObjectContext **pobc, + ObjectContextRef *pobc, bool can_create, snapid_t *psnapid=NULL); - void add_object_context_to_pg_stat(ObjectContext *obc, pg_stat_t *stat); + void add_object_context_to_pg_stat(ObjectContextRef obc, pg_stat_t *stat); void get_src_oloc(const object_t& oid, const object_locator_t& oloc, object_locator_t& src_oloc); @@ -531,7 +537,7 @@ protected: int prep_object_replica_pushes(const hobject_t& soid, eversion_t v, int priority, map<int, vector<PushOp> > *pushes); - void calc_head_subsets(ObjectContext *obc, SnapSet& snapset, const hobject_t& head, + void calc_head_subsets(ObjectContextRef obc, SnapSet& snapset, const hobject_t& head, pg_missing_t& missing, const hobject_t &last_backfill, interval_set<uint64_t>& data_subset, @@ -541,17 +547,17 @@ protected: interval_set<uint64_t>& data_subset, map<hobject_t, interval_set<uint64_t> >& clone_subsets); void prep_push_to_replica( - ObjectContext *obc, + ObjectContextRef obc, const hobject_t& oid, int dest, int priority, PushOp *push_op); void prep_push(int priority, - ObjectContext *obc, + ObjectContextRef obc, const hobject_t& oid, int dest, PushOp *op); void prep_push(int priority, - ObjectContext *obc, + ObjectContextRef obc, const hobject_t& soid, int peer, eversion_t version, interval_set<uint64_t> &data_subset, @@ -654,8 +660,8 @@ protected: } }; struct C_OSD_OndiskWriteUnlock : public Context { - ObjectContext *obc, *obc2; - C_OSD_OndiskWriteUnlock(ObjectContext *o, ObjectContext *o2=0) : obc(o), obc2(o2) {} + ObjectContextRef obc, obc2; + C_OSD_OndiskWriteUnlock(ObjectContextRef o, ObjectContextRef o2 = ObjectContextRef()) : obc(o), obc2(o2) {} void finish(int r) { obc->ondisk_write_unlock(); if (obc2) @@ -663,17 +669,17 @@ protected: } }; struct C_OSD_OndiskWriteUnlockList : public Context { - list<ObjectContext*> *pls; - C_OSD_OndiskWriteUnlockList(list<ObjectContext*> *l) : pls(l) {} + list<ObjectContextRef> *pls; + C_OSD_OndiskWriteUnlockList(list<ObjectContextRef> *l) : pls(l) {} void finish(int r) { - for (list<ObjectContext*>::iterator p = pls->begin(); p != pls->end(); ++p) + for (list<ObjectContextRef>::iterator p = pls->begin(); p != pls->end(); ++p) (*p)->ondisk_write_unlock(); } }; struct C_OSD_AppliedRecoveredObject : public Context { ReplicatedPGRef pg; - ObjectContext *obc; - C_OSD_AppliedRecoveredObject(ReplicatedPG *p, ObjectContext *o) : + ObjectContextRef obc; + C_OSD_AppliedRecoveredObject(ReplicatedPG *p, ObjectContextRef o) : pg(p), obc(o) {} void finish(int r) { pg->_applied_recovered_object(obc); @@ -736,7 +742,7 @@ protected: void sub_op_modify_commit(RepModify *rm); void sub_op_modify_reply(OpRequestRef op); - void _applied_recovered_object(ObjectContext *obc); + void _applied_recovered_object(ObjectContextRef obc); void _applied_recovered_object_replica(); void _committed_pushed_object(epoch_t epoch, eversion_t lc); void recover_got(hobject_t oid, eversion_t v); @@ -885,10 +891,10 @@ public: void mark_all_unfound_lost(int what); eversion_t pick_newest_available(const hobject_t& oid); - ObjectContext *mark_object_lost(ObjectStore::Transaction *t, + ObjectContextRef mark_object_lost(ObjectStore::Transaction *t, const hobject_t& oid, eversion_t version, utime_t mtime, int what); - void _finish_mark_all_unfound_lost(list<ObjectContext*>& obcs); + void _finish_mark_all_unfound_lost(list<ObjectContextRef>& obcs); void on_role_change(); void on_change(ObjectStore::Transaction *t); diff --git a/src/osd/Watch.cc b/src/osd/Watch.cc index 8a084ca9aa1..ffa3adced24 100644 --- a/src/osd/Watch.cc +++ b/src/osd/Watch.cc @@ -250,15 +250,14 @@ public: string Watch::gen_dbg_prefix() { stringstream ss; ss << pg->gen_prefix() << " -- Watch(" - << make_pair(cookie, entity) - << ", obc->ref=" << (obc ? obc->ref : -1) << ") "; + << make_pair(cookie, entity) << ") "; return ss.str(); } Watch::Watch( ReplicatedPG *pg, OSDService *osd, - ObjectContext *obc, + ObjectContextRef obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, @@ -272,7 +271,6 @@ Watch::Watch( addr(addr), entity(entity), discarded(false) { - obc->get(); dout(10) << "Watch()" << dendl; } @@ -292,13 +290,6 @@ Context *Watch::get_delayed_cb() return cb; } -ObjectContext *Watch::get_obc() -{ - assert(obc); - obc->get(); - return obc; -} - void Watch::register_cb() { Mutex::Locker l(osd->watch_lock); @@ -370,8 +361,7 @@ void Watch::discard_state() sessionref->put(); conn = ConnectionRef(); } - pg->put_object_context(obc); - obc = NULL; + obc = ObjectContextRef(); } bool Watch::is_discarded() @@ -428,7 +418,7 @@ void Watch::notify_ack(uint64_t notify_id) WatchRef Watch::makeWatchRef( ReplicatedPG *pg, OSDService *osd, - ObjectContext *obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, entity_addr_t addr) + ObjectContextRef obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, entity_addr_t addr) { WatchRef ret(new Watch(pg, osd, obc, timeout, cookie, entity, addr)); ret->set_self(ret); diff --git a/src/osd/Watch.h b/src/osd/Watch.h index 1c9fa28cb65..ecb61ad8b72 100644 --- a/src/osd/Watch.h +++ b/src/osd/Watch.h @@ -151,7 +151,7 @@ class Watch { OSDService *osd; boost::intrusive_ptr<ReplicatedPG> pg; - ObjectContext *obc; + std::tr1::shared_ptr<ObjectContext> obc; std::map<uint64_t, NotifyRef> in_progress_notifies; @@ -165,7 +165,7 @@ class Watch { Watch( ReplicatedPG *pg, OSDService *osd, - ObjectContext *obc, uint32_t timeout, + std::tr1::shared_ptr<ObjectContext> obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, entity_addr_t addr); @@ -187,7 +187,7 @@ public: string gen_dbg_prefix(); static WatchRef makeWatchRef( ReplicatedPG *pg, OSDService *osd, - ObjectContext *obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, entity_addr_t addr); + std::tr1::shared_ptr<ObjectContext> obc, uint32_t timeout, uint64_t cookie, entity_name_t entity, entity_addr_t addr); void set_self(WatchRef _self) { self = _self; } @@ -195,8 +195,8 @@ public: /// Does not grant a ref count! boost::intrusive_ptr<ReplicatedPG> get_pg() { return pg; } - /// Grants a ref count! - ObjectContext *get_obc(); + std::tr1::shared_ptr<ObjectContext> get_obc() { return obc; } + uint64_t get_cookie() const { return cookie; } entity_name_t get_entity() const { return entity; } entity_addr_t get_peer_addr() const { return addr; } |