Sha256: 969e58a9c2687998baacedc6e6669d714de93031ebd96f6880607ab7eba1df6a
Contents?: true
Size: 1.39 KB
Versions: 2
Compression:
Stored size: 1.39 KB
Contents
module Pione module Command class PioneTupleSpaceReceiver < ChildProcess set_program_name("pione-tuple-space-receiver") do parent_front = @no_parent_mode ? "nil" : @parent_front.uri "<front=%s, parent=%s>" % [Global.front.uri, parent_front] end set_program_message <<TXT Runs tuple space receiver process for receiving tuple space presence notifier. This command is launched by other processes like pione-broker normally, but you can force to start by calling with --no-parent option. TXT use_option_module CommandOption::TupleSpaceReceiverOption attr_reader :tuple_space_receiver def create_front Front::TupleSpaceReceiverFront.new(self) end def prepare super @tuple_space_receiver = TupleSpaceReceiver.new end def start super # start provider activity @tuple_space_receiver.start # set my uri to parent front as its provider unless @no_parent_mode @parent_front.set_tuple_space_receiver(Global.front.uri) end # wait DRb.thread.join rescue DRb::ReplyReaderThreadError => e # ignore reply reader error end def terminate puts "terminate %s" % program_name begin @tuple_space_receiver.terminate rescue DRb::DRbConnError end super end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
pione-0.1.1 | lib/pione/command/pione-tuple-space-receiver.rb |
pione-0.1.0 | lib/pione/command/pione-tuple-space-receiver.rb |