X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8e5967203f4ea512a321daeb1dafb5eac209d69a..7bcd4cc9d936caa1d23579f7aca67e68fade2a36:/src/bindings/ruby/simgrid.rb diff --git a/src/bindings/ruby/simgrid.rb b/src/bindings/ruby/simgrid.rb index b3cc65be9b..c618f33a61 100644 --- a/src/bindings/ruby/simgrid.rb +++ b/src/bindings/ruby/simgrid.rb @@ -1,12 +1,16 @@ +# Task-related bindings to ruby */ +# +# Copyright 2010. The SimGrid Team. All right reserved. */ +# +# This program is free software; you can redistribute it and/or modify it +# under the terms of the license (GNU LGPL) which comes with this package. */ +# # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # # require 'simgrid_ruby' -include MSG require 'thread' -$DEBUG = false # This is a Global Variable Useful for Debugging - -########################################################################### -# Class Semaphore -########################################################################### +####################################### +# Semaphore +####################################### class Semaphore def initialize(initvalue = 0) @@ -17,8 +21,11 @@ class Semaphore def acquire Thread.critical = true if (@counter -= 1) < 0 + MSG::debug(Thread.current.to_s+" acquires "+self.to_s+". That's blocking.") @waiting_list.push(Thread.current) Thread.stop + else + MSG::debug(Thread.current.to_s+" acquires "+self.to_s+". It was free.") end self ensure @@ -29,8 +36,11 @@ class Semaphore Thread.critical = true begin if (@counter += 1) <= 0 - t = @waiting_list.shift - t.wakeup if t + t = @waiting_list.shift + t.wakeup if t + MSG::debug(Thread.current.to_s+" releases "+self.to_s+". Wakeup "+t.to_s) + else + MSG::debug(Thread.current.to_s+" releases "+self.to_s+". Nobody to wakeup") end rescue ThreadError retry @@ -44,132 +54,47 @@ end ######################################################################## # Class Process ######################################################################## -class MsgProcess < Thread +class MSG::Process < Thread @@nextProcessId = 0 # Attributes - attr_reader :bind, :id, :pargs # Read only - attr_accessor :name, :properties # R/W + attr_reader :name, :pargs ,:properties # Read only -# Initialize : Used from ApplicationHandler to fill it in - def initialize(*args) + def initialize(*args) + super(){ + + raise "Bad number of arguments to create a Ruby process. Expected (name,args,prop) " if args.size < 3 + @schedBegin = Semaphore.new(0) @schedEnd = Semaphore.new(0) - @properties = Hash.new() - @id = @@nextProcessId++ - - argc = args.size - - if argc == 0 # Default initializer - super() { - @id = 0 - @bind = 0 - @name = "" - @pargs = Array.new() - start() - debug "Initializer without any argument" - } - - # 2 arguments: (HostName,Name) Or (Host , Name) - elsif argc == 2 - super(){ - debug "Initilize with 2 args" - type = args[0].type() - if ( type.to_s == "String") - host = Host.getByName(args[0]) - elsif ( type.to_s == "MSG::Host") - host = args[0] - else - raise "first argument of type "+args[0].type().to_s+", but expecting either String or MSG::Host" - end - if $DEBUG - puts host - end - raise "Process name cannot be null" if args[1].empty? - @name = args[1] - if $DEBUG - puts @name - end - @pargs = Array.new() # No Args[] Passed in Arguments - start() - createProcess(self,host) + @id = @@nextProcessId + @@nextProcessId +=1 + @name = args[0] + @pargs = args[1] + @properties = args[2] + start() } - - # 3 arguments: (hostName,Name,args[]) or (Host,Name,args[]) - elsif argc == 3 - super(){ - debug "Initilize with 3 args" - type = args[0].type() - if ( type.to_s == "String") - host = Host.getByName(args[0]) - elsif ( type.to_s == "MSG::Host") - host = args[0] - else - raise "first argument of type "+args[0].type().to_s+", but expecting either String or MSG::Host" - end - if $DEBUG - puts host - end - - raise "Process name cannot be null" if args[1].empty? - @name = args[1] - type = args[2].type() - raise "Third argument should be an Array" if type != "Array" - @pargs = args[3] - createProcess(self,host) - - } - else - raise "Bad number of argument: Expecting either 1, 2 or 3, but got "+argc.to_s - end end - - # main + def main(args) # To be overriden by childs raise("You must define a main() function in your process, containing the code of this process") end - # Start : To keep the process alive and waiting via semaphore def start() - @schedBegin.acquire - # execute the main code of the process - debug("Begin execution") + @schedBegin.acquire + MSG::debug("Let's execute the main() of the Ruby process") main(@pargs) - processExit(self) # Exit the Native Process @schedEnd.release - end + MSG::debug("Released my schedEnd, bailing out") + processExit(self) # Exit the Native Process - def processList() - Thread.list.each {|t| p t} - end - - #Get Own ID - def getID() - return @id - end - - #Get a Process ID - def processID(process) - return process.id - end - - #Get Own Name - def getName() - return @name end - - #Get a Process Name - def processName(process) - return process.name - end - - #Get Bind + def getBind() return @bind end - - #Get Binds + def setBind(bind) @bind = bind end @@ -179,78 +104,125 @@ class MsgProcess < Thread @schedBegin.acquire end - def schedule() + def schedule() @schedBegin.release @schedEnd.acquire end - #C Simualator Process Equivalent Management - # After Binding Ruby Process to C Process - -# pause def pause() processSuspend(self) end -# restart def restart() processResume(self) end -# isSuspended def isSuspended() processIsSuspended(self) end -# getHost def getHost() processGetHost(self) end - -# The Rest of Methods !!! To be Continued ... + +# The Rest of Methods !!! To be Continued ... FIXME: what's missing? end +############################################ +# Task Extend from the native Class RbTask +############################################ +class MSG::Task < MSG::RbTask -######################################################################### -# Class ApplicationHandler -######################################################################### -class ApplicationHandler - def initialize() - @hostName = nil - @function = nil + def initialize(*args) + super() + end + + def setData(value) + super(self,value) + end + + def data() + super(self) + end + + def name + super(self) + end + + def compSize + super(self) + end + + def send(mailbox) + super(self,mailbox) + end + + def source + super(self) end - def onBeginProcess(hostName,function) - @args = Array.new - @properties = Hash.new + def sender + super(self) + end + + def listen(t_alias) + super(t_alias) + end + + def execute + super(self) + end - @hostName = hostName - @function = function - - debug("onBeginProcess("+hostName+","+function+")") + def listenFromHost(t_alias,host) + super(t_alias,host) end - - def onProperty(id,value) - @properties[id] = value + + def setPriority(priority) + super(self,priority) end - def onProcessArg(arg) - @args.push(arg) + def cancel() + super(self) end - - def onEndProcess() - process = rubyNewInstance(@function) - size = @args.size - for i in 0..size-1 - process.pargs.push(@args[i]) - end - process.name = @function - host = Host.getByName(@hostName) - processCreate(process,host) - process.properties = @properties + +end +#################################################### +# Host Extend from the native Class RbHost +#################################################### +class MSG::Host < MSG::RbHost + def getByName(name) + super(name) end + + def name + super(self) + end + + def speed + super(self) + end + + def getData + super(self) + end + + def setData(data) + super(self,data) + end + + def isAvail + super(self) + end + + def number + super() + end + + def getHostProcess(process) + super(process) + end + end - ######################### # Main chunck ######################### -MSG.init(ARGV) +MSG.init(ARGV) \ No newline at end of file