From: sage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Date: Sun, 26 Jun 2005 22:16:18 +0000 (+0000)
Subject: *** empty log message ***
X-Git-Tag: v0.1~2041
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=aa516bc3fcf91e322d0a187fd496a4dfc3dd1f14;p=ceph.git

*** empty log message ***


git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@340 29311d96-e01e-0410-9327-a35deaab8ce9
---

diff --git a/ceph/mds/MDCache.cc b/ceph/mds/MDCache.cc
index 8868e7e1a8509..3cc376027a226 100644
--- a/ceph/mds/MDCache.cc
+++ b/ceph/mds/MDCache.cc
@@ -669,8 +669,8 @@ bool MDCache::shutdown_pass()
   }
 	
   // done!
+  dout(7) << "done, sending shutdown_finish" << endl;
   if (mds->get_nodeid() != 0) {
-	dout(7) << "done, sending shutdown_finish" << endl;
 	mds->messenger->send_message(new MGenericMessage(MSG_MDS_SHUTDOWNFINISH),
 								 MSG_ADDR_MDS(0), MDS_PORT_MAIN, MDS_PORT_MAIN);
   } else {
diff --git a/ceph/msg/TCPMessenger.cc b/ceph/msg/TCPMessenger.cc
index 8f990627f29e6..1d87a5ece5966 100644
--- a/ceph/msg/TCPMessenger.cc
+++ b/ceph/msg/TCPMessenger.cc
@@ -155,9 +155,12 @@ int tcpmessenger_init(int& argc, char**& argv)
   //  for (int i=0; i<mpi_world; i++) 
   //dout(DBL) << "  addr of " << i << " is " << remote_addr[i] << endl;
 
-
+  dout(DBL) << "tcpmessenger_shutdown barrier" << endl;
+  MPI_Barrier (MPI_COMM_WORLD);
   MPI_Finalize();
 
+
+  // init socket arrays
   in_sd = new int[mpi_world];
   memset(in_sd, 0, sizeof(int)*mpi_world);
   out_sd = new int[mpi_world];
@@ -173,7 +176,7 @@ int tcpmessenger_init(int& argc, char**& argv)
 
 int tcpmessenger_shutdown() 
 {
-  dout(5) << "tcpmessenger_shutdown closing all sockets etc" << endl;
+  dout(1) << "tcpmessenger_shutdown closing all sockets etc" << endl;
 
   // bleh
   for (int i=0; i<mpi_world; i++) {
@@ -576,6 +579,7 @@ void tcpmessenger_wait()
   dout(10) << "tcpmessenger_wait waiting for thread to finished." << endl;
   pthread_join(dispatch_thread_id, &returnval);
   dout(10) << "tcpmessenger_wait thread finished." << endl;
+
 }
 
 
@@ -635,7 +639,7 @@ int TCPMessenger::shutdown()
 
   // last one?
   if (directory.empty()) {
-	dout(10) << "shutdown last tcpmessenger on rank " << mpi_rank << " shut down" << endl;
+	dout(1) << "shutdown last tcpmessenger on rank " << mpi_rank << " shut down" << endl;
 	pthread_t whoami = pthread_self();
 
 
@@ -652,9 +656,14 @@ int TCPMessenger::shutdown()
 
 	dout(DBL) << "setting tcp_done" << endl;
 
+	incoming_lock.Lock();
 	tcp_done = true;
-	tcpmessenger_kick_incoming_loop();
+	incoming_cond.Signal();
+	incoming_lock.Unlock();
+
 	tcpmessenger_kick_outgoing_loop();
+
+
 	/*
 
 	dout(15) << "whoami = " << whoami << ", thread = " << dispatch_thread_id << endl;
diff --git a/ceph/osd/OSD.cc b/ceph/osd/OSD.cc
index 3c69e3ea9b73b..f2927f6b1e64b 100644
--- a/ceph/osd/OSD.cc
+++ b/ceph/osd/OSD.cc
@@ -110,8 +110,16 @@ int OSD::init()
 
 int OSD::shutdown()
 {
+  dout(1) << "shutdown" << endl;
+
+  // stop threads
+  delete threadpool;
+  threadpool = 0;
+
+  // shut everything else down
   monitor->shutdown();
   messenger->shutdown();
+
   int r = store->finalize();
   return r;
 }