|   | 1 | [wiki:WikiStart Orbit] > [wiki:OTG OTG] > [wiki:OTG/ScriptsRepository Scripts Repository] > otf.rb | 
          
          
            |   | 2 |  | 
          
          
            |   | 3 | {{{ | 
          
          
            |   | 4 |  | 
          
          
            |   | 5 | require 'handler/appDefinition' | 
          
          
            |   | 6 |  | 
          
          
            |   | 7 | a = AppDefinition.create('test:app:otf') | 
          
          
            |   | 8 | a.name = "otr" | 
          
          
            |   | 9 | a.version(0, 0, 2) | 
          
          
            |   | 10 | a.shortDescription = "Programmable traffic forwarder" | 
          
          
            |   | 11 | a.description = <<TEXT | 
          
          
            |   | 12 | otf is a configurable traffic forwarder. It re-route traffice from one | 
          
          
            |   | 13 | incoming interface to another one using raw sockets | 
          
          
            |   | 14 | TEXT | 
          
          
            |   | 15 |  | 
          
          
            |   | 16 | #addProperty(name, description, mnemonic, type, isDynamic = false, constraints = nil) | 
          
          
            |   | 17 | a.addProperty('protocol', 'Protocol to use [raw|raw_libmac]', nil, String, false) | 
          
          
            |   | 18 | a.addProperty('rxdev', 'incoming interface [eth0|eth2|eth3|ath0|ath1]', nil, String, false) | 
          
          
            |   | 19 | a.addProperty('txdev', 'outgoing interface [eth0|eth2|eth3|ath0|ath1]', nil, String, false) | 
          
          
            |   | 20 | a.addProperty('dstfilter', 'packet filter using destination IP address', nil, String, false) | 
          
          
            |   | 21 | a.addProperty('dstmacaddr', 'MAC address for next-hop', nil,String, false) | 
          
          
            |   | 22 |  | 
          
          
            |   | 23 | a.addMeasurement("senderport", nil, [ | 
          
          
            |   | 24 |     ['stream_no', 'int'], | 
          
          
            |   | 25 |     ['pkt_seqno', 'long'], | 
          
          
            |   | 26 |     ['pkt_size', 'long'], | 
          
          
            |   | 27 |     ['gen_timestamp', 'long'], | 
          
          
            |   | 28 |     ['tx_timestamp', 'long'] | 
          
          
            |   | 29 | ]) | 
          
          
            |   | 30 |  | 
          
          
            |   | 31 | a.addMeasurement("otfreceiver", nil, [ | 
          
          
            |   | 32 |   ['flow_no'],'int','id of receiving flow'], | 
          
          
            |   | 33 |   ['pkt_num_rcvd','long',' Packet Sequence id of the flow'], | 
          
          
            |   | 34 |   ['rcvd_pkt_size', 'long', 'Payload size'], | 
          
          
            |   | 35 |   ['rx_timestamp', 'long', 'Time when packet has been received'], | 
          
          
            |   | 36 |   ['rssi', 'int', 'rssi of received packet'] , | 
          
          
            |   | 37 |   ['xmit_rate','int','channel rate of received packet'] | 
          
          
            |   | 38 | ]) | 
          
          
            |   | 39 |  | 
          
          
            |   | 40 | a.path = "/usr/local/bin/otf" | 
          
          
            |   | 41 |  | 
          
          
            |   | 42 | if $0 == __FILE__ | 
          
          
            |   | 43 |   require 'stringio' | 
          
          
            |   | 44 |   require 'rexml/document' | 
          
          
            |   | 45 |   include REXML | 
          
          
            |   | 46 |  | 
          
          
            |   | 47 |   sio = StringIO.new() | 
          
          
            |   | 48 |   a.to_xml.write($stdout, 2) | 
          
          
            |   | 49 | end | 
          
          
            |   | 50 |  | 
          
          
            |   | 51 |  | 
          
          
            |   | 52 | }}} |