@@nextProcessId = 0
# Attributes
- attr_reader :bind, :id # Read only
- attr_accessor :name, :properties, :pargs # R/W
+ attr_reader :bind, :id ,:name # Read only
+ attr_accessor :properties, :pargs # R/W
-# Initialize : Used from ApplicationHandler to fill it in
- def initialize(*args)
- # FIXME: use only one variante (the one with 3 args) and kill the others
+
+ def initialize(*args)
+ super(){
+
+ raise "Bad Number Of arguments to create a a Ruby Process (name,args,prop) " if args.size < 3
+
@schedBegin = Semaphore.new(0)
@schedEnd = Semaphore.new(0)
- @properties = Hash.new()
- @id = @@nextProcessId++
+ #@properties = Hash.new()
+ @id = @@nextProcessId
+ @@nextProcessId += 1
+ @name = args[0]
+ @pargs = args[1]
+ @properties = args[2]
- argc = args.size
-
- if argc == 0 # Default initializer
- super() {
- @id = 0
- @bind = 0
- @name = ""
- @pargs = Array.new()
- start()
- MSG::debug "Initializer without any argument"
- }
-
- # 2 arguments: (HostName,Name) Or (Host , Name)
- elsif argc == 2
- super(){
- MSG::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)
+ start()
+
}
-
- # 3 arguments: (hostName,Name,args[]) or (Host,Name,args[])
- elsif argc == 3
- super(){
- MSG::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
@schedEnd.release
end
- def processList() (KILLME?)
- Thread.list.each {|t| p t}
- end
-
- #Get Own ID (KILLME?)
- def getID()
- return @id
- end
-
- #Get a Process ID (KILLME?)
- def processID(process)
- return process.id
- end
-
- #Get Own Name (KILLME?)
- def getName()
- return @name
- end
+
- #Get Bind (KILLME?)
+ #Get Bind ( Used > Native to Ruby)
def getBind()
return @bind
end
- #Get Binds (KILLME?)
+ #Get Binds (Used > Ruby to Native)
def setBind(bind)
@bind = bind
end
# The Rest of Methods !!! To be Continued ...
end
-#########################################################################
-# Class ApplicationHandler
-#########################################################################
-class ApplicationHandler
- def initialize()
- @hostName = nil
- @function = nil
- end
-
- def onBeginProcess(hostName,function)
- @args = Array.new
- @properties = Hash.new
-
- @hostName = hostName
- @function = function
-
- MSG::debug("onBeginProcess("+hostName+","+function+")")
- end
-
- def onProperty(id,value)
- @properties[id] = value
- end
-
- def onProcessArg(arg)
- @args.push(arg)
- end
-
- def onEndProcess()
- # must be in C, called from a callback to the FlexML parser
- # newInstance must take args and hostname as argument to initialize everything, *and* bind it to C element
- # Allows to mark all attributes of process (but properties) to read-only
- process = MSG::rubyNewInstance(@function)
- process.pargs = @args
- process.name = @function
- host = MSG::Host.getByName(@hostName)
- MSG::processCreate(process,host)
- process.properties = @properties
- end
-end
-
#########################
# Main chunck
#########################
