{
ReplicatedPG::ObjectContext *obc = (ReplicatedPG::ObjectContext *)_obc;
Watch::Notification *notif = (Watch::Notification *)_notif;
- dout(0) << "got the last reply from pending watchers, can send response now" << dendl;
+ dout(10) << "got the last reply from pending watchers, can send response now" << dendl;
MWatchNotify *reply = notif->reply;
client_messenger->send_message(reply, notif->session->con);
notif->session->put();
for (map<ReplicatedPG::ObjectContext *, pg_t>::iterator oiter = obcs.begin(); oiter != obcs.end(); ++oiter) {
ReplicatedPG::ObjectContext *obc = (ReplicatedPG::ObjectContext *)oiter->first;
- dout(0) << "obc=" << (void *)obc << dendl;
+ dout(10) << "obc=" << (void *)obc << dendl;
ReplicatedPG *pg = static_cast<ReplicatedPG *>(lookup_lock_raw_pg(oiter->second));
assert(pg);
map<entity_name_t, Session *>::iterator witer = obc->watchers.begin();
while (1) {
while (witer != obc->watchers.end() && witer->second == session) {
- dout(0) << "removing watching session entity_name=" << session->entity_name
+ dout(10) << "removing watching session entity_name=" << session->entity_name
<< " from " << obc->obs.oi << dendl;
entity_name_t entity = witer->first;
watch_info_t& w = obc->obs.oi.watchers[entity];
bool OSD::ms_handle_reset(Connection *con)
{
- dout(0) << "OSD::ms_handle_reset()" << dendl;
+ dout(1) << "OSD::ms_handle_reset()" << dendl;
OSD::Session *session = (OSD::Session *)con->get_priv();
if (!session)
return false;
- dout(0) << "OSD::ms_handle_reset() s=" << (void *)session << dendl;
disconnect_session_watches(session);
session->put();
return true;
{
assert(watch_lock.is_locked());
Watch::Notification *notif = (Watch::Notification *)_notif;
- dout(0) << "OSD::handle_notify_timeout notif " << notif->id << dendl;
+ dout(10) << "OSD::handle_notify_timeout notif " << notif->id << dendl;
ReplicatedPG::ObjectContext *obc = (ReplicatedPG::ObjectContext *)notif->obc;
{
assert(osd->watch_lock.is_locked());
- dout(0) << "dump_watchers " << obc->obs.oi.soid << " " << obc->obs.oi << dendl;
+ dout(10) << "dump_watchers " << obc->obs.oi.soid << " " << obc->obs.oi << dendl;
for (map<entity_name_t, OSD::Session *>::iterator iter = obc->watchers.begin();
iter != obc->watchers.end();
++iter)
- dout(0) << " * obc->watcher: " << iter->first << " session=" << iter->second << dendl;
+ dout(10) << " * obc->watcher: " << iter->first << " session=" << iter->second << dendl;
for (map<entity_name_t, watch_info_t>::iterator oi_iter = obc->obs.oi.watchers.begin();
oi_iter != obc->obs.oi.watchers.end();
oi_iter++) {
watch_info_t& w = oi_iter->second;
- dout(0) << " * oi->watcher: " << oi_iter->first << " cookie=" << w.cookie << dendl;
+ dout(10) << " * oi->watcher: " << oi_iter->first << " cookie=" << w.cookie << dendl;
}
}