updated
diff --git a/Detailed_Testing_Methodology.txt b/Detailed_Testing_Methodology.txt
new file mode 100644
index 0000000..ceb723a
--- /dev/null
+++ b/Detailed_Testing_Methodology.txt
@@ -0,0 +1,804 @@
+******Conformance Test-suite**************************
+OF-Switch-1.0.0-TestCases detailed testing methodology
+
+
+##### Openflow protocol messages ######################
+
+1. Features Request
+
+Test Description: Check features request is implemented
+Test mode: Automated
+Test Title: features_request
+Ports: I (Control Plane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_FEATURES_REQUEST from controller.
+c) Verify OFPT_FEATURES_REPLY is received without errors
+
+
+2. Configuration request
+
+Test Description: Check basic get configuration request is implemented
+Test mode: Automated
+Test Title: configuration_request
+Ports: I (Control Plane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_GET_CONFIG_REQUEST
+c) Verify OFPT_GET_CONFIG_REPLY is received without errors.
+
+
+3. Modify State (ADD)
+
+Test Description: Check basic Flow ADD request is implemented
+Test mode: Automated
+Test Title: modify_state_add
+Ports: 3 (1 Control Plane 2 dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_FLOW_MOD, command = OFPFC_ADD
+b) Send ofp_table_stats request
+c) Verify that active_count=1 in the reply
+
+4. Modify State (DELETE)
+
+Test Description: Check basic Flow Delete request is implemented
+Test mode: Automated
+Test Title: modify_state_delete
+Ports: 3 (1 Control Plane 2 dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_FLOW_MOD, command = OFPFC_ADD
+b) Send ofp_table_stats request
+c) Verify that active_count=1 in the reply
+d) Send OFPT_FLOW_MOD, command = OFPFC_DELETE
+e) Send ofp_table_stats request
+f) Verify active _count=0 in the reply
+
+5. Modify State (MODIFY)
+
+Test Description: Check basic Flow Modify request is implemented
+Test mode: Automated
+Test Title: modify_state_modify
+Ports: 3 (1 Control Plane and 2 Dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_FLOW_MOD , command = OFPFC_ADD, action A
+b) Send ofp_table_stats request, Verify active_count=1
+c) Send OFPT_FLOW_MOD , command = OFPFC_MODIFY, action A
+d) Send Test Packet matching the flow
+e) Verify packet implements action A
+
+
+
+6. Read State
+
+Test Description: Check basic Read State is implemented
+Test mode: Automated
+Test Title: read_state
+Ports: 3 (1 Control Plane, 2 dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_FLOW_MOD, command = OFPFC_ADD
+b) Create a OFPC_FLOW_STATS message and send it
+c) Verify switch replies without errors
+
+7. Send packet
+
+Test Description: Check basic Send-Packet is implemented.
+Send-Packet: These are used by the controller to send packets out of a specified port on the switch.
+Test mode: Automated
+Test Title: send_packet
+Ports: 5 (1 Control Plane, 4 Dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+
+Test Notes:
+a) Send OFPT_PACKET_OUT out message from controller to switch for every dataplane port.
+b) Verify the packet appears on the each dataplane port
+c) Verify sent packet matches the received packet
+
+8. Barrier Request
+
+Test Description: This test checks that a basic barrier request does not generate an error.
+Test mode: Automated
+Test Title: barrier_request_reply
+Ports: I (Control Plane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Send OFPT_BARRIER_REQUEST
+c) Verify OFPT_BARRIER_REPLY is received on the control plane.
+
+
+9. Packet In
+
+Test Description: Check packet_in is implemented. This test just checks that non matched dataplane packets generate a packet_in
+Test mode: Automated
+Test Title: packet_In
+Ports: 2 (1 Control Plane and 1 Dataplane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send a packet to dataplane port , without inserting a flow entry
+b) Verify a OFPT_PACKET_IN is generated on the control plane
+
+
+10. Hello
+
+Test Description: This test checks for basic Hello message generation with correct version field.
+Test mode: Automated
+Test Title: hello
+Ports: 1 (Control Plane)
+Initial State: Default (Clear switch state), Connection Setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_HELLO from controller to switch
+b) Verify switch also sends OFPT_HELLO message in response
+c) Verify version field in the hello message is set to Openflow version 1.0.0
+
+11. Echo
+
+Test Description: This test checks for basic Echo Reply message generation with correct version field with same transaction id.
+Test mode: Automated
+Test Title: echo_without_body
+Ports: 1 (Control Plane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send OFPT_ECHO_REQUEST from the controller side.
+b) Verify switch responds back with OFPT_ECHO_REPLY with same xid.
+c) Verify Openflow version in header is set to Openflow version 1.0.0.
+
+
+
+############# Detailed controller to switch messages ##################################
+
+1. Overlap checking
+
+Test Description: Verify that if overlap check flag is set in the flow entry and an overlapping flow is inserted then an error is generated and switch refuses flow entry
+Test mode: Automated
+Test Title: overlap_checking
+Ports: 3 (1 Control Plane 2 dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Generate Flow F1--> Wildcard All
+b) Send ofp_table_stats request , verify active_count=1
+c) Generate overlapping flow F2 --> Wildcard All Except Ingress Port ( with flag OFPFF_CHECK_OVERLAP set)
+d) Verify that switch generates OFPT_ERROR msg.
+Type: OFPET_FLOW_MOD_FAILED code : OFPFMFC_OVERLAP
+
+2. No overlap checking
+
+Test Description: Verify that without overlap check flag set, overlapping flows can be created.
+Test mode: Automated
+Test Title: no_overlap_checking
+Ports: 3 (1 Control Plane, 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Generate Flow F1--> Wildcard All.
+b) Send ofp_table_stats request , verify active_count=1
+e) Generate overlapping flow F2 --> Wildcard All Except Ingress Port ( without flag OFPFF_CHECK_OVERLAP set)
+c) Send a ofp_table_stats request, verify active_count=2
+
+3. Identical flows
+
+Test Description: Verify that adding two identical flows overwrites the existing one and clears counters
+Test mode: Automated
+Test Title: identical_flows
+Ports: 3 (1 Control Plane), (2 dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Generate Flow F1.
+b) Send ofp_table_stats request , verify active_count=1
+b) Increment counters (packet_count, byte_count) by sending a packet matching flow F1.
+C) Send ofp_flow_stats request. Verify flow counters: byte_count and packet_count
+c) Create identical flow F2
+d) Send a ofp_table_stats request, verify active_count=1
+e) Send ofp_flow_stats request. Verify flow counters: byte_count and packet_count are reset
+
+
+
+4. No table to add (Written in oftestNeed to add to conformance Test-Suites)
+
+5. Never valid port (TBD)
+
+6. Currently not existing port Version A and B (TBD)
+
+7. Emergency flow with timeout values
+
+Test Description: Timeout values are not allowed for emergency flows
+Test Title: emer_flow_with_timeout
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+
+Test Notes:
+
+a) Generate a flow F with OFPFF_EMERG set in flag and timeout values assigned.
+b) Verify switch generates an OFPT_ERROR msg, Type: OFPET_FLOW_MOD_FAILED, Code OFPFMFC_BAD_EMERG_TIMEOUT
+
+
+8. Missing modify adds
+
+Test Description: If a modify does not match an existing flow, the flow gets added.
+Title: missing_modify_add
+Test mode: Automated
+Ports:3 (1 control plane,2 Data Plane)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Generate a flow-mod , command OFPC_MODIFY (Note: There should be no flows matching this flow_mod modify command)
+b) Send a ofp_table_stats request, verify active_count=1
+
+9. Modify changes action, preserves counters
+
+Test Description: A modified flow preserves counters
+Title: modify_action
+Test mode: Automated
+Ports: 4(1 control plane, 3 Dataplane)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Create a flow_mod F-1 with command OFPC_ADD, action A
+b) Send a test Packet matching the flow
+c) Send an ofp_flow_stats request, verify byte_count and packet_count
+e) Create flow_mod with command OFPC_MODIFY ,action A and modify action of flow F-1
+f) Send a ofp_flow_stats request, verify flow counters are preserved
+g) Send test packet, verify it implements action A
+
+
+10. Strict Modify changes action, preserves counters
+
+Test Description: Strict Modify Flow also changes action preserves counters
+Title: strict_modify_action
+Test mode: Automated
+Ports: 4(1 control plane, 3 Dataplane)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Create two overlapping flows: F --> Match on all, except one wildcarded (src address). Action A. Priority=100
+F --> Match on ingress_port = port [0], wildcarded rest. Action A. Priority=10
+b) Send a ofp_table_stats request, verify active_count=2
+c) Send Packet (it would have matched both the flows, since they are overlapping flows but it would match Flow-F1 as it has higher priority.)
+d) Send ofp_flow_stats request for Flow-1 and verify counters packet_count and byte_count
+e) Create flow_mod ,command OFPC_STRICT_MODIFY,match on all except src address ,priority 100 action A
+f) Send test packet , verify action is modified
+g) Send ofp_flow_stats request, verify counters are preserved.
+
+11. Delete non existing flow
+
+Test Description: Request deletion of non-existing flow
+Title: delete_nonexisting_flow
+Test mode: Automated
+Ports: 1(1 control plane)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Issue a delete command, with no flows inserted
+b) Make sure no error is generated on the control plane
+
+12. Delete flows with and without removed message
+
+Test Description: Check deletion of flows happens and generates messages as configured.
+I.e. if Send Flow removed message Flag is set in the flow entry, the flow deletion of that respective flow should generate the flow removed message, vice versa also exists
+Test Title: Send_Flow_Rem
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplane)
+Initial State: Connection setup, Default (clear switch state)
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Generate a flow F without OFPFF_SEND_FLOW_REM flag set
+b) Issue a delete command OFPFC_DELETE
+c) Verify that OFPT_FLOW_REMOVED message is not generated.
+c) Generate a flow F with OFPFF_SEND_FLOW_REM flag set
+d) Issue a delete command OFPFC_DELETE
+e) Verify that OFPT_FLOW_REMOVED message is generated
+
+
+
+13. Delete emergency flow
+
+Test Description: Delete emergency flow and verify no message is generated.
+An emergency flow deletion will not generate flow-removed messages even if Send Flow removed message flag was set during the emergency flow entry.
+Title: delete_emer_flow
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplane)
+Initial State: Connection setup, Clear Switch State (default)
+
+Test-Notes:
+
+a) Insert a flow with OFPFF_EMERG flag set.
+b) Delete the added flow with OFPFF_SEND_FLOW_REM flag set
+c) Test successful if no flow removed message is generated.
+
+
+14. Delete and verify strict and non-strict
+
+Test Description: Delete and verify strict and non-strict behaviors
+This test compares the behavior of delete strict and non-strict.
+Title: delete_strict_nonstrict
+Test mode: Automated
+Ports: 3 (1 control plane, 2 dataplane)
+Initial State: Connection setup, Clear Switch State
+
+Test-Notes:
+
+a) Insert Flow F with an exact match.
+b) Issue Non-strict Delete command, verify F gets deleted.
+c) Insert F with an exact Match
+d) Issue Strict Delete Command, verify F gets deleted.
+e) Insert Flow T with match on all, except one wildcarded (say src address).
+f) Insert another flow T' with match on ingress_port, wildcarded rest.
+g) Issue Non-strict Delete ( match on ingress_port). Verify T+T' gets deleted.
+h) Insert T and T' again. Issue Strict Delete (match on ingress port), verify only T' gets deleted
+i) Insert T, add Priority P (say 100)
+j) Insert T' add priority (200).
+k) Insert T' again add priority 300 --> T
+l) Issue Non-Strict Delete (match on ingress port). Verify T+T+T gets deleted.
+m) Insert T, T, T again, Issue Strict Delete (match on ingress_port) with priority = 200. Verify only T gets deleted
+
+
+15. Delete flows with constraint out_port
+
+Test Description: Delete flows filtered by action output
+DELETE and DELETE STRICT commands can be optionally filtered by output port. If the out_port field contains a value other than OFPP_NONE, it introduces a constraint when matching. This constraint is that the rule must contain an output action directed at that port.
+
+Title: delete_with_outport
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplanes)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Insert a flow F with output action = port x
+b) Send a delete command matching flow F ,but out_port =port y
+c) Send a table_stats request , verify no flow gets deleted i.e. active_count=1
+d) Send a delete command matching flow F ,outport = port x
+e) Send a table_stats request, verify flow F gets deleted.
+
+
+16. Add, modify flows with constraint output
+
+Test Description: Add, modify flows with outport set. This field is ignored by ADD, MODIFY, and MODIFY STRICT messages.
+Title: add_modify_with_outport
+Test mode: Automated
+Ports: 4 (1 control plane, 3 Data planes)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Insert a flow F with action A (output --> port x) , but out_port field in the flow mod set as port y
+b) Send Table_Stats_Request, Verify Flow gets inserted. ( Flow add ignores out_port field)
+c) Modify the action in flow F , action A ( output -->port z ), but out_port field in the flow mod set as port y
+d) Send test packet matching the flow F
+e) Verify packet implements action A (flow modify ignores out_port field)
+
+17. Verify that idle timeout is implemented
+
+
+Test Description: Verify that idle timeout is implemented
+Title: idle_timeout
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplanes)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Add a flow with idle timeout set and with OFPP_SEND_FLOW_REM bit set
+b) Verify flow removed message is received.
+c) Verify flow removed reason was idle_timeout
+d) Verify the duration_sec field is 1 sec
+
+
+18. Verify that hard timeout is implemented
+
+Test Description: Verify that hard timeout is implemented
+Title: hard_timeout
+Test mode: Automated
+Ports: 3 (1 control plane, 2 Dataplanes)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Add a flow with hard timeout =1 set and with OFPP_SEND_FLOW_REM bit set
+b) Verify flow removed message is received.
+c) Verify flow removed reason was hard_timeout
+d) Verify the duration_sec field is 1 sec
+
+19. Verify that messages are generated as expected
+
+Test Description: Verify that Flow removed messages are generated as expected
+Since flow removed messages being generated when flag is set is already tested in the above tests
+So here, we test the vice-versa condition.
+Title: flow_timeout
+Test mode: Automated
+Ports: 3 (1control plane, 1dataplane)
+Initial State: Connection setup, Clear Switch State
+Test-Field: Mandatory
+
+Test-Notes:
+
+a) Generate and install a flow with idle_timeout = 1 set no OFPFF_SEND_FLOW_REM flag set.
+b) Verify no flow removed message is received.
+c) Send table_stats_request message and verify active_count=0
+
+
+
+
+################# Actions #####################################################################
+
+1. No Action drops packet
+
+Test Description: If no forward actions are present, the packet is dropped.
+Required Action: Drop.
+A flow-entry with no specified action indicates that all matching packets should be dropped.
+Test mode: Automated
+Test Title: no_action_drop
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send Flow mod message without any action specified
+b) Send N packets matching the flow
+c) Verify packets are not received on any of the dataplane ports
+d) Verify packets are not even sent to the controller
+
+2. Get supported actions from switch
+
+Test Description: Get the supported actions from switch and make sanity checks.
+When connecting to the controller, a switch indicate which of the Optional Actions it supports
+Test mode: Automated
+Test Title: announcement
+Ports: 1 (Control Plane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+a) Send features_request .
+b) Verify response is OFPT_FEATURES_REPLY
+c) Verify reply has supported action list specified
+
+
+
+3. Forward All
+
+Test Description: Packet is sent to all dataplane ports except ingress port when output action.port = OFPP_ALL
+Test mode: Automated
+Test Title: forward_all
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+
+Test Notes:
+
+ a) Install a flow with output action.port = OFPP_ALL.
+ b) Verify packets are forwarded to all ports except ingress port.
+
+
+4. Forward Controller
+Test Description: Packet is sent to controller output.port = OFPP_CONTROLLER
+Test mode: Automated
+Test Title: forward_controller
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+
+Test Notes:
+
+a) Insert a flow with action output port = OFPP_CONTROLLER
+b) Send packets matching the flow
+c) Verify packet received on the control plane as a packet_in message
+
+
+5. Forward Local (TBD Verification of packet being received at local networking stack)
+
+Test Description: Packet is sent to switchs local networking stack if output.port = OFPP_LOCAL
+Test mode: Automated
+Test Title: forward_local
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+
+Test Notes:
+
+a) Insert a flow with action output port = OFPP_LOCAL
+b) Send packets matching the flow
+c) Verify packet received in the switchs local networking stack.
+
+6. Forward Table
+
+Test Description: Perform actions in flow table. Only for packet-out messages.
+If the output action.port in the packetout message = OFP.TABLE, then the packet implements the action specified in the matching flow of the FLOW-TABLE
+Test mode: Automated
+Test Title: forward_table
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Insert a flow F with action output.port = egress_port
+b) Send a OFPT_PACKET_OUT message with out port=OFPP_TABLE matching flow F
+c) Verify packet received on egress_port (i.e packetout message implemented the action specified in the matching flow of the Table)
+
+
+7. Forward In Port
+
+Test Description: Packet is sent to input port if output.port = OFPP_INPORT
+Test mode: Automated
+Test Title: forward_inport
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Mandatory
+
+Test Notes:
+
+a) Insert a flow with action output port = OFPP_INPORT
+b) Send packets matching the flow
+c) Verify packet received on all dataplane ports except for input port
+
+
+8. Forward Flood
+
+Test Description: FLOOD: Flood the packet along the minimum spanning tree, not including the incoming interface.
+Packet is sent all the dataplane ports except the input port if output.port = OFPP_FLOOD
+Test mode: Automated
+Test Title: forward_flood
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+Test Notes:
+
+a) Insert a flow with action output port = OFPP_FLOOD
+b) Send packets matching the flow
+c) Verify packet received on all dataplane ports except for input port
+
+9. Multiple Ports -- TBD
+
+10. Forward Enqueue --- TBD
+
+
+11. Set VLAN Id
+
+Test Description: Attach VLAN ID to untagged packet
+If no VLAN is present, a new header is added with the specified VLAN ID and priority of zero.
+Test mode: Automated
+Test Title: add_vlan_id
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+
+a) Insert a flow with action = OFPAT_SET_VLAN_VID , vlan_vid = x
+b) Send packet (length = 100 bytes) matching the flow
+b) Verify packet received has vlan id added to it. (I.e length of packet with vid is 104 bytes, dl_vlan_enable = True, dl_vlan= x, dl_vlan_pcp=0)
+
+12. Modify VLAN Id
+
+Test Description: Modifies Vlan Tag for a tagged packet
+If a VLAN header already exists, the VLAN ID is replaced with the specified value
+Test mode: Automated
+Test Title: modify_vlan_id
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_VLAN_VID , vlan_vid = x
+b) Send packet (length = 100 bytes) matching the flow
+c) Verify packet received has vlan id rewritten. (I.e length of 104 bytes, dl_vlan_enable = True, dl_vlan=x)
+
+
+13. Add VLAN Priority to an untagged packet
+
+Test Description: Attach VLAN priority to an untagged packet.
+Since, no VLAN ID is present; a new header is added with the specified priority and a VLAN ID of zero.
+Test mode: Automated
+Test Title: vlan_prio_untagged
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+
+a) Insert a flow with action = OFPAT_SET_VLAN_PCP , dl_vlan_pcp =x
+b) Send untagged packet matching the flow
+c) Verify packet received has vlan priority added to it along with a vid value of zero added by default (dl_vlan_enable , dl_vlan = 0 , dl_vlan_pcp =x )
+
+14. Rewrite existing VLAN priority
+
+Test Description: Modify VLAN priority for a tagged packet.
+Test mode: Automated
+Test Title: modify_vlan_prio
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+
+a) Insert a flow with action = OFPAT_SET_VLAN_PCP , dl_vlan_pcp =new_vlan_pcp
+b) Send tagged packet matching the flow (dl_vlan = old_vlan_id , dl_vlan_pcp = old_vlan_pcp)
+c) Verify packet received has vlan id added to it. (dl_vlan_enable , dl_vlan = 0 , dl_vlan_pcp = new_vlan_pcp)
+
+
+
+
+15. Modify L2 Src Address
+
+Test Description: Modify Ethernet Src Address of a packet
+Test mode: Automated
+Test Title: modify_l2_src
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_DL_SRC , dl_src =new_dl_src
+b) Send packet matching the flow (dl_dst = old_dl_src )
+c) Verify packet received has src address rewritten. (dl_src= new_dl_src)
+
+
+
+16. Modify L2 Destination Address
+
+Test Description: Modify Ethernet Destination Address of a packet
+Test mode: Automated
+Test Title: modify_l2_dst
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_DL_DST , dl_dst =new_dl_dst
+b) Send packet matching the flow (dl_dst = old_dl_src )
+c) Verify packet received has destination address rewritten. (dl_src= new_dl_src)
+
+17. Strip VLAN header (In oftest, need to add in conformance test-suite )
+
+
+18. Modify L3 Src Address
+
+Test Description: Modify Network Src Address of a packet
+Test mode: Automated
+Test Title: modify_l3_src
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_NW_SRC , nw_src =new_nw_src
+b) Send packet matching the flow (nw_src = old_nw_src )
+c) Verify packet received has nw address rewritten. (nw_src= new_nw_src)
+
+
+
+
+
+
+
+19. Modify L3 Dst Address
+
+Test Description: Modify Network Dst Address of a packet
+Test mode: Automated
+Test Title: modify_l3_dst
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_NW_DST , nw_dst =new_nw_dst
+b) Send packet matching the flow (nw_dst = old_nw_dst )
+c) Verify packet received has nw destination address rewritten. (nw_dst= new_nw_dst)
+
+
+
+
+20. Modify L4 Src Address
+
+Test Description: Modify TCP Source Port of a packet
+Test mode: Automated
+Test Title: modify_l4_src
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_TP_SRC , tcp_sport =new_tcp_sport
+b) Send packet matching the flow (tcp_sport = old_tcp_sport )
+c) Verify packet received has tcp source port rewritten. (tcp_sport = new_tcp_sport)
+
+
+21. Modify L4 Dst Address
+
+Test Description: Modify TCP Destination Port of a packet
+Test mode: Automated
+Test Title: modify_l4_dst
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_TP_DST , tcp_dport =new_tcp_dport
+b) Send packet matching the flow (tcp_dport = old_tcp_dport )
+c) Verify packet received has tcp destination port rewritten. (tcp_sport = new_tcp_sport)
+
+
+
+22. Modify TOS
+
+Test Description: Modify Network Type of service
+Test mode: Automated
+Test Title: modify_tos
+Ports: 3 (1 Control Plane 2 Dataplane)
+Initial State: Default (Clear switch state), Connection setup
+Test-Field: Optional
+
+
+Test Notes:
+a) Insert a flow with action = OFPAT_SET_NW_TOS, ip_tos =new_ip_tos
+b) Send packet matching the flow (ip_tos= old_ip_tos)
+c) Verify packet received has tcp destination port rewritten. (ip_tos= new_ip_tos)
+
+
+23. Order Not possible -- TBD
+
+24. Sequential execution -- TBD
+
diff --git a/tests/Actions.py b/tests/Actions.py
new file mode 100644
index 0000000..011d9c7
--- /dev/null
+++ b/tests/Actions.py
@@ -0,0 +1,847 @@
+
+"""These tests fall under Conformance Test-Suite (OF-SWITCH-1.0.0 TestCases).
+ Refer Documentation -- Detailed testing methodology
+ <Some of test-cases are directly taken from oftest> """
+
+"Test Suite 6 ---> Actions "
+
+
+import logging
+
+import unittest
+import random
+
+import oftest.controller as controller
+import oftest.cstruct as ofp
+import oftest.message as message
+import oftest.dataplane as dataplane
+import oftest.action as action
+import oftest.parse as parse
+import basic
+import time
+
+from testutils import *
+from time import sleep
+from FuncUtils import *
+
+ac_port_map = None
+ac_logger = None
+ac_config = None
+of_ports = None
+
+def test_set_init(config):
+ basic.test_set_init(config)
+
+ global ac_port_map
+ global ac_logger
+ global ac_config
+ global of_ports
+
+ ac_logger = logging.getLogger("Running Actions test-suite")
+ ac_logger.info("Initializing test set")
+ ac_port_map = config["port_map"]
+ ac_config = config
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+
+
+
+class no_action_drop(basic.SimpleDataPlane):
+
+ """NoActionDrop : no action added to flow , drops the packet."""
+
+ def runTest(self):
+
+ ac_logger.info("Running no_action_drop test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Install a flow without action")
+ ac_logger.info("Send packets matching that flow")
+ ac_logger.info("Expecting switch to drop all packets")
+
+ # Insert a flow wildcard all without any action
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ self.assertTrue(match is not None, "Could not generate flow match from pkt")
+ match.wildcards=ofp.OFPFW_ALL
+ match.in_port = of_ports[0]
+
+ msg = message.flow_mod()
+ msg.out_port = ofp.OFPP_NONE
+ msg.command = ofp.OFPFC_ADD
+ msg.buffer_id = 0xffffffff
+ msg.match = match
+ rv = self.controller.message_send(msg)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+
+ #Sending N packets matching the flow inserted
+ for pkt_cnt in range(5):
+ self.dataplane.send(of_ports[0],str(pkt))
+
+ #Verify packets not recieved on any of the dataplane ports
+ for any_port in of_ports:
+ (rcv_port, rcv_pkt, pkt_time) = self.dataplane.poll(timeout=1, port_number=any_port,exp_pkt=pkt)
+ self.assertTrue(rcv_pkt is None,
+ "Packet received on port " + str(any_port))
+
+ #Verify packets not sent on control plane either
+ (response, raw) = self.controller.poll(ofp.OFPT_PACKET_IN, timeout=1)
+ self.assertTrue(response is None,
+ 'Packets not received on control plane')
+
+
+class announcement(basic.SimpleDataPlane):
+
+ """Announcement : Get all supported actions by the switch.
+ Send OFPT_FEATURES_REQUEST to get features supported by sw."""
+
+ def runTest(self):
+
+ ac_logger.info("Running announcement test")
+
+ ac_logger.info("Sending Features_Request")
+ ac_logger.info("Expecting Features Reply with supported actions")
+
+ # Sending Features_Request
+ request = message.features_request()
+ (reply, pkt) = self.controller.transact(request)
+ self.assertTrue(reply is not None, "Failed to get any reply")
+ self.assertEqual(reply.header.type, ofp.OFPT_FEATURES_REPLY,'Response is not Features_reply')
+
+ supported_actions =[]
+ if(reply.actions &1<<ofp.OFPAT_OUTPUT):
+ supported_actions.append('OFPAT_OUTPUT')
+ if(reply.actions &1<<ofp.OFPAT_SET_VLAN_VID):
+ supported_actions.append('OFPAT_SET_VLAN_VID')
+ if(reply.actions &1<<ofp.OFPAT_SET_VLAN_PCP):
+ supported_actions.append('OFPAT_SET_VLAN_PCP')
+ if(reply.actions &1<<ofp.OFPAT_STRIP_VLAN):
+ supported_actions.append('OFPAT_STRIP_VLAN')
+ if(reply.actions &1<<ofp.OFPAT_SET_DL_SRC):
+ supported_actions.append('OFPAT_SET_DL_SRC')
+ if(reply.actions &1<<ofp.OFPAT_SET_DL_DST):
+ supported_actions.append('OFPAT_SET_NW_SRC')
+ if(reply.actions &1<<ofp.OFPAT_SET_NW_DST):
+ supported_actions.append('OFPAT_SET_NW_DST')
+ if(reply.actions &1<<ofp.OFPAT_SET_NW_TOS):
+ supported_actions.append('OFPAT_SET_NW_TOS')
+ if(reply.actions &1<<ofp.OFPAT_SET_TP_SRC):
+ supported_actions.append('OFPAT_SET_TP_SRC')
+ if(reply.actions &1<<ofp.OFPAT_SET_TP_DST):
+ supported_actions.append('OFPAT_SET_TP_DST')
+ if(reply.actions &1<<ofp.OFPAT_VENDOR):
+ supported_actions.append('OFPAT_VENDOR')
+ if(reply.actions &1<<ofp.OFPAT_ENQUEUE):
+ supported_actions.append('OFPAT_ENQUEUE')
+
+ ac_logger.info(supported_actions)
+
+
+class forward_all(basic.SimpleDataPlane):
+
+ """ForwardAll : Packet is sent to all dataplane ports
+ except ingress port when output action.port = OFPP_ALL"""
+
+ def runTest(self):
+
+ ac_logger.info("Running forward all test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow with output action port OFPP_ALL")
+ ac_logger.info("Send packet matching the flow")
+ ac_logger.info("Expecting packet on all dataplane ports except ingress_port")
+
+ #Create a packet
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ act = action.action_output()
+
+ #Delete all flows
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+ ingress_port=of_ports[0]
+ match.in_port = ingress_port
+
+ #Create a flow mod with action.port = OFPP_ALL
+ request = message.flow_mod()
+ request.match = match
+ request.match.wildcards = ofp.OFPFW_ALL&~ofp.OFPFW_IN_PORT
+ act.port = ofp.OFPP_ALL
+ request.actions.add(act)
+
+ ac_logger.info("Inserting flow")
+ rv = self.controller.message_send(request)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+ self.assertEqual(do_barrier(self.controller), 0, "Barrier failed")
+
+ #Send Packet matching the flow
+ ac_logger.info("Sending packet to dp port " + str(ingress_port))
+ self.dataplane.send(ingress_port, str(pkt))
+
+ #Verifying packets recieved on expected dataplane ports
+ yes_ports = set(of_ports).difference([ingress_port])
+ receive_pkt_check(self.dataplane, pkt, yes_ports, [ingress_port],
+ self, ac_logger, ac_config)
+
+
+class forward_controller(basic.SimpleDataPlane):
+
+ """ForwardController : Packet is sent to controller
+ output.port = OFPP_CONTROLLER"""
+
+ def runTest(self):
+
+ ac_logger.info("Running forward_controller test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow with output action port OFPP_CONTROLLER")
+ ac_logger.info("Send packet matching the flow")
+ ac_logger.info("Expecting packet on the control plane")
+
+ #Create packet
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ act = action.action_output()
+
+ for ingress_port in of_ports:
+ #Delete all flows
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ match.in_port = ingress_port
+
+ #Create a flow mod message
+ request = message.flow_mod()
+ request.match = match
+ act.port = ofp.OFPP_CONTROLLER
+ request.actions.add(act)
+
+ ac_logger.info("Inserting flow")
+ rv = self.controller.message_send(request)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+ self.assertEqual(do_barrier(self.controller), 0, "Barrier failed")
+
+ #Send packet matching the flow
+ ac_logger.info("Sending packet to dp port " + str(ingress_port))
+ self.dataplane.send(ingress_port, str(pkt))
+
+ #Verifying packet recieved on the control plane port
+ (response, raw) = self.controller.poll(ofp.OFPT_PACKET_IN, timeout=10)
+ self.assertTrue(response is not None,
+ 'Packet in message not received by controller')
+
+
+
+class forward_local(basic.SimpleDataPlane):
+
+ """ForwardLocal : Packet is sent to OFPP_LOCAL port .
+ TBD : To verify packet recieved in the local networking stack of switch"""
+
+ def runTest(self):
+
+ ac_logger.info("Running Forward Local test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow with output action port OFPP_LOCAL")
+ ac_logger.info("Send packet matching the flow")
+ ac_logger.info("Expecting packet in the local networking stack of switch")
+
+ #Clear switch state
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ act = action.action_output()
+
+ for ingress_port in of_ports:
+ #Delete the flows
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ match.in_port = ingress_port
+ #Create flow mod message
+ request = message.flow_mod()
+ request.match = match
+ act.port = ofp.OFPP_LOCAL
+ request.actions.add(act)
+
+ ac_logger.info("Inserting flow")
+ rv = self.controller.message_send(request)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+ self.assertEqual(do_barrier(self.controller), 0, "Barrier failed")
+
+ #Send packet matching the flow
+ ac_logger.info("Sending packet to dp port " + str(ingress_port))
+ self.dataplane.send(ingress_port, str(pkt))
+
+ #TBD: Verification of packets being recieved.
+
+
+class forward_flood(basic.SimpleDataPlane):
+
+ """Forward:Flood : Packet is sent to all dataplane ports
+ except ingress port when output action.port = OFPP_FLOOD
+ TBD : Verification---Incase of STP being implemented, flood the packet along the minimum spanning tree,
+ not including the incoming interface. """
+
+ def runTest(self):
+
+ ac_logger.info("Running forward flood tests")
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow with output action port OFPP_FORWARD")
+ ac_logger.info("Send packet matching the flow")
+ ac_logger.info("Expecting packet on all the ports except the input port")
+
+ #Create a packet
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ act = action.action_output()
+
+ #Delete all flows
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+ ingress_port=of_ports[0]
+ match.in_port = ingress_port
+
+ #Create a flow mod with action.port = OFPP_ALL
+ request = message.flow_mod()
+ request.match = match
+ request.match.wildcards = ofp.OFPFW_ALL&~ofp.OFPFW_IN_PORT
+ act.port = ofp.OFPP_FLOOD
+ request.actions.add(act)
+
+ ac_logger.info("Inserting flow")
+ rv = self.controller.message_send(request)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+ self.assertEqual(do_barrier(self.controller), 0, "Barrier failed")
+
+ #Send Packet matching the flow
+ ac_logger.info("Sending packet to dp port " + str(ingress_port))
+ self.dataplane.send(ingress_port, str(pkt))
+
+ #Verifying packets recieved on expected dataplane ports
+ yes_ports = set(of_ports).difference([ingress_port])
+ receive_pkt_check(self.dataplane, pkt, yes_ports, [ingress_port],
+ self, ac_logger, ac_config)
+
+class forward_inport(basic.SimpleDataPlane):
+
+ """ ForwardInPort : Packet sent to virtual port IN_PORT
+ If the output.port = OFPP.INPORT then the packet is sent to the input port itself"""
+
+ def runTest(self):
+
+ ac_logger.info("Running forward_inport test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow with output action port OFPP_INPORT")
+ ac_logger.info("Send packet matching the flow")
+ ac_logger.info("Expecting packet on the input port")
+
+ #Create a packet
+ pkt = simple_tcp_packet()
+ match = parse.packet_to_flow_match(pkt)
+ act = action.action_output()
+
+ #Delete the flows
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+ ingress_port=of_ports[0]
+ match.in_port = ingress_port
+
+ # Create a flow mod message
+ request = message.flow_mod()
+ request.match = match
+ act.port = ofp.OFPP_IN_PORT
+
+ request.actions.add(act)
+ ac_logger.info("Inserting flow")
+ rv = self.controller.message_send(request)
+ self.assertTrue(rv != -1, "Error installing flow mod")
+ self.assertEqual(do_barrier(self.controller), 0, "Barrier failed")
+
+ #Send packet matching the flow
+ ac_logger.info("Sending packet to dp port " + str(ingress_port))
+ self.dataplane.send(ingress_port, str(pkt))
+ yes_ports = [ingress_port]
+
+ #Verfying packet recieved on expected dataplane ports
+ receive_pkt_check(self.dataplane, pkt, yes_ports,set(of_ports).difference([ingress_port]),
+ self, ac_logger, ac_config)
+
+class forward_table(basic.SimpleDataPlane):
+
+ """ForwardTable : Perform actions in flow table. Only for packet-out messages.
+ If the output action.port in the packetout message = OFP.TABLE , then
+ the packet implements the action specified in the matching flow of the FLOW-TABLE"""
+
+ def runTest(self):
+
+ ac_logger.info("Running Forward Table test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Insert a flow F with output action port set to some egress_port")
+ ac_logger.info("Send packet out message (matching flow F) with action.port = OFP.TABLE")
+ ac_logger.info("Expecting packet on the egress_port")
+
+ #Insert a all wildcarded flow
+ (pkt,match) = Wildcard_All(self,of_ports)
+
+ #Create a packet out message
+ pkt_out =message.packet_out();
+ pkt_out.data = str(pkt)
+ pkt_out.in_port = of_ports[0]
+ act = action.action_output()
+ act.port = ofp.OFPP_TABLE
+ pkt_out.actions.add(act)
+ rv = self.controller.message_send(pkt_out)
+ self.assertTrue(rv == 0, "Error sending out message")
+
+ #Verifying packet out message recieved on the expected dataplane port.
+ (of_port, pkt, pkt_time) = self.dataplane.poll(port_number=of_ports[1],
+ exp_pkt=pkt,timeout=3)
+ self.assertTrue(pkt is not None, 'Packet not received')
+
+
+class add_vlan_tag(basic.SimpleDataPlane):
+
+ """AddVlanTag : Adds VLAN Tag to untagged packet."""
+
+ def runTest(self):
+
+ ac_logger.info("Running add_vlan_tag test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- set vlan id, if not skip the test")
+ ac_logger.info("Insert a flow with set vid action")
+ ac_logger.info("Send packet matching the flow , verify recieved packet has vid set")
+
+ #Verify set_vlan_id is a supported action
+ sup_acts = sw_supported_actions(self)
+ if not(sup_acts & 1<<ofp.OFPAT_SET_VLAN_VID):
+ skip_message_emit(self, "Add VLAN tag test skipped")
+ return
+
+ #Create packet to be sent and an expected packet with vid set
+ new_vid = 2
+ len_wo_vid = 100
+ len_w_vid = 104
+ pkt = simple_tcp_packet(pktlen=len_wo_vid)
+ exp_pkt = simple_tcp_packet(pktlen=len_w_vid, dl_vlan_enable=True,
+ dl_vlan=new_vid,dl_vlan_pcp=0)
+ vid_act = action.action_set_vlan_vid()
+ vid_act.vlan_vid = new_vid
+
+ #Insert flow with action -- set vid , Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt,
+ exp_pkt=exp_pkt, action_list=[vid_act])
+
+class modify_vlan_tag(basic.SimpleDataPlane):
+
+ """ModifyVlanTag : Modifies VLAN Tag to tagged packet."""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_vlan_tag test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify vlan id, if not skip the test")
+ ac_logger.info("Insert a flow with action --set vid ")
+ ac_logger.info("Send tagged packet matching the flow , verify recieved packet has vid rewritten")
+
+ #Verify set_vlan_id is a supported action
+ sup_acts = sw_supported_actions(self)
+ if not (sup_acts & 1 << ofp.OFPAT_SET_VLAN_VID):
+ skip_message_emit(self, "Modify VLAN tag test skipped")
+ return
+
+ #Create a tagged packet with old_vid to be sent, and expected packet with new_vid
+ old_vid = 2
+ new_vid = 3
+ pkt = simple_tcp_packet(dl_vlan_enable=True, dl_vlan=old_vid)
+ exp_pkt = simple_tcp_packet(dl_vlan_enable=True, dl_vlan=new_vid)
+ vid_act = action.action_set_vlan_vid()
+ vid_act.vlan_vid = new_vid
+
+ #Insert flow with action -- set vid , Send packet matching the flow.Verify recieved packet is expected packet.
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=[vid_act])
+
+class vlan_prio_untagged(basic.SimpleDataPlane):
+
+ """AddVlanPrioUntaggedPkt : Add VLAN priority to untagged packet."""
+
+ def runTest(self):
+
+ ac_logger.info("Running vlan_prio_untagged test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- set vlan priority, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set vlan priority ")
+ ac_logger.info("Send untagged packet matching the flow , verify recieved packet has specified VLAN priority and has vid set tO 0 ")
+
+ #Verify set_vlan_priority is a supported action
+ sup_acts = sw_supported_actions(self)
+ if not (sup_acts & 1 << ofp.OFPAT_SET_VLAN_PCP):
+ skip_message_emit(self, "Set VLAN priority test skipped")
+ return
+
+ #Create a untagged packet to be sent and an expected packet with vid = 0 , vlan_priority set.
+ vlan_id = 0
+ pkt = simple_tcp_packet()
+ exp_pkt = simple_tcp_packet(dl_vlan_enable=True, dl_vlan=vlan_id,dl_vlan_pcp=0)
+ act = action.action_set_vlan_vid()
+
+ #Insert flow with action -- set vLAN priority, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=[act])
+
+
+class modify_vlan_prio(basic.SimpleDataPlane):
+
+ """ModifyVlanPrio : Modify VLAN priority to tagged packet."""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_vlan_prio test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- set vlan priority, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set vlan priority ")
+ ac_logger.info("Send tagged packet matching the flow, verify recieved packet has vlan priority rewritten")
+
+ #Verify set_vlan_priority is a supported action
+ sup_acts = sw_supported_actions(self,"true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_VLAN_PCP):
+ skip_message_emit(self, "modify_vlan_prio test skipped")
+ return
+
+ #Create a tagged packet , and an expected packet with vlan_priority set to specified value
+ vid = 123
+ old_vlan_pcp = 2
+ new_vlan_pcp = 3
+ pkt = simple_tcp_packet(dl_vlan_enable=True, dl_vlan=vid, dl_vlan_pcp=old_vlan_pcp)
+ exp_pkt = simple_tcp_packet(dl_vlan_enable=True, dl_vlan=vid, dl_vlan_pcp=new_vlan_pcp)
+ vid_act = action.action_set_vlan_pcp()
+ vid_act.vlan_pcp = new_vlan_pcp
+
+ #Insert flow with action -- set vLAN priority, Send tagged packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=[vid_act])
+
+
+class modify_l2_src(basic.SimpleDataPlane):
+
+ """ModifyL2Src :Modify the source MAC address"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l2_src test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l2_src, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set etherent src address")
+ ac_logger.info("Send packet matching the flow, verify recieved packet src address rewritten ")
+
+ #Verify set_dl_src is a supported action
+ sup_acts = sw_supported_actions(self,use_cache="true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_DL_SRC):
+ skip_message_emit(self, "modify_l2_src test skipped")
+ return
+
+ #Create packet to be sent and expected packet with dl_src set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['dl_src'],
+ check_test_params=True)
+
+ #Insert flow with action -- set src address, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+
+class modify_l2_dst(basic.SimpleDataPlane):
+
+ """ModifyL2SDSt :Modify the dest MAC address"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l2_dst test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l2_dst, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set etherent dst address ")
+ ac_logger.info("Send packet matching the flow, verify recieved packet dst address rewritten ")
+
+ #Verify set_dl_dst is a supported action
+ sup_acts = sw_supported_actions(self)
+ if not (sup_acts & 1 << ofp.OFPAT_SET_DL_DST):
+ skip_message_emit(self, "modify_l2_dst test skipped")
+ return
+
+ #Create packet to be sent and expected packet with dl_src set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['dl_dst'],
+ check_test_params=True)
+
+ #Insert flow with action -- set dst address, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+class modify_l3_src(basic.SimpleDataPlane):
+
+ """ModifyL3Src : Modify the source IP address of an IP packet """
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l3_src test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l3_src, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set network src address ")
+ ac_logger.info("Send packet matching the flow, verify recieved packet network src address rewritten ")
+
+ #Verify set_nw_src is a supported action
+ sup_acts = sw_supported_actions(self)
+ if not (sup_acts & 1 << ofp.OFPAT_SET_NW_SRC):
+ skip_message_emit(self, "modify_l3_src test")
+ return
+
+ #Create packet to be sent and expected packet with nw_src set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['ip_src'],
+ check_test_params=True)
+
+ #Insert flow with action -- set nw src address, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+class modify_l3_dst(basic.SimpleDataPlane):
+
+ """ModifyL3Dst :Modify the dest IP address of an IP packet"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l3_dst test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l3_dst, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set network dst address ")
+ ac_logger.info("Send packet matching the flow, verify recieved packet network dst address rewritten ")
+
+ #Verify set_nw_dst is a supported action
+ sup_acts = sw_supported_actions(self,use_cache="true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_NW_DST):
+ skip_message_emit(self, "modify_l3_dst test skipped")
+ return
+
+ #Create packet to be sent and expected packet with nw_dst set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['ip_dst'],
+ check_test_params=True)
+
+ #Insert flow with action -- set nw dst address, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+
+class modify_l4_src(basic.SimpleDataPlane):
+
+ """ModifyL4Src : Modify the source TCP port of a TCP packet"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l4_src test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l4_src, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set src tcp port")
+ ac_logger.info("Send packet matching the flow, verify recieved packet src tcp port is rewritten ")
+
+ #Verify set_tp_src is a supported action
+ sup_acts = sw_supported_actions(self,use_cache="true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_TP_SRC):
+ skip_message_emit(self, "modify_l4_src test skipped")
+ return
+
+ #Create packet to be sent and expected packet with tcp_src set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['tcp_sport'],
+ check_test_params=True)
+
+ #Insert flow with action -- set tcp src port, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+class modify_l4_dst(basic.SimpleDataPlane):
+
+ """ ModifyL4Dst: Modify the dest TCP port of a TCP packet (TP1)"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_l4_dst test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_l4_dst, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set dst tcp port")
+ ac_logger.info("Send packet matching the flow, verify recieved packet dst tcp port is rewritten ")
+
+ #Verify set_tp_dst is a supported action
+ sup_acts = sw_supported_actions(self,use_cache="true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_TP_DST):
+ skip_message_emit(self, "ModifyL4Dst test")
+ return
+
+ #Create packet to be sent and expected packet with tcp_dst set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['tcp_dport'],
+ check_test_params=True)
+
+ #Insert flow with action -- set tcp dst port, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2)
+
+class modify_tos(basic.SimpleDataPlane):
+
+ """ModifyTOS :Modify the IP type of service of an IP packet"""
+
+ def runTest(self):
+
+ ac_logger.info("Running modify_tos test")
+
+ of_ports = ac_port_map.keys()
+ of_ports.sort()
+ self.assertTrue(len(of_ports) > 1, "Not enough ports for test")
+
+ #Clear switch state
+ rv = delete_all_flows(self.controller, ac_logger)
+ self.assertEqual(rv, 0, "Failed to delete all flows")
+
+ ac_logger.info("Verify if switch supports the action -- modify_tos, if not skip the test")
+ ac_logger.info("Insert a flow with action -- set type of service ")
+ ac_logger.info("Send packet matching the flow, verify recieved packet has TOS rewritten ")
+
+ #Verify set_tos is a supported action
+ sup_acts = sw_supported_actions(self,use_cache="true")
+ if not (sup_acts & 1 << ofp.OFPAT_SET_NW_TOS):
+ skip_message_emit(self, "ModifyTOS test")
+ return
+
+ #Create packet to be sent and expected packet with TOS set to specified value
+ (pkt, exp_pkt, acts) = pkt_action_setup(self, mod_fields=['ip_tos'],
+ check_test_params=True)
+
+ #Insert flow with action -- set TOS, Send packet matching the flow, Verify recieved packet is expected packet
+ flow_match_test(self, ac_port_map, pkt=pkt, exp_pkt=exp_pkt,
+ action_list=acts, max_test=2, egr_count=-1)
diff --git a/tests/Detailed_Contr_Sw_Messages.py b/tests/Detailed_Contr_Sw_Messages.py
index e5c1c57..30c72d9 100644
--- a/tests/Detailed_Contr_Sw_Messages.py
+++ b/tests/Detailed_Contr_Sw_Messages.py
@@ -40,7 +40,7 @@
cs_config = config
-class Overlap_Checking(basic.SimpleDataPlane):
+class overlap_checking(basic.SimpleDataPlane):
"""Verify that if overlap check flag is set in the flow entry and an overlapping flow is inserted then an error
is generated and switch refuses flow entry"""
@@ -101,7 +101,7 @@
'Error Message code is not overlap')
-class No_Overlap_Checking(basic.SimpleDataPlane):
+class no_overlap_checking(basic.SimpleDataPlane):
"""Verify that without overlap check flag set, overlapping flows can be created."""
@@ -133,7 +133,7 @@
Verify_TableStats(self,active_entries=2)
-class Identical_Flows(basic.SimpleDataPlane):
+class identical_flows(basic.SimpleDataPlane):
"""Verify that adding two identical flows overwrites the existing one and clears counters"""
@@ -174,7 +174,7 @@
Verify_FlowStats(self,match,byte_count=0,packet_count=0)
-class Emer_Flow_With_Timeout(basic.SimpleProtocol):
+class emer_flow_with_timeout(basic.SimpleProtocol):
"""Timeout values are not allowed for emergency flows"""
@@ -226,7 +226,7 @@
'Error Message code is not bad emergency timeout')
-class Missing_Modify_Add(basic.SimpleDataPlane):
+class missing_modify_add(basic.SimpleDataPlane):
"""If a modify does not match an existing flow, the flow gets added """
@@ -266,7 +266,7 @@
Verify_TableStats(self,active_entries=1)
-class Modify_Action(basic.SimpleDataPlane):
+class modify_action(basic.SimpleDataPlane):
"""A modified flow preserves counters"""
@@ -304,7 +304,7 @@
Verify_FlowStats(self,match,byte_count=(2*len(str(pkt))),packet_count=2)
-class Strict_Modify_Action(basic.SimpleDataPlane):
+class strict_mdify_action(basic.SimpleDataPlane):
"""Strict Modify Flow also changes action preserves counters"""
@@ -348,7 +348,7 @@
Verify_FlowStats(self,match,byte_count=(2*len(str(pkt))),packet_count=2)
-class Delete_NonExisting_Flow(basic.SimpleDataPlane):
+class delete_nonexisting_flow(basic.SimpleDataPlane):
"""Request deletion of non-existing flow"""
@@ -382,7 +382,7 @@
-class Send_Flow_Rem(basic.SimpleDataPlane):
+class send_flow_rem(basic.SimpleDataPlane):
"""Check deletion of flows happens and generates messages as configured.
If Send Flow removed message Flag is set in the flow entry, the flow deletion of that respective flow should generate the flow removed message,
@@ -443,7 +443,7 @@
'Did not receive flow removed message for this flow')
-class Delete_Emer_Flow(basic.SimpleProtocol):
+class delete_emer_flow(basic.SimpleProtocol):
"""Delete emergency flow and verify no message is generated.An emergency flow deletion will not generate flow-removed messages even if
Send Flow removed message flag was set during the emergency flow entry"""
@@ -486,7 +486,7 @@
'Test Failed ')
-class Delete_Strict_NonStrict(basic.SimpleDataPlane):
+class delete_strict_nonstrict(basic.SimpleDataPlane):
"""Delete and verify strict and non-strict behaviors
This test compares the behavior of delete strict and non-strict"""
@@ -573,7 +573,7 @@
-class Delete_With_Outport(basic.SimpleDataPlane):
+class delete_with_outport(basic.SimpleDataPlane):
"""Delete flows filtered by action outport.If the out_port field in the delete command contains a value other than OFPP_NONE,
it introduces a constraint when matching. This constraint is that the rule must contain an output action directed at that port."""
@@ -632,7 +632,7 @@
Verify_TableStats(self,active_entries=0)
-class Idle_Timeout(basic.SimpleDataPlane):
+class idle_timeout(basic.SimpleDataPlane):
""" Verify that idle timeout is implemented"""
@@ -676,7 +676,7 @@
'Flow was not alive for 1 sec')
-class Add_Modify_With_Outport(basic.SimpleDataPlane):
+class add_modify_with_outport(basic.SimpleDataPlane):
"""Add, modify flows with outport set. This field is ignored by ADD, MODIFY, and MODIFY STRICT messages."""
@@ -716,7 +716,7 @@
-class Hard_Timeout(basic.SimpleDataPlane):
+class hard_timeout(basic.SimpleDataPlane):
""" Verify that hard timeout is implemented """
@@ -760,7 +760,7 @@
'Flow was not alive for 1 sec')
-class Flow_Timeout(basic.SimpleDataPlane):
+class flow_timeout(basic.SimpleDataPlane):
"""Verify that Flow removed messages are generated as expected
Flow removed messages being generated when flag is set, is already tested in the above tests
diff --git a/tests/Openflow_Protocol_Messages.py b/tests/Openflow_Protocol_Messages.py
index d3db3b1..2e37058 100644
--- a/tests/Openflow_Protocol_Messages.py
+++ b/tests/Openflow_Protocol_Messages.py
@@ -42,7 +42,7 @@
of_config = config
-class Features_Request(basic.SimpleProtocol):
+class features_request(basic.SimpleProtocol):
"""Verify Features_Request-Reply is implemented
a) Send OFPT_FEATURES_REQUEST
@@ -71,7 +71,7 @@
'Did not receive Features Reply')
-class Configuration_Request(basic.SimpleProtocol):
+class configuration_request(basic.SimpleProtocol):
"""Check basic Get Config request is implemented
a) Send OFPT_GET_CONFIG_REQUEST
@@ -100,7 +100,7 @@
self.assertTrue(response is not None,
'Did not receive OFPT_GET_CONFIG_REPLY')
-class Modify_State_Add(basic.SimpleProtocol):
+class modify_state_add(basic.SimpleProtocol):
"""Check basic Flow Add request is implemented
a) Send OFPT_FLOW_MOD , command = OFPFC_ADD
@@ -127,7 +127,7 @@
Verify_TableStats(self,active_entries=1)
-class Modify_State_Delete(basic.SimpleProtocol):
+class modify_state_delete(basic.SimpleProtocol):
"""Check Basic Flow Delete request is implemented
a) Send OFPT_FLOW_MOD, command = OFPFC_ADD
@@ -163,7 +163,7 @@
-class Modify_State_Modify(basic.SimpleDataPlane):
+class modify_state_modify(basic.SimpleDataPlane):
"""Verify basic Flow Modify request is implemented
a) Send OFPT_FLOW_MOD, command = OFPFC_ADD, Action A
@@ -194,7 +194,7 @@
SendPacket(self, pkt, of_ports[0],of_ports[2])
-class Read_State(basic.SimpleProtocol):
+class read_state(basic.SimpleProtocol):
"""Test that a basic Read state request (like flow_stats_get request) does not generate an error
a) Send OFPT_FLOW_MOD, command = OFPFC_ADD
@@ -221,7 +221,7 @@
#Verify Flow_Stats request does not generate errors
Verify_FlowStats(self,match)
-class Send_Packet(basic.SimpleDataPlane):
+class send_packet(basic.SimpleDataPlane):
"""Test packet out function
a) Send packet out message for each dataplane port.
@@ -278,7 +278,7 @@
'Response packet does not match send packet')
-class Packet_In(basic.SimpleDataPlane):
+class packet_in(basic.SimpleDataPlane):
"""Test basic packet_in function
a) Send a simple tcp packet to a dataplane port, without any flow-entry
@@ -312,7 +312,7 @@
'Packet in event is not sent to the controller')
-class Hello(basic.SimpleDataPlane):
+class hello(basic.SimpleDataPlane):
"""Test Hello messages are implemented
a) Create Hello messages from controller
@@ -336,7 +336,7 @@
-class EchoWithoutBody(basic.SimpleProtocol):
+class echo_without_body(basic.SimpleProtocol):
"""Test basic echo-reply is implemented
a) Send echo-request from the controller side, note echo body is empty here.
@@ -359,7 +359,7 @@
self.assertEqual(len(response.data), 0, 'response data non-empty')
-class BarrierRequestReply(basic.SimpleProtocol):
+class barrier_request_reply(basic.SimpleProtocol):
""" Check basic Barrier request is implemented
a) Send OFPT_BARRIER_REQUEST