a0f7039b27
git-svn-id: svn://scm.gforge.inria.fr/svnroot/paradiseo@609 331e1502-861f-0410-8da2-ba01fb791d7f
93 lines
1.6 KiB
C++
93 lines
1.6 KiB
C++
// "worker.cpp"
|
|
|
|
// (c) OPAC Team, LIFL, August 2005
|
|
|
|
/*
|
|
Contact: paradiseo-help@lists.gforge.inria.fr
|
|
*/
|
|
|
|
#include <vector>
|
|
|
|
#include "tags.h"
|
|
#include "send.h"
|
|
#include "node.h"
|
|
#include "schema.h"
|
|
#include "worker.h"
|
|
#include "mess.h"
|
|
#include "../../core/peo_debug.h"
|
|
|
|
static std :: vector <Worker *> key_to_worker (1); /* Vector of registered workers */
|
|
|
|
Worker * getWorker (WORKER_ID __key) {
|
|
|
|
return key_to_worker [__key];
|
|
}
|
|
|
|
Worker :: Worker () {
|
|
|
|
toto = false;
|
|
id = key_to_worker.size ();
|
|
key_to_worker.push_back (this);
|
|
}
|
|
|
|
void Worker :: packResult () {
|
|
|
|
pack (serv_id);
|
|
serv -> packResult ();
|
|
}
|
|
|
|
void Worker :: unpackData () {
|
|
|
|
printDebugMessage ("unpacking the ID. of the service.");
|
|
unpack (serv_id);
|
|
serv = getService (serv_id);
|
|
printDebugMessage ("found the service.");
|
|
serv -> unpackData ();
|
|
printDebugMessage ("unpacking the data.");
|
|
setActive ();
|
|
}
|
|
|
|
void Worker :: packTaskDone () {
|
|
|
|
pack (getNodeRank ());
|
|
pack (id);
|
|
}
|
|
|
|
void Worker :: notifySendingResult () {
|
|
|
|
/* Notifying the scheduler of the termination */
|
|
toto = true;
|
|
wakeUp ();
|
|
}
|
|
|
|
void Worker :: notifySendingTaskDone () {
|
|
|
|
setPassive ();
|
|
}
|
|
|
|
void Worker :: setSource (int __rank) {
|
|
|
|
src = __rank;
|
|
}
|
|
|
|
void Worker :: start () {
|
|
|
|
while (true) {
|
|
|
|
sleep ();
|
|
|
|
if (! atLeastOneActiveRunner ())
|
|
break;
|
|
|
|
if (toto) {
|
|
send (this, my_node -> rk_sched, TASK_DONE_TAG);
|
|
toto = false;
|
|
}
|
|
else {
|
|
|
|
printDebugMessage ("executing the task.");
|
|
serv -> execute ();
|
|
send (this, src, TASK_RESULT_TAG);
|
|
}
|
|
}
|
|
}
|