#################################################
class Master < MSG::Process
- # main : that function that will be executed when Running Simulation
+ # main : that function that will be executed when running simulation
def main(args) # args is an array containing arguments for function master
size = args.size
for i in 0..numberOfTask-1
task = MSG::Task.new("Task_"+ i.to_s, taskComputeSize , taskCommunicationSize);
mailbox = "slave " + (i%slaveCount).to_s
- MSG::info("Master Sending "+ task.name + " to " + mailbox + " with Comput Size " +
+ MSG::debug("Master Sending "+ task.name + " to " + mailbox + " with Comput Size " +
task.compSize.to_s)
task.send(mailbox)
- MSG::info("Master Done Sending " + task.name + " to " + mailbox)
+ MSG::debug("Master Done Sending " + task.name + " to " + mailbox)
end
# Sending Finalize MSG::Tasks
+ #MSG::info("Master: All "+numberOfTask+" tasks have been dispatched. Let's tell everybody the computation is over.")
MSG::info("Master: All tasks have been dispatched. Let's tell everybody the computation is over.")
for i in 0..slaveCount-1
mailbox = "slave " + i.to_s
- MSG::info("Master Sending Finalize to " + mailbox)
finalize_task = Task.new("finalize",0,0)
finalize_task.send(mailbox)
end
end
while true
- info("Ready to Receive Task")
task = MSG::Task.receive(mailbox)
- MSG::info("Task Received : " + task.name)
if (task.name == "finalize")
- MSG::info("Slave " + mailbox + " got finalize msg")
break
end
- MSG::info("Slave " + mailbox + " ...Processing" + task.name)
task.execute
- MSG::info("task "+ task.name + " Executed !!")
+ MSG::debug("Slave '" + mailbox + "' done executing task "+ task.name + ".")
end
- MSG::info("Slave " + mailbox + "I'm Done , See You !!")
+ MSG::info("I'm done, see you")
end
end
// Wrap Ruby Value to m_task_t struct
m_task_t tk;
Data_Get_Struct(task, s_m_task_t, tk);
- INFO1("Sending task %p",tk);
+ DEBUG1("Sending task %p",tk);
rv = MSG_task_send(tk,RSTRING(mailbox)->ptr);
if(rv != MSG_OK)
{
m_task_t *ptask = malloc(sizeof(m_task_t));
m_task_t task;
*ptask = NULL;
- INFO2("Receiving a task on mailbox '%s', store it into %p",RSTRING(mailbox)->ptr,&task);
+ DEBUG2("Receiving a task on mailbox '%s', store it into %p",RSTRING(mailbox)->ptr,&task);
MSG_task_receive(ptask,RSTRING(mailbox)->ptr);
task = *ptask;
free(ptask);