#define DOUT_SUBSYS filestore
#undef dout_prefix
-#define dout_prefix *_dout << dbeginl << "filestore(" << basedir << ") "
+#define dout_prefix *_dout << dbeginl << pthread_self() << " filestore(" << basedir << ") "
#include "include/buffer.h"
p != heartbeat_from.end();
p++) {
if (heartbeat_from_stamp.count(p->first)) {
- if (!osdmap->is_up(p->first) || osdmap->get_hb_inst(p->first) != heartbeat_inst[p->first]) {
+ if (!osdmap->is_up(p->first)) {
+ dout(10) << "not checking timeout on down osd" << p->first << dendl;
+ } else if (osdmap->get_hb_inst(p->first) != heartbeat_inst[p->first]) {
dout(10) << "not checking timeout on osd" << p->first
- << " whose up " << osdmap->is_up(p->first)
- << " != 1 || hb inst " << heartbeat_inst[p->first]
- << " != map's "
+ << " hb inst " << heartbeat_inst[p->first]
+ << " != map's " << osdmap->get_hb_inst(p->first)
<< dendl;
} else if (heartbeat_from_stamp[p->first] < grace) {
dout(0) << "no heartbeat from osd" << p->first
}
pg->unlock();
+ dout(10) << "_remove_pg " << pgid << " taking osd_lock" << dendl;
osd_lock.Lock();
pg->lock();