module Trema
OpenFlow controller framework.
OpenFlow controller programming framework.
Base module.
Constants
- VERSION
gem version.
Public Class Methods
fetch(name, socket_dir)
click to toggle source
# File lib/trema/drb.rb, line 28 def self.fetch(name, socket_dir) trema_processes(socket_dir).each do |trema| begin return trema.fetch(name) rescue next end end raise %("#{name}" does not exist.) end
trema_process(controller_name, socket_dir)
click to toggle source
# File lib/trema/drb.rb, line 6 def self.trema_process(controller_name, socket_dir) Phut.socket_dir = socket_dir socket_path = File.join(Phut.socket_dir, "#{controller_name}.ctl") unless FileTest.socket?(socket_path) raise %(Controller process "#{controller_name}" does not exist.) end DRbObject.new_with_uri('drbunix:' + socket_path) end
trema_processes(socket_dir = Phut.socket_dir)
click to toggle source
# File lib/trema/drb.rb, line 15 def self.trema_processes(socket_dir = Phut.socket_dir) Phut.socket_dir = socket_dir all = Dir.glob(File.join(Phut.socket_dir, '*.ctl')) vhosts = Dir.glob(File.join(Phut.socket_dir, 'vhost.*.ctl')) (all - vhosts).map { |each| DRbObject.new_with_uri("drbunix:#{each}") } end
vhosts(socket_dir = Phut.socket_dir)
click to toggle source
# File lib/trema/drb.rb, line 22 def self.vhosts(socket_dir = Phut.socket_dir) Phut.socket_dir = socket_dir vhosts = Dir.glob(File.join(Phut.socket_dir, 'vhost.*.ctl')) vhosts.map { |each| DRbObject.new_with_uri("drbunix:#{each}") } end