-require 'msg'
-require 'RubyProcess'
+# Debug it with this command:
+# make -C ../.. && valgrind ruby MasterSlave.rb --log=ruby.thres:debug 2>&1 | less
-def Master(*args)
-
- puts "Hey ..from Master"#info("Hey")
-
- slaves = Array.new()
-
+require 'simgrid'
+
+include MSG
+
+#################################################
+# Class Master
+#################################################
+
+class Master < MSG::Process
+ # 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
-
- puts "Args = " + size
-
for i in 0..size-1
- puts "argv :" + args[1]
+ MSG::info("args["+String(i)+"]="+args[i])
end
+
+ raise "Master needs 3 arguments" if size < 3
+ numberOfTask = Integer(args[0])
+ taskComputeSize = Float(args[1])
+ taskCommunicationSize = Float(args[2])
+ slaveCount = Integer(args[3])
- raise "Master needs 3 arguments" if size < 3
-
- numberOfTask = args[0] #convert to int
- taskComputeSize = args[1] #convert to double
- taskCommunicationSize = args[2] #convert to double
- slaveCount = args[3] #convert to int
-
-
-# todo = Array.new(numberOfTask)
-
- #Creating & Sending Task
- for i in 0..numberOfTask
-
- task = RbTask.new("Task_" + i.to_s, taskComputeSize , taskCommunicationSize );
- s_alias = "slave " + (i%slaveCount).to_s
- puts "Master Sending "+ RbTask.name(task) + " to " + s_alias
- RbTask.send(task,s_alias)
- puts "Master Done Sending " +RbTask.name(task) + " to " + s_alias
-
+ # Creates and sends the tasks
+ 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 "+ MSG::Task.name(task) + " to " + mailbox + " with Comput Size " +
+ MSG::Task.compSize(task).to_s)
+# task.compSize.to_s) # FIXME: This version creates a deadlock. Interesting
+ MSG::Task.send(task,mailbox)
+ MSG::info("Master Done Sending " +MSG::Task.name(task) + " to " + mailbox)
end
- # Sending Finalize Tasks
- puts "Master: All tasks have been dispatched. Let's tell everybody the computation is over."
+ # Sending Finalize MSG::Tasks
+ MSG::info("Master: All tasks have been dispatched. Let's tell everybody the computation is over.")
for i in 0..slaveCount-1
- s_alias = "slave " + i.to_s
- puts "Master Sending Finalize to " + s_alias
- RbTask.send(RbTask.new("finalize",0,0),s_alias)
+ mailbox = "slave " + i.to_s
+ MSG::info("Master Sending Finalize to " + mailbox)
+ MSG::Task.send(Task.new("finalize",0,0),mailbox)
end
-
- puts "Master : Everything's Done"
-
-
-
+ MSG::info("Master : Everything's Done")
+ end
end
+#################################################
+# Class Slave
+#################################################
+class Slave < MSG::Process
+ def main(args)
+ mailbox = "slave " + args[0]
-def Slave(*args)
-
- puts "Hello From Slave"
- s_mailbox = "slave" + args[0]
-
-
while true
-
- task = RbTask.recieve(s_mailbox)
-
- task_name = RbTask.name(task)
-
- if ( task_name == "finalize" )
- puts "Slave" + s_mailbox + "got finalize msg"
- break
- end
-
- puts "Slave " + s_mailbox + "Processing" + RbTask.name(task)
- RbTask.execute(task)
-
+ info("Ready to Receive Task")
+ task = MSG::Task.receive(mailbox)
+ task_name = MSG::Task.name(task)
+ MSG::info("Task Received : " + task.name)
+ if (task_name == "finalize")
+ MSG::info("Slave" + s_mailbox + "got finalize msg")
+ break
+ end
+ MSG::info("Slave " + s_mailbox + " ...Processing" + MSG::Task.name(task))
+ MSG::Task.execute(task)
end
-
- puts "Slave " + s_mailbox + "I'm Done , See You !!"
-
-
-end
\ No newline at end of file
+ MSG::info("Slave " + s_mailbox + "I'm Done , See You !!")
+ end
+end
+
+
+#################################################
+# main chunck
+#################################################
+
+if (ARGV.length == 2)
+ MSG.createEnvironment(ARGV[0])
+ MSG.deployApplication(ARGV[1])
+else
+ MSG.createEnvironment("platform.xml")
+ MSG.deployApplication("deploy.xml")
+ #Thread.list.each {|t| p t}
+end
+
+# Thread.list.each {|t| p t}
+MSG.run
+MSG.getClock #FIXME: write "puts MSG.getClock" instead
+# exit()
