require 'thread'
#######################################
-# Semaphore
+# Semaphore
#######################################
class Semaphore
@name = args[0]
@pargs = args[1]
@properties = args[2]
-
start()
}
end
end
def start()
- @schedBegin.acquire
+ @schedBegin.acquire
MSG::debug("Let's execute the main() of the Ruby process")
main(@pargs)
@schedEnd.release
processGetHost(self)
end
-# The Rest of Methods !!! To be Continued ... FIXME: what's missing?
end
############################################
# Task Extend from the native Class RbTask
############################################
class MSG::Task < MSG::RbTask
-
+
def initialize(*args)
- super()
+ #Nothing todo
+ end
+
+ def join(value)
+ super(self,value)
+ end
+
+ def data()
+ super(self)
end
def name
- super(self)
+ super(self)
end
def compSize
- super(self)
+ super(self)
end
def send(mailbox)
- super(self,mailbox)
+ super(self,mailbox)
+ end
+
+ def receive(mailbox)
+ super(self)
end
def source
end
def listen(t_alias)
- super(t_alias)
+ super(self)
end
def execute
end
def listenFromHost(t_alias,host)
- super(t_alias,host)
+ super(self)
+ end
+
+ def setPriority(priority)
+ super(self,priority)
+ end
+
+ def cancel
+ super(self)
end
+
+ def hasData
+ super(self)
+ end
+
end
+
####################################################
# Host Extend from the native Class RbHost
####################################################
class MSG::Host < MSG::RbHost
+
+ attr_reader :data
+ def initialize(*ars)
+ @data = 1
+ p "Host Initializer"
+ end
+
+ def data()
+ return @data
+ end
+
+ def setData(value)
+ @data = value
+ end
+
def getByName(name)
super(name)
end
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)
\ No newline at end of file
+MSG.init(ARGV)