PARALLEL OBJECT PROGRAMMING IN C++ (POP-C++) : DEMO

////// Fichier POPCobject.ph
#ifndef POPCOBJECT_PH_
#define POPCOBJECT_PH_

#include <timer.h>

parclass POPCobject
{
  classuid(1500);

  public:
    POPCobject(int newID, int wanted, int minp) @{od.power(wanted, minp);};
    POPCobject(int newID, paroc_string machine) @{od.url(machine);};
    ~POPCobject();
    
    async seq void sendIDto([in] POPCobject &o);
    sync conc int getID();
    async conc void recAnID(int i);
    sync mutex void wait(int sec);
  
  private:
    int iD;
    Timer timer;
    double initTime, computeTime;
    
};

#endif /*POPCOBJECT_PH_*/

////// Fichier POPCobject.cc

#include "POPCobject.ph"
#include <unistd.h>

POPCobject::POPCobject(int newID, int wanted, int minp)
{
  printf("POPCobject with ID=%d created (by JobMgr) on machine:%s\n", newID, (const char*)paroc_system::GetHost()); 
  iD=newID;
}

POPCobject::POPCobject(int newID, paroc_string machine)
{
  printf("POPCobject with ID=%d created on machine:%s\n", newID, (const char*)paroc_system::GetHost()); 
  iD=newID;
}

POPCobject::~POPCobject()
{
  printf("POPCobject:%d on machine:%s is being destroyed\n", iD, (const char*)paroc_system::GetHost()); 
  iD=-1;
}

void POPCobject::sendIDto(POPCobject &o)
{
  printf("POPCobject:%d on machine:%s is sending his iD to object:%d\n", iD, (const char*)paroc_system::GetHost(), o.getID()); 
  o.recAnID(iD);
}

int  POPCobject::getID()
{
  return iD;
}

void POPCobject::recAnID(int i)
{
  printf("POPCobject:%d on machine:%s is receiving id = %d\n", iD, (const char*)paroc_system::GetHost(), i);   
}

void POPCobject::wait(int sec)
{
  printf("POPCobject:%d on machine:%s is waiting %d sec.\n", iD, (const char*)paroc_system::GetHost(), sec);
  sleep(sec);
}

@pack(POPCobject);

////// Fichier main.cc
#include "POPCobject.ph"

int main(int argc, char** argv)

{
  if (argc<2)
  {
    printf("Usage: parocrun objmap %s NbObjects machine1, machine2, .... \n", argv[0]);
    return 0;
  }
  else
  {
    int nbObjects = atoi(argv[1]);
    POPCobject** objects=new POPCobject*[nbObjects]; 

    printf("\nSTART of %s program with %d objects\n", argv[0], nbObjects);

    for (int i = 0; i<argc-2; i++){ 
	  if(argv[i+2][0]=='-'){
		// objects created by job manager
		objects[i]=new POPCobject(i+1, 60, 40);	
	  }
	  else
	  {
		// objects created on a given hostname
		objects[i]=new POPCobject(i+1, argv[i+2]);
	  }
	}
    // The rest is created using hostname=localhost
    for (int i = argc-2; i<nbObjects; i++) objects[i]=new POPCobject(i+1, (paroc_string)("localhost"));
	    
    // Send IDs to each other
    for (int i=0; i<(nbObjects-1); i++) objects[i]->sendIDto(*(objects[i+1]));
    objects[nbObjects-1]->sendIDto(*(objects[0]));
    objects[nbObjects-1]->wait(2);
    for (int i=0; i<nbObjects; i++) delete objects[i];
    delete objects;
  }
  printf("\nEND of %s program\n", argv[0]);
  return 0;
}