*** Settings ***
-Documentation Test suite for 3Node Cluster - 100K flows and 10 DPNs in Cluster Scale Up scenario
-Suite Setup ClusterManagement Setup
-Suite Teardown Delete All Sessions
-Library DateTime
-Library OperatingSystem
-Library ../../../libraries/ScaleClient.py
-Resource ../../../libraries/MininetKeywords.robot
-Resource ../../../libraries/ClusterManagement.robot
-Resource ../../../libraries/ClusterOpenFlow.robot
-Variables ../../../variables/Variables.py
+Documentation Test suite for 3Node Cluster - 100K flows and 10 DPNs in Cluster Scale Up scenario
+
+Library DateTime
+Library OperatingSystem
+Library ../../../libraries/ScaleClient.py
+Resource ../../../libraries/MininetKeywords.robot
+Resource ../../../libraries/ClusterManagement.robot
+Resource ../../../libraries/ClusterOpenFlow.robot
+Variables ../../../variables/Variables.py
+
+Suite Setup ClusterManagement Setup
+Suite Teardown Delete All Sessions
+
*** Variables ***
${operation_timeout} 250s
-${oper_ds_timeout} 400s
-${mininet_timeout} 120s
-${flow_count} 100000
-${switch_count} 100
-${swspread} linear
-${tabspread} first
-${fpr} 10
-${nrthreads} 5
-${karaf_log_level} log:set WARN
+${oper_ds_timeout} 400s
+${mininet_timeout} 120s
+${flow_count} 100000
+${switch_count} 100
+${swspread} linear
+${tabspread} first
+${fpr} 10
+${nrthreads} 5
+${karaf_log_level} log:set WARN
${rate_results_file} rate.csv
${time_results_file} time.csv
+
*** Test Cases ***
Check Shards Status And Initialize Variables
[Documentation] Check Status for all shards in OpenFlow application and set the logs across cluster nodes.
ClusterOpenFlow.Check OpenFlow Shards Status
Wait Until Keyword Succeeds 3x 3s ClusterManagement.Run_Karaf_Command_On_List_Or_All ${karaf_log_level}
- ${flows} ${notes} ScaleClient.Generate New Flow Details flows=${flow_count} switches=${switch_count} swspread=${swspread} tabspread=${tabspread}
+ ${flows} ${notes}= ScaleClient.Generate New Flow Details
+ ... flows=${flow_count}
+ ... switches=${switch_count}
+ ... swspread=${swspread}
+ ... tabspread=${tabspread}
Set Suite Variable ${flows}
Get Inventory Config Shard Follower And Leader
[Documentation] Find a leader and followers in the inventory config shard
- ${inventory_leader} ${inventory_followers} ClusterOpenFlow.Get InventoryConfig Shard Status
+ ${inventory_leader} ${inventory_followers}= ClusterOpenFlow.Get InventoryConfig Shard Status
${Follower_Node_1}= Get From List ${Inventory_Followers} 0
${Follower_Node_2}= Get From List ${Inventory_Followers} 1
${Inventory_Leader_List}= Create List ${inventory_leader}
Start Mininet Connect To Follower Node1
[Documentation] Start mininet with connection to follower node1.
- ${mininet_conn_id}= MininetKeywords.Start Mininet Single Controller ${TOOLS_SYSTEM_IP} ${ODL_SYSTEM_${Follower_Node_1}_IP} --topo linear,${switch_count}
+ ${mininet_conn_id}= MininetKeywords.Start Mininet Single Controller
+ ... ${TOOLS_SYSTEM_IP}
+ ... ${ODL_SYSTEM_${Follower_Node_1}_IP}
+ ... --topo linear,${switch_count}
BuiltIn.Set Suite Variable ${mininet_conn_id}
- BuiltIn.Wait Until Keyword Succeeds ${mininet_timeout} 2s ClusterOpenFlow.Verify_Switch_Connections_Running_On_Member ${switch_count} ${Inventory_Leader}
+ BuiltIn.Wait Until Keyword Succeeds
+ ... ${mininet_timeout}
+ ... 2s
+ ... ClusterOpenFlow.Verify_Switch_Connections_Running_On_Member
+ ... ${switch_count}
+ ... ${Inventory_Leader}
Add Bulk Flow via REST From Follower Node2
[Documentation] 100K Flows (1K Flows per DPN) in 100 DPN added via Follower Node2 and verify it gets applied in all instances.
${config_datastore_write_start_time}= DateTime.Get Current Date result_format=timestamp
- ScaleClient.Configure Flows Bulk flow_details=${flows} controllers=${Inventory_Follower_Node2_List} nrthreads=${nrthreads} fpr=${fpr}
+ ScaleClient.Configure Flows Bulk
+ ... flow_details=${flows}
+ ... controllers=${Inventory_Follower_Node2_List}
+ ... nrthreads=${nrthreads}
+ ... fpr=${fpr}
${config_datastore_write_end_time}= DateTime.Get Current Date result_format=timestamp
- ${config_datastore_write_time}= DateTime.Subtract Date From Date ${config_datastore_write_end_time} ${config_datastore_write_start_time}
+ ${config_datastore_write_time}= DateTime.Subtract Date From Date
+ ... ${config_datastore_write_end_time}
+ ... ${config_datastore_write_start_time}
${config_datastore_write_rate}= BuiltIn.Evaluate ${flow_count} / ${config_datastore_write_time}
BuiltIn.Set Suite Variable ${config_datastore_write_start_time}
BuiltIn.Log to console ${\n}
Verify Flows In Switch
[Documentation] Verify 100K flows are installed in 10 switches.
${Mininet_write_start_time}= DateTime.Get Current Date result_format=timestamp
- MininetKeywords.Verify Aggregate Flow From Mininet Session ${mininet_conn_id} ${flow_count} ${operation_timeout}
+ MininetKeywords.Verify Aggregate Flow From Mininet Session
+ ... ${mininet_conn_id}
+ ... ${flow_count}
+ ... ${operation_timeout}
${Mininet_write_end_time}= DateTime.Get Current Date result_format=timestamp
- ${Mininet_write_time}= DateTime.Subtract Date From Date ${Mininet_write_end_time} ${config_datastore_write_start_time}
+ ${Mininet_write_time}= DateTime.Subtract Date From Date
+ ... ${Mininet_write_end_time}
+ ... ${config_datastore_write_start_time}
${Mininet_write_rate}= BuiltIn.Evaluate ${flow_count} / ${Mininet_write_time}
BuiltIn.Log to console ${\n}
BuiltIn.Log to console The Mininet_write_time is ${Mininet_write_time}
Verify Flows In Oper DS
[Documentation] Check Flows in Operational Datastore
- Wait Until Keyword Succeeds ${oper_ds_timeout} 2s ClusterOpenFlow.Check_Flows_Operational_Datastore_On_Member ${flow_count} ${Inventory_Leader}
+ Wait Until Keyword Succeeds
+ ... ${oper_ds_timeout}
+ ... 2s
+ ... ClusterOpenFlow.Check_Flows_Operational_Datastore_On_Member
+ ... ${flow_count}
+ ... ${Inventory_Leader}
${oper_datastore_write_end_time}= DateTime.Get Current Date result_format=timestamp
- ${oper_datastore_write_time}= DateTime.Subtract Date From Date ${oper_datastore_write_end_time} ${config_datastore_write_start_time}
+ ${oper_datastore_write_time}= DateTime.Subtract Date From Date
+ ... ${oper_datastore_write_end_time}
+ ... ${config_datastore_write_start_time}
${oper_datastore_write_rate}= BuiltIn.Evaluate ${flow_count} / ${oper_datastore_write_time}
BuiltIn.Log to console ${\n}
BuiltIn.Log to console The oper_datastore_write_time is ${oper_datastore_write_time}
Stop Mininet Connected To Follower Node1 After Reconcilliation
[Documentation] Stop mininet and exit connection.
MininetKeywords.Stop Mininet And Exit ${mininet_conn_id}
- BuiltIn.Wait Until Keyword Succeeds ${mininet_timeout} 2s ClusterOpenFlow.Verify_Switch_Connections_Running_On_Member 0 ${Inventory_Leader}
+ BuiltIn.Wait Until Keyword Succeeds
+ ... ${mininet_timeout}
+ ... 2s
+ ... ClusterOpenFlow.Verify_Switch_Connections_Running_On_Member
+ ... 0
+ ... ${Inventory_Leader}
Delete All Flows From Follower Node2
[Documentation] 100K Flows deleted via Follower Node2 and verify it gets applied in all instances.
${config_datastore_delete_start_time}= Get Current Date result_format=timestamp
ClusterManagement.Delete From Member ${RFC8040_NODES_API} ${Follower_Node_2}
${config_datastore_delete_end_time}= Get Current Date result_format=timestamp
- ${config_datastore_delete_time}= Subtract Date From Date ${config_datastore_delete_end_time} ${config_datastore_delete_start_time}
+ ${config_datastore_delete_time}= Subtract Date From Date
+ ... ${config_datastore_delete_end_time}
+ ... ${config_datastore_delete_start_time}
${config_datastore_delete_rate}= Evaluate ${flow_count} / ${config_datastore_delete_time}
BuiltIn.Log to console ${\n}
BuiltIn.Log to console The config_datastore_delete_time is ${config_datastore_delete_time}
Log Results And Determine Status
[Documentation] Log results for plotting.
OperatingSystem.Append To File ${rate_results_file} Config DS,OVS Switch,Operational DS\n
- OperatingSystem.Append To File ${rate_results_file} ${config_datastore_write_rate},${Mininet_write_rate},${oper_datastore_write_rate}\n
+ OperatingSystem.Append To File
+ ... ${rate_results_file}
+ ... ${config_datastore_write_rate},${Mininet_write_rate},${oper_datastore_write_rate}\n
OperatingSystem.Append To File ${time_results_file} Config DS,OVS Switch,Operational DS\n
- OperatingSystem.Append To File ${time_results_file} ${config_datastore_write_time},${Mininet_write_time},${oper_datastore_write_time}\n
+ OperatingSystem.Append To File
+ ... ${time_results_file}
+ ... ${config_datastore_write_time},${Mininet_write_time},${oper_datastore_write_time}\n
Code Review / integration / test.git / blobdiff