src/examples/dumper/dumper.rb in trema-0.4.6 vs src/examples/dumper/dumper.rb in trema-0.4.7

@@ -18,43 +18,43 @@
 
 #
 # Openflow message event dumper.
 #
 class Dumper < Controller
-  def switch_ready datapath_id
-    info "[switch_ready]"
+  def switch_ready(datapath_id)
+    info '[switch_ready]'
     info "  datapath_id: #{ datapath_id.to_hex }"
   end
 
 
-  def switch_disconnected datapath_id
-    info "[switch_disconnected]"
+  def switch_disconnected(datapath_id)
+    info '[switch_disconnected]'
     info "  datapath_id: #{ datapath_id.to_hex }"
   end
 
 
-  def openflow_error datapath_id, message
-    info "[error]"
+  def openflow_error(datapath_id, message)
+    info '[error]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "type: #{ message.type.to_hex }"
     info "code: #{ message.code.to_hex }"
     info "data: #{ message.data.unpack "H*" }"
   end
 
 
-  def vendor datapath_id, message
-    info "[vendor]"
+  def vendor(datapath_id, message)
+    info '[vendor]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
-    info "data:"
+    info 'data:'
     info "#{ message.buffer.unpack "H*" }"
   end
 
 
-  def features_reply datapath_id, message
-    info "[features_reply]"
+  def features_reply(datapath_id, message)
+    info '[features_reply]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "n_buffers: #{ message.n_buffers }"
     info "n_tables: #{ message.n_tables }"
     info "capabilities: #{ message.capabilities.to_hex }"
@@ -63,37 +63,37 @@
       dump_phy_port each
     end
   end
 
 
-  def get_config_reply datapath_id, message
-    info "[get_config_reply]"
+  def get_config_reply(datapath_id, message)
+    info '[get_config_reply]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "flags: #{ message.flags.to_hex }"
     info "miss_send_len: #{ message.miss_send_len }"
   end
 
 
-  def packet_in datapath_id, message
-    info "[packet_in]"
+  def packet_in(datapath_id, message)
+    info '[packet_in]'
     info "  datapath_id: #{ datapath_id.to_hex }"
     info "  transaction_id: #{ message.transaction_id.to_hex }"
     info "  buffer_id: #{ message.buffer_id.to_hex }"
     info "  total_len: #{ message.total_len }"
     info "  in_port: #{ message.in_port }"
     info "  reason: #{ message.reason.to_hex }"
     info "  data: #{ message.data.unpack "H*" }"
   end
 
 
-  def flow_removed datapath_id, message
-    info "[flow_removed]"
+  def flow_removed(datapath_id, message)
+    info '[flow_removed]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
 
-    info "match:"
+    info 'match:'
     info "  wildcards: #{ message.match.wildcards.to_hex }"
     info "  in_port: #{ message.match.in_port }"
     info "  dl_src: #{ message.match.dl_src }"
     info "  dl_dst: #{ message.match.dl_dst }"
     info "  dl_vlan: #{ message.match.dl_vlan }"
@@ -115,52 +115,52 @@
     info "packet_count: #{ message.packet_count.to_hex }"
     info "byte_count: #{ message.byte_count.to_hex }"
   end
 
 
-  def port_status datapath_id, message
-    info "[port_status]"
+  def port_status(datapath_id, message)
+    info '[port_status]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "reason: #{ message.reason.to_hex }"
     dump_phy_port message.phy_port
   end
 
 
-  def stats_reply datapath_id, message
-    info "[stats_reply]"
+  def stats_reply(datapath_id, message)
+    info '[stats_reply]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "type: #{ message.type.to_hex }"
     info "flags: #{ message.flags.to_hex }"
     message.stats.each { | each | info each.to_s }
   end
 
 
-  def barrier_reply datapath_id, message
-    info "[barrier_reply]"
+  def barrier_reply(datapath_id, message)
+    info '[barrier_reply]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
   end
 
 
-  def queue_get_config_reply datapath_id, message
-    info "[queue_get_config_reply]"
+  def queue_get_config_reply(datapath_id, message)
+    info '[queue_get_config_reply]'
     info "datapath_id: #{ datapath_id.to_hex }"
     info "transaction_id: #{ message.transaction_id.to_hex }"
     info "port: #{ message.port }"
-    info( "queues:" );
+    info('queues:');
     dump_packet_queue message.queues
   end
 
 
   ##############################################################################
   private
   ##############################################################################
 
 
-  def dump_phy_port port
+  def dump_phy_port(port)
     # for testing port-status record the mac address if port.number == 2.
     @hw_addr = port.hw_addr if port.number == 2
     info "port_no: #{ port.number }"
     info "  hw_addr: #{ port.hw_addr }"
     info "  name: #{ port.name }"
@@ -171,18 +171,18 @@
     info "  supported: #{ port.supported.to_hex }"
     info "  peer: #{ port.peer.to_hex }"
   end
 
 
-  def dump_packet_queue queues
+  def dump_packet_queue(queues)
     queues.each do | packet_queue |
       info "queue_id: #{ packet_queue.queue_id.to_hex }"
       info "  len: #{ packet_queue.len }"
-      info "  properties:"
+      info '  properties:'
       packet_queue.properties.each do | prop |
         info "    property: #{ prop.property.to_hex }"
         info "    len: #{ prop.len.to_hex }"
-        info "      rate: %u" % prop.rate if prop.property == PacketQueue::OFPQT_MIN_RATE
+        info '      rate: %u' % prop.rate if prop.property == PacketQueue::OFPQT_MIN_RATE
       end
     end
   end
 end