- mon: less push, more pull
- mon: request routing
- mon cluster expansion
-
-- revert 4fe2e6acb9d3613ca041774c1243940d1c8c9c9c
+- osd: fix pg parsing, restarts on larger clusters
- kclient: msgs built with a page list
- kclient: retry alloc on ENOMEM when reading from connection?
int SimpleMessenger::Endpoint::shutdown()
{
- dout(0) << "shutdown " << get_myaddr() << dendl;
+ dout(10) << "shutdown " << get_myaddr() << dendl;
// stop my dispatch thread
if (dispatch_thread.am_self()) {
// done! clean up.
if (did_bind) {
- dout(0) << "wait: stopping accepter thread" << dendl;
+ dout(20) << "wait: stopping accepter thread" << dendl;
accepter.stop();
dout(20) << "wait: stopped accepter thread" << dendl;
}
// close+reap all pipes
lock.Lock();
{
- dout(0) << "wait: closing pipes" << dendl;
+ dout(10) << "wait: closing pipes" << dendl;
list<Pipe*> toclose;
for (hash_map<entity_addr_t,Pipe*>::iterator i = rank_pipe.begin();
i != rank_pipe.end();
}
reaper();
+ dout(10) << "wait: waiting for pipes " << pipes << " to close" << dendl;
while (!pipes.empty()) {
- dout(0) << "wait: waiting for pipes " << pipes << " to close" << dendl;
wait_cond.Wait(lock);
reaper();
}
lock.Unlock();
dout(10) << "wait: done." << dendl;
- dout(0) << "shutdown complete." << dendl;
+ dout(1) << "shutdown complete." << dendl;
remove_pid_file();
started = false;
did_bind = false;