Changeset 196 for XMLIO_V2/dev/dev_rv/src/xmlio/buffer_list.cpp

Timestamp:

05/18/11 17:47:46 (13 years ago)

Author:

hozdoba

Message:

 

File:

• XMLIO_V2/dev/dev_rv/src/xmlio/buffer_list.cpp (modified) (3 diffs)

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

@@ -7 +7 @@
       /// ////////////////////// Définitions ////////////////////// ///
       CBufferList::CBufferList(MPIComm com_client_server)
-         : SuperClass()
+         : SuperClass(CMPIManager::GetCommSize(com_client_server) - 1)
          , com_client_server(com_client_server)
          , nbbuffer(CMPIManager::GetCommSize(com_client_server) - 1)
-      {
-         for (StdSize i = 0; i < this->nbbuffer; i++)
-            SuperClass::push_back(BufferType(BUFFER_SERVER_SIZE));
-      }
+      { /* Ne rien faire de plus */ }
 
       CBufferList::~CBufferList(void)
@@ -28 +25 @@
       }
 
-      void CBufferList::recvRequests(void)
+      bool CBufferList::recvRequests(void)
       {
          while (!this->hasRequests())
@@ -38 +35 @@
                   StdSize size = CMPIManager::GetReceivedDataSize(com_client_server, i);
                   if (SuperClass::operator[](i-1).isAvailable(size))
+                  {
+                     std::cout << "b:" << i << std::endl;
                      CMPIManager::ReceiveCircularBuffer
                         (com_client_server, i, SuperClass::operator[](i-1));
+                  }
+                  else
+                  {
+                     DEBUG ("Impossible d'écrire dans le tampon " << i 
+                             << " (Taille requise : " << size << " octets,"
+                             << " Taille du buffer circulaire : "
+                             << SuperClass::operator[](i-1).getSize() << " octets)");
+                  }
                }
             }
          }
+         std::cout << "lol" << std::endl;
+         return (true);
       }
 
-      std::vector<CLinearBuffer> CBufferList::getRequests(void)
+      void CBufferList::getRequests(std::vector<CLinearBuffer> & lbuffer)
       {
-         std::vector<CLinearBuffer> retvalue;
          for (StdSize i = 0; i < this->nbbuffer; i++)
-            retvalue.push_back(SuperClass::operator[](i).getNextRequest());
-         return (retvalue);
+            lbuffer.push_back(SuperClass::operator[](i).getNextRequest());
       }