From 1fb26425f986335e027a124a5c8c1676e484e86f Mon Sep 17 00:00:00 2001
From: sage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Date: Sat, 4 Jun 2005 03:33:36 +0000
Subject: [PATCH] *** empty log message ***

git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@262 29311d96-e01e-0410-9327-a35deaab8ce9
---
 ceph/msg/MPIMessenger.cc | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git a/ceph/msg/MPIMessenger.cc b/ceph/msg/MPIMessenger.cc
index ca736a3e4303c..64cad01652478 100644
--- a/ceph/msg/MPIMessenger.cc
+++ b/ceph/msg/MPIMessenger.cc
@@ -209,13 +209,13 @@ int mpi_send(Message *m)
 
   // send envelope
   MPI_Request req; 
-  ASSERT(MPI_Send((void*)env,
+  ASSERT(MPI_Isend((void*)env,
 				  sizeof(*env),
 				  MPI_CHAR,
 				  rank,
 				  TAG_ENV,
-				  MPI_COMM_WORLD/*,
-								  &req*/) == MPI_SUCCESS);
+				  MPI_COMM_WORLD,
+				   &req) == MPI_SUCCESS);
   
   int i = 0;
   vector<MPI_Request> chunk_reqs(env->nchunks);
@@ -223,13 +223,13 @@ int mpi_send(Message *m)
 	   it != blist.buffers().end();
 	   it++) {
 	dout(10) << "mpi_sending frag " << i << " len " << (*it).length() << endl;
-	ASSERT(MPI_Send((void*)(*it).c_str(),
+	ASSERT(MPI_Isend((void*)(*it).c_str(),
 					 (*it).length(),
 					 MPI_CHAR,
 					 rank,
 					 TAG_PAYLOAD,
-					 MPI_COMM_WORLD/*,
-									 &chunk_reqs[i]*/) == MPI_SUCCESS);
+					 MPI_COMM_WORLD,
+					 &chunk_reqs[i]) == MPI_SUCCESS);
 	i++;
   }
 
@@ -344,11 +344,12 @@ MPI_Request kick_req;
 
 void mpimessenger_kick_loop()
 {
+  /*
   dout(10) << "kicking" << endl;
   MPI_Cancel(&recv_env_req);
   dout(10) << "kicked" << endl;
   return;
-
+  */
 
   // wake up the event loop with a bad "message"
   //char stop = 0;               // a byte will do
@@ -469,7 +470,7 @@ int MPIMessenger::send_message(Message *m, msg_addr_t dest, int port, int frompo
   m->set_source(myaddr, fromport);
   m->set_dest(dest, port);
 
-  if (0) {
+  if (1) {
 	// send in this thread
 	mpi_send(m);
   } else {
-- 
2.39.5