Changeset 204 for XMLIO_V2/dev/dev_rv/src/xmlio/buffer_pair.cpp

Timestamp:

05/25/11 15:19:14 (13 years ago)

Author:

hozdoba

Message:

 

File:

• XMLIO_V2/dev/dev_rv/src/xmlio/buffer_pair.cpp (modified) (7 diffs)

XMLIO_V2/dev/dev_rv/src/xmlio/buffer_pair.cpp

@@ -1 +1 @@
 #include "buffer_pair.hpp"
+
+#include "impi_interface.hpp"
 
 namespace xmlioserver
@@ -9 +11 @@
          : com_client_server(com_client_server) 
          , first(BUFFER_CLIENT_SIZE), second(BUFFER_CLIENT_SIZE)
-         , first_request(-1), second_request(-1)
+         , first_request(mpi_request_null), second_request(mpi_request_null)
          , currentBuffer(0)
       { /* Ne rien faire de plus */ }
@@ -21 +23 @@
       {
          if ((currentBuffer  ==  0) && (first.getUsedSize()  != 0) &&
-            ((second_request == -1) || CMPIManager::Test (second_request)))
+            ((second_request == mpi_request_null) || CMPIManager::Test (second_request)))
              return (true);
              
          if ((currentBuffer  ==  1) && (second.getUsedSize() != 0) &&
-            ((first_request  == -1) || CMPIManager::Test (first_request)))
+            ((first_request  == mpi_request_null) || CMPIManager::Test (first_request)))
             return (true);
             
@@ -38 +40 @@
          {
             CMPIManager::Wait(this->second_request);
-            this->second_request = -1;
+            this->second_request = mpi_request_null;
             return (this->second_request);
          }
@@ -44 +46 @@
          {
             CMPIManager::Wait(this->first_request);
-            this->first_request = -1;
+            this->first_request = mpi_request_null;
             return (this->first_request);
          }
@@ -58 +60 @@
                (this->com_client_server, 0, this->first, this->first_request);
             this->currentBuffer  =  1;
-            this->second_request = -1;
+            this->second_request = mpi_request_null;
             this->second.clear();
          }
@@ -66 +68 @@
                (this->com_client_server, 0, this->second, this->second_request);
             this->currentBuffer =  0;
-            this->first_request = -1;
+            this->first_request = mpi_request_null;
             this->first.clear();
          }