Contents

module Pione
  module Command
    # PioneTupleSpaceReceiver is a command that launchs tuple space receiver
    # agent.
    class PioneTupleSpaceReceiver < ChildProcess
      define_info do
        set_name "pione-tuple-space-receiver"
        set_tail {|cmd|
          front = Global.front.uri
          parent_front = cmd.option[:no_parent_mode] ? "nil" : cmd.option[:parent_front].uri
          "{Front: %s, ParentFront: %s}" % [front, parent_front]
        }
        set_banner <<TXT
Run 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
      end

      define_option do
        use Option::PresenceNotifierOption

        option("--presence-port=PORT", "set presence port number") do |data, port|
          Global.presence_port = port.to_i
        end
      end

      attr_reader :tuple_space_receiver

      def create_front
        Front::TupleSpaceReceiverFront.new(self)
      end

      prepare do
        @tuple_space_receiver = TupleSpaceReceiver.new
      end

      start do
        begin
          # start provider activity
          @tuple_space_receiver.start

          # set my uri to parent front as its provider
          unless option[:no_parent_mode]
            option[:parent_front].set_tuple_space_receiver(Global.front.uri)
          end

          # wait
          DRb.thread.join
        rescue DRb::ReplyReaderThreadError => e
          # ignore reply reader error
        end
      end

      terminate do
        Global.monitor.synchronize do
          @tuple_space_receiver.terminate
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
pione-0.2.0	lib/pione/command/pione-tuple-space-receiver.rb
pione-0.1.4	lib/pione/command/pione-tuple-space-receiver.rb
pione-0.1.3	lib/pione/command/pione-tuple-space-receiver.rb