Changeset 178 for XMLIO_V2/dev/dev_rv/src/xmlio/buffer_pair.hpp

Timestamp:

04/18/11 14:56:41 (13 years ago)

Author:

hozdoba

Message:

 

File:

• XMLIO_V2/dev/dev_rv/src/xmlio/buffer_pair.hpp (modified) (2 diffs)

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

@@ -15 +15 @@
       /// ////////////////////// Déclarations ////////////////////// ///
       class CBufferPair
-         : public std::pair<CLinearBuffer, CLinearBuffer>   // << pas une liste
       {
 
             /// Définition de type ///
-            typedef std::pair<CLinearBuffer, CLinearBuffer> SuperClass;
             typedef CLinearBuffer BufferType;
 
@@ -29 +27 @@
             CBufferPair(const CBufferPair * const buffer_pair); // Not implemented yet.
 
+            template <typename A1, typename A2, typename A3, typename A4>
+               void prepareRequest(const long int & managerId,
+                                   const long int & methodId,
+                                   A1 * arg1 = CLinearBuffer::NULL_ARG,
+                                   A2 * arg2 = CLinearBuffer::NULL_ARG,
+                                   A3 * arg3 = CLinearBuffer::NULL_ARG,
+                                   A4 * arg4 = CLinearBuffer::NULL_ARG);
+                                  
             /// Destructeur ///
             virtual ~CBufferPair(void);
+            
+         protected :
+            
+            /// Test ///
+            bool mustBeSent(void);
+            
+            /// Traitements divers ///
+            void wait(void);
+            void sendCurrentBuffer(void);
+            
+            /// Accesseur ///    
+            CLinearBuffer & getCurrentBuffer(void);
 
          private :
 
             MPIComm com_client_server;
+            CLinearBuffer first, second;
+            MPIRequest first_request, second_request;
+            int currentBuffer;
 
       }; // class CBufferPair
+      
+      ///--------------------------------------------------------------
+      
+      template <typename A1, typename A2, typename A3, typename A4>
+         void CBufferPair::prepareRequest(const long int & managerId,
+                                          const long int & methodId,
+                                          A1 * arg1, A2 * arg2, A3 * arg3, A4 * arg4)
+      {
+         if (this->mustBeSent()) this->sendCurrentBuffer();       
+           
+         CLinearBuffer & cbuffer = this->getCurrentBuffer();
+         StdSize usize = cbuffer.getUnusedSize();         
+         StdSize rsize = cbuffer.getRequestedSize(arg1, arg2, arg3, arg4) ;
+         StdSize msize = cbuffer.getSize();
+         
+         long int nbargs = 0;
+         
+         if (arg1 != CLinearBuffer::NULL_ARG) nbargs++;
+         if (arg2 != CLinearBuffer::NULL_ARG) nbargs++;
+         if (arg3 != CLinearBuffer::NULL_ARG) nbargs++;
+         if (arg4 != CLinearBuffer::NULL_ARG) nbargs++;
+         
+         if (rsize > msize)
+            ERROR("CBufferPair::sendRequest(...)", << "Le tampon client est trop petit !");
+                  
+         if (rsize <= usize)
+         {
+            cbuffer.appendRequestInfos(managerId, methodId, nbargs);        
+         }
+         else
+         {
+            this->wait();
+            this->prepareRequest(managerId, methodId, arg1, arg2, arg3, arg4);
+         }
+      }
+      
+      ///--------------------------------------------------------------
+      
+      
    } // namespace comm
 } // namespace xmlioserver