#include "xios.hpp"
#include "attribute_template.hpp"
#include "buffer_out.hpp"
#include "buffer_in.hpp"
#include "type.hpp"
#include "cxios.hpp"
#include "client.hpp"
#include "event_client.hpp"
#include "context.hpp"
#include "context_client.hpp"
#include "context_server.hpp"
#include "object_template.hpp"
#include "array_new.hpp"
#include "mpi.hpp"


using namespace std ;

int main (int argc, char ** argv, char ** UNUSED (env))
{
  
  int a=3 ;
  int b=2 ;
  int c=1 ;
  int buff[100] ;
  string str("titi") ;
   CBufferOut bufferOut(&buff,sizeof(buff)) ;
   CBufferIn  bufferIn(&buff,sizeof(buff)) ;
   CMessage msg ;

   CAttributeArray<double,1> tabIn("in") ;
   CAttributeArray<double,1> tabOut("out") ;

   CArray<double,1> tab(5)
    tab=0,1,2,3,4 ;
    tabIn=tab ;
    tab= 4,3,2,1,0
    tabOut=tab ;
//   tabOut=1 ;
   tabIn.toBuffer(bufferOut) ;
   tabOut.fromBuffer(bufferIn) ;
   
   cout<<"attribut<Arraydouble,5>>="<<tabOut.toString()<<endl ;
   
   MPI_Init(&argc,&argv) ;
   int rank ;
   int size ;
   char buffer[128] ;
   
   MPI_Comm_rank(MPI_COMM_WORLD,&rank) ;
   if (rank>=0 && rank<=1) 
   {
     CXios::initClientSide("test1") ;
     CClient::registerContext("toto",CClient::intraComm) ;
//     CClient::registerContext("tata",CClient::intraComm) ;
     CClient::registerContext("tutu",CClient::intraComm) ;
     CContext::setCurrent("tutu") ;
     CContext*  tutu=CContext::get("tutu").get() ; 
     
     
     CContext::setCurrent("toto") ;
     CContext*  toto=(CContext::get("toto").get() ;
     toto->calendar_type.setValue("NoLeap") ;
     toto->sendAttributToServer("calendar_type" );


       for(int i=0;i<0;i++)
       {
         CMessage msg ;
         int count ;
         int msgSize; 
         CEventClient event(1,1) ;
         count=rand()%32 ;
         msg<<string("toto")<<string(buffer,count)<<rank<<msgSize;
         msgSize=msg.size() ;
         event.push(0,2,msg) ;
         event.push(1,2,msg) ;
         toto->client->sendEvent(event) ;
         cout<<"Send Event from toto : size "<<msgSize<<endl ;
       }
     toto->client->finalize() ;
     tutu->client->finalize() ;
     CXios::clientFinalize() ;
   }
   else if (rank>=2 && rank<=3) CXios::initServerSide();
   else if (rank>=4 && rank<=6) 
   {
     CXios::initClientSide("test2") ;
     CClient::registerContext("tito",CClient::intraComm) ;
     CContext::setCurrent("tito") ;
     CContext*  tito=CContext::get("tito").get() ;
      
     CClient::registerContext("tete",CClient::intraComm) ;
     CContext::setCurrent("tete") ;
     CContext*  tete=CContext::get("tete").get() ; 

     tito->client->finalize() ;
     tete->client->finalize() ;
     CXios::clientFinalize() ;
   } 
   else if (rank>=7 && rank<=7) 
   {
     CXios::initClientSide("test3") ;
     CClient::registerContext("turlututu",CClient::intraComm) ;
     CContext::setCurrent("turlututu") ;
     CContext*  turlututu=CContext::get("turlututu").get() ; 
     turlututu->client->finalize() ;
     CXios::clientFinalize() ;
   }
   
   
  
   MPI_Barrier(MPI_COMM_WORLD); 
   MPI_Finalize() ;

  return EXIT_SUCCESS ;
 
}