Contents

require 'drb'
require 'phut'

# OpenFlow controller programming framework.
module Trema
  def self.trema_process(controller_name, socket_dir)
    Phut.socket_dir = socket_dir
    socket_path = File.join(Phut.socket_dir, "trema.#{controller_name}.ctl")
    unless FileTest.socket?(socket_path)
      fail %(Controller process "#{controller_name}" does not exist.)
    end
    DRbObject.new_with_uri('drbunix:' + socket_path)
  end

  def self.trema_processes(socket_dir = Phut.socket_dir)
    Phut.socket_dir = socket_dir
    Dir.glob(File.join Phut.socket_dir, 'trema.*.ctl').map do |each|
      DRbObject.new_with_uri('drbunix:' + each)
    end
  end

  def self.fetch(name, socket_dir)
    trema_processes(socket_dir).each do |trema|
      begin
        return trema.fetch(name)
      rescue
        next
      end
    end
    fail %("#{name}" does not exist.)
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
trema-0.9.0	lib/trema/drb.rb
trema-0.8.4	lib/trema/drb.rb
trema-0.8.3	lib/trema/drb.rb
trema-0.8.2	lib/trema/drb.rb
trema-0.8.1	lib/trema/drb.rb
trema-0.8.0	lib/trema/drb.rb
trema-0.7.1	lib/trema/drb.rb
trema-0.7.0	lib/trema/drb.rb
trema-0.6.0	lib/trema/drb.rb
trema-0.5.1	lib/trema/drb.rb
trema-0.5.0	lib/trema/drb.rb
trema-0.4.8	lib/trema/drb.rb