fix issue#28 to allow multiple trema switches to be started

ruby/trema/dsl/configuration.rb

@@ -89,6 +89,12 @@ class Configuration
       attr_reader :netnss
 
 
+      #
+      # holds all instances of configured trema switches
+      #
+      attr_reader :trema_switches
+
+
       #
       # Creates a new Trema configuration
       #
@@ -104,7 +110,7 @@ def initialize
         @links = Trema::Link.clear
         @packetin_filter = Trema::PacketinFilter.clear
         @switch_manager = Trema::SwitchManager.clear
-        @trema_switch = Trema::TremaSwitch.clear
+        @trema_switches = Trema::TremaSwitch.clear
         @switches = Trema::OpenflowSwitch.clear
         @netnss = Trema::Netns.clear
       end
@@ -134,11 +140,6 @@ def packetin_filter
       def switch_manager
         @switch_manager.values.last
       end
-
-
-      def trema_switch
-        @trema_switch.values.last
-      end
     end
   end
 end

ruby/trema/dsl/runner.rb

@@ -145,7 +145,9 @@ def maybe_run_netnss
 
 
       def maybe_run_trema_switch
-        @context.trema_switch.run! if @context.trema_switch
+        @context.trema_switches.each do | name, trema_switch |
+          trema_switch.run!
+        end
       end
 
 

ruby/trema/trema-switch.rb

@@ -53,7 +53,16 @@ def method_missing message, *args
 
     def command
       ports = @stanza[ :ports ]
-      ports = Trema::Link.instances.values.map.with_index { | each, i | "#{ each.name }/#{ i + 1 }"  }.join( ',' ) if @stanza[ :ports ].nil?
+      if @stanza[ :ports ].nil?
+        ports = []
+        # TODO refactor
+        Trema::Link.instances.values.map.with_index do | each, i |
+          if each.peers[ 0 ].split( ':' )[ 0 ] == @stanza[ :name ] || each.peers[ 1 ].split( ':' )[ 0 ] == @stanza[ :name ]
+            ports << "#{ each.name }/#{ i + 1 }"
+          end
+        end
+        ports = ports.join( ',' )
+      end
       "export TREMA_HOME=`pwd`; sudo -E #{ Executables.switch } -i #{ dpid_short } -e #{ ports } > #{ log_file } &"
     end
   end