Changeset 1037 for XIOS/dev/branch_yushan/src/context_server.cpp

Timestamp:

01/25/17 16:25:17 (7 years ago)

Author:

yushan

Message:

initialize the branch

File:

• XIOS/dev/branch_yushan/src/context_server.cpp (modified) (7 diffs)

XIOS/dev/branch_yushan/src/context_server.cpp

@@ -57 +57 @@
   }
 
-  bool CContextServer::eventLoop(bool enableEventsProcessing /*= true*/)
+  bool CContextServer::eventLoop(void)
   {
     listen();
     checkPendingRequest();
-    if (enableEventsProcessing)
-      processEvents();
+    processEvents();
     return finished;
   }
@@ -77 +76 @@
     for(rank=0;rank<commSize;rank++)
     {
+      //printf("in CContextServer::listen, rank = %d, commSize = %d, pendingRequest.find(rank) = %d\n", rank, commSize, pendingRequest.find(rank));
       if (pendingRequest.find(rank)==pendingRequest.end())
       {
@@ -85 +85 @@
         {
           it=buffers.find(rank);
+          
           if (it==buffers.end()) // Receive the buffer size and allocate the buffer
           {
@@ -91 +92 @@
             mapBufferSize_.insert(std::make_pair(rank, buffSize));
             it=(buffers.insert(pair<int,CServerBuffer*>(rank,new CServerBuffer(buffSize)))).first;
+            //printf("find message, is buffer end, receiving, buffSize = %d, rank = %d, commSize = %d\n", buffSize, rank, commSize);
           }
           else
           {
+            
             MPI_Get_count(&status,MPI_CHAR,&count);
             if (it->second->isBufferFree(count))
@@ -100 +103 @@
               MPI_Irecv(addr,count,MPI_CHAR,rank,20,interComm,&pendingRequest[rank]);
               bufferRequest[rank]=addr;
+              //printf("find message, i-receiving to buffer %p, rank = %d, commSize = %d\n", addr, rank, commSize);
             }
           }
@@ -116 +120 @@
     int count;
     MPI_Status status;
+
+    //printf("enter checkPendingRequest\n");
 
     for(it=pendingRequest.begin();it!=pendingRequest.end();it++)
@@ -185 +191 @@
          // The best way to properly solve this problem will be to use the event scheduler also in attached mode
          // for now just set up a MPI barrier
-         if (!CServer::eventScheduler && CXios::isServer) MPI_Barrier(intraComm) ;
+         if (!CServer::eventScheduler) MPI_Barrier(intraComm) ;
 
          CTimer::get("Process events").resume();