X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=csit%2Flibraries%2FClusterOpenFlow.robot;h=4936e3de43f70c834cf42a4c3dec40a65775c444;hb=94651ca9711d8eb316721775561e815830bc6c7e;hp=f249a5e7ecddb3e90bfc812198e4d59ff39f2360;hpb=dd4cc54ad35d01822fa8d06a95f428645fe0ec6b;p=integration%2Ftest.git diff --git a/csit/libraries/ClusterOpenFlow.robot b/csit/libraries/ClusterOpenFlow.robot index f249a5e7ec..4936e3de43 100644 --- a/csit/libraries/ClusterOpenFlow.robot +++ b/csit/libraries/ClusterOpenFlow.robot @@ -1,6 +1,7 @@ *** Settings *** Documentation Cluster OpenFlow library. So far this library is only to be used by OpenFlow cluster test as it is very specific for this test. Library RequestsLibrary +Library ${CURDIR}/ScaleClient.py Resource ClusterManagement.robot Resource MininetKeywords.robot Resource Utils.robot @@ -34,12 +35,18 @@ Check OpenFlow Shards Status After Cluster Event Wait Until Keyword Succeeds 90s 1s ClusterOpenFlow.Check OpenFlow Shards Status ${controller_index_list} Get OpenFlow Entity Owner Status For One Device - [Arguments] ${device} ${controller_index} ${controller_index_list}=${EMPTY} + [Arguments] ${device} ${controller_index} ${controller_index_list}=${EMPTY} ${after_stop}=False [Documentation] Check Entity Owner Status and identify owner and successors for the device ${device}. Request is sent to controller ${controller_index}. ${owner} ${successor_list} Wait Until Keyword Succeeds 10s 1s ClusterManagement.Verify_Owner_And_Successors_For_Device device_name=${device} - ... device_type=openflow member_index=${controller_index} candidate_list=${controller_index_list} + ... device_type=openflow member_index=${controller_index} candidate_list=${controller_index_list} after_stop=${after_stop} [Return] ${owner} ${successor_list} +Check OpenFlow Device Owner + [Arguments] ${device} ${controller_index} ${expected_owner} ${expected_candidate_list}=${EMPTY} + [Documentation] Check owner and candidates for the device ${device}. Request is sent to controller ${controller_index}. + ${owner} ${successor_list} ClusterManagement.Verify_Owner_And_Successors_For_Device device_name=${device} device_type=openflow member_index=${controller_index} candidate_list=${expected_candidate_list} + Should Be Equal ${owner} ${expected_owner} + Check OpenFlow Network Operational Information For Sample Topology [Arguments] ${controller_index_list}=${EMPTY} [Documentation] Check devices in tree,2 are in operational inventory and topology in all instances in ${controller_index_list}. @@ -54,7 +61,9 @@ Check No OpenFlow Network Operational Information [Arguments] ${controller_index_list}=${EMPTY} [Documentation] Check device is not in operational inventory or topology in all cluster instances in ${controller_index_list}. ${dictionary} Create Dictionary openflow=0 - Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${OPERATIONAL_NODES_API} dictionary=${dictionary} member_index_list=${controller_index_list} + CompareStream.Run_Keyword_If_At_Least_Neon Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_No_Content_Member_List_Or_All uri=${OPERATIONAL_NODES_API} member_index_list=${controller_index_list} + CompareStream.Run_Keyword_If_At_Most_Fluorine Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${OPERATIONAL_NODES_API} dictionary=${dictionary} + ... member_index_list=${controller_index_list} ${dictionary} Create Dictionary openflow=0 Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${OPERATIONAL_TOPO_API} dictionary=${dictionary} member_index_list=${controller_index_list} @@ -69,6 +78,15 @@ Add Sample Flow And Verify ClusterManagement.Put_As_Json_And_Check_Member_List_Or_All ${config_table_0}/flow/1 ${body} ${controller_index} ${controller_index_list} Wait Until Keyword Succeeds 15s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${operational_table_0} dictionary=${dictionary} member_index_list=${controller_index_list} +Verify Sample Flow + [Arguments] ${controller_index_list}=${EMPTY} + [Documentation] Verify sample flow gets applied in all instances in ${controller_index_list}. + # There are slight differences on the way He and Li plugin display table information. He plugin has an additional Hashmap field + # replicating some of the matches in the flows section. Same comment applies for further keywords. + Run Keyword If '${ODL_OF_PLUGIN}' == 'helium' Set Test Variable &{dictionary} 10.0.1.0/24=2 "output-node-connector":"1"=1 + Run Keyword If '${ODL_OF_PLUGIN}' == 'lithium' Set Test Variable &{dictionary} 10.0.1.0/24=1 "output-node-connector":"1"=1 + Wait Until Keyword Succeeds 15s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${operational_table_0} dictionary=${dictionary} member_index_list=${controller_index_list} + Modify Sample Flow And Verify [Arguments] ${controller_index} ${controller_index_list}=${EMPTY} [Documentation] Modify sample flow in ${controller_index} and verify it gets applied in all instances in ${controller_index_list}. @@ -81,7 +99,7 @@ Modify Sample Flow And Verify Delete Sample Flow And Verify [Arguments] ${controller_index} ${controller_index_list}=${EMPTY} [Documentation] Delete sample flow in Owner and verify it gets removed from all instances. - ${dictionary}= Create Dictionary 10.0.2.0/24=0 + ${dictionary}= Create Dictionary 10.0.1.0/24=0 ClusterManagement.Delete_And_Check_Member_List_Or_All ${config_table_0}/flow/1 ${controller_index} ${controller_index_list} Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${operational_table_0} dictionary=${dictionary} member_index_list=${controller_index_list} @@ -118,4 +136,66 @@ Take OpenFlow Device Link Up and Verify ${ouput}= MininetKeywords.Send Mininet Command ${mininet_conn_id} link s1 s2 up Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${operational_port_1} dictionary=${dictionary} member_index_list=${controller_index_list} ${dictionary} Create Dictionary openflow:1=21 openflow:2=19 openflow:3=19 - Wait Until Keyword Succeeds 5s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${OPERATIONAL_TOPO_API} dictionary=${dictionary} member_index_list=${controller_index_list} + Wait Until Keyword Succeeds 10s 1s ClusterManagement.Check_Item_Occurrence_Member_List_Or_All uri=${OPERATIONAL_TOPO_API} dictionary=${dictionary} member_index_list=${controller_index_list} + +Verify Switch Connections Running On Member + [Arguments] ${switch_count} ${member_index} + [Documentation] Check if number of Switch connections on member of given index is equal to ${switch_count}. + ${count} = ScaleClient.Get_Switches_Count controller=${ODL_SYSTEM_${member_index}_IP} + BuiltIn.Should_Be_Equal_As_Numbers ${switch_count} ${count} + +Check Flows Operational Datastore On Member + [Arguments] ${flow_count} ${member_index} + [Documentation] Check if number of Operational Flows on member of given index is equal to ${flow_count}. + ${sw} ${reported_flow} ${found_flow}= ScaleClient.Flow Stats Collected controller=${ODL_SYSTEM_${member_index}_IP} + BuiltIn.Should_Be_Equal_As_Numbers ${flow_count} ${found_flow} + +Check Linear Topology On Member + [Arguments] ${switches} ${member_index}=1 + [Documentation] Check Linear topology. + ${session} = Resolve_Http_Session_For_Member member_index=${member_index} + ${resp} RequestsLibrary.Get Request ${session} ${OPERATIONAL_TOPO_API} + Log ${resp.content} + Should Be Equal As Strings ${resp.status_code} 200 + FOR ${switch} IN RANGE 1 ${switches+1} + Should Contain ${resp.content} "node-id":"openflow:${switch}" + Should Contain ${resp.content} "tp-id":"openflow:${switch}:1" + Should Contain ${resp.content} "tp-id":"openflow:${switch}:2" + Should Contain ${resp.content} "source-tp":"openflow:${switch}:2" + Should Contain ${resp.content} "dest-tp":"openflow:${switch}:2" + ${edge} Evaluate ${switch}==1 or ${switch}==${switches} + Run Keyword Unless ${edge} Should Contain ${resp.content} "tp-id":"openflow:${switch}:3" + Run Keyword Unless ${edge} Should Contain ${resp.content} "source-tp":"openflow:${switch}:3" + Run Keyword Unless ${edge} Should Contain ${resp.content} "dest-tp":"openflow:${switch}:3 + END + +Check No Switches On Member + [Arguments] ${switches} ${member_index}=1 + [Documentation] Check no switch is in topology + ${session} = Resolve_Http_Session_For_Member member_index=${member_index} + ${resp} RequestsLibrary.Get Request ${session} ${OPERATIONAL_TOPO_API} + Log ${resp.content} + Should Be Equal As Strings ${resp.status_code} 200 + FOR ${switch} IN RANGE 1 ${switches+1} + Should Not Contain ${resp.content} openflow:${switch} + END + +Check Number Of Flows On Member + [Arguments] ${flows} ${member_index}=1 + [Documentation] Check number of flows in the inventory. + ${session} = Resolve_Http_Session_For_Member member_index=${member_index} + ${resp}= RequestsLibrary.Get Request ${session} ${OPERATIONAL_NODES_API} + Log ${resp.content} + Should Be Equal As Strings ${resp.status_code} 200 + ${count}= Get Count ${resp.content} "priority" + Should Be Equal As Integers ${count} ${flows} + +Check Number Of Groups On Member + [Arguments] ${groups} ${member_index}=1 + [Documentation] Check number of groups in the inventory. + ${session} = Resolve_Http_Session_For_Member member_index=${member_index} + ${resp}= RequestsLibrary.Get Request ${session} ${OPERATIONAL_NODES_API} + Log ${resp.content} + Should Be Equal As Strings ${resp.status_code} 200 + ${group_count}= Get Count ${resp.content} "group-type" + Should Be Equal As Integers ${group_count} ${groups}