blob: 4cf61b3d8c7ceaf2d3af8131e26ea0e891111806 [file] [log] [blame]
Joey Armstrong888f1ee2023-01-11 17:14:30 -05001# Copyright 2017-2023 Open Networking Foundation (ONF) and the ONF Contributors
Kailash6f5acb62019-08-28 14:38:45 -07002#
3# Licensed under the Apache License, Version 2.0 (the "License");
4# you may not use this file except in compliance with the License.
5# You may obtain a copy of the License at
6#
7# http://www.apache.org/licenses/LICENSE-2.0
8#
9# Unless required by applicable law or agreed to in writing, software
10# distributed under the License is distributed on an "AS IS" BASIS,
11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12# See the License for the specific language governing permissions and
13# limitations under the License.
Kailash6f5acb62019-08-28 14:38:45 -070014# onos common functions
15
16*** Settings ***
17Documentation Library for various utilities
18Library SSHLibrary
Kailash6f5acb62019-08-28 14:38:45 -070019Library String
20Library DateTime
21Library Process
22Library Collections
23Library RequestsLibrary
24Library OperatingSystem
Matteo Scandoloeb26a842020-05-08 10:06:24 -070025Resource ./flows.robot
Kailash6f5acb62019-08-28 14:38:45 -070026
TorstenThiemeb198c482020-12-14 19:45:23 +000027*** Variables ***
28@{connection_list}
TorstenThieme2ddb6e82022-02-08 14:44:24 +000029${alias} ONOS_SSH
TorstenThieme1f58cac2022-02-10 15:58:38 +000030${ssh_read_timeout} 60s
TorstenThieme2ddb6e82022-02-08 14:44:24 +000031${ssh_prompt} karaf@root >
32${ssh_regexp_prompt} REGEXP:k.*a.*r.*a.*f.*@.*r.*o.*o.*t.* .*>.*
TorstenThieme5fef5a52022-05-12 12:12:31 +000033${regexp_prompt} (?ms)(.*)k(.*)a(.*)r(.*)a(.*)f(.*)@(.*)r(.*)o(.*)o(.*)t(.*) (.*)>(.*)
TorstenThieme2ddb6e82022-02-08 14:44:24 +000034${ssh_width} 400
35${disable_highlighter} setopt disable-highlighter
TorstenThieme36a38a82022-02-09 15:51:30 +000036# ${keep_alive_interval} is set to 0s means sending the keepalive packet is disabled!
37${keep_alive_interval} 0s
TorstenThiemeb198c482020-12-14 19:45:23 +000038
Kailash6f5acb62019-08-28 14:38:45 -070039*** Keywords ***
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070040
41Open ONOS SSH Connection
42 [Documentation] Establishes an ssh connection to ONOS contoller
43 [Arguments] ${host} ${port} ${user}=karaf ${pass}=karaf
TorstenThieme2ddb6e82022-02-08 14:44:24 +000044 ${conn_id}= SSHLibrary.Open Connection ${host} port=${port} timeout=${ssh_read_timeout} alias=${alias}
TorstenThieme36a38a82022-02-09 15:51:30 +000045 SSHLibrary.Login username=${user} password=${pass} keep_alive_interval=${keep_alive_interval}
TorstenThieme1d1413b2022-02-04 12:41:01 +000046 # set excepted prompt and terminal width to suppress unwanted line feeds
TorstenThieme2ddb6e82022-02-08 14:44:24 +000047 SSHLibrary.Set Client Configuration prompt=${ssh_prompt} width=${ssh_width}
TorstenThiemeb198c482020-12-14 19:45:23 +000048 ${conn_list_entry}= Create Dictionary conn_id=${conn_id} user=${user} pass=${pass}
TorstenThieme1d1413b2022-02-04 12:41:01 +000049 ... host=${host} port=${port} alias=${alias}
TorstenThiemeb198c482020-12-14 19:45:23 +000050 Append To List ${connection_list} ${conn_list_entry}
51 ${conn_list_id}= Get Index From List ${connection_list} ${conn_list_entry}
52 Set Global Variable ${connection_list}
TorstenThieme1d1413b2022-02-04 12:41:01 +000053 # disable highlighting to suppress control sequences
TorstenThieme2ddb6e82022-02-08 14:44:24 +000054 ${output}= Execute Single ONOS CLI Command ${conn_id} ${disable_highlighter} do_reconnect=False
TorstenThiemeb198c482020-12-14 19:45:23 +000055 [Return] ${conn_list_id}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070056
TorstenThieme4e2168e2021-06-22 14:01:47 +000057Execute ONOS CLI Command use single connection
58 [Documentation] Execute ONOS CLI Command use an Open Connection
59 ... In case no connection is open a connection will be opened
TorstenThieme1d1413b2022-02-04 12:41:01 +000060 ... Using Write and Read instead of Execute Command to keep connection alive.
TorstenThieme4e2168e2021-06-22 14:01:47 +000061 [Arguments] ${host} ${port} ${cmd}
62 ${connection_list_id}= Get Conn List Id ${host} ${port}
63 ${connection_list_id}= Run Keyword If "${connection_list_id}"=="${EMPTY}"
64 ... Open ONOS SSH Connection ${host} ${port}
65 ... ELSE Set Variable ${connection_list_id}
66 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
TorstenThieme2ddb6e82022-02-08 14:44:24 +000067 ${output}= Execute Single ONOS CLI Command ${connection_entry.conn_id} ${cmd}
TorstenThieme36a38a82022-02-09 15:51:30 +000068 ... connection_list_id=${connection_list_id}
TorstenThieme2ddb6e82022-02-08 14:44:24 +000069 [Return] ${output}
70
71Execute Single ONOS CLI Command
72 [Documentation] Executes ONOS CLI Command on current connection
73 ... Using Write and Read instead of Execute Command to keep connection alive.
TorstenThieme36a38a82022-02-09 15:51:30 +000074 [Arguments] ${conn_id} ${cmd} ${do_reconnect}=True ${connection_list_id}=${EMPTY}
TorstenThieme2ddb6e82022-02-08 14:44:24 +000075 Log Command: ${cmd}
76 SSHLibrary.Switch Connection ${conn_id}
77 # get connection settings, has no functional reason, only for info
TorstenThieme1d1413b2022-02-04 12:41:01 +000078 ${connection_info}= SSHLibrary.Get Connection
TorstenThiemeedc50672022-02-14 10:32:10 +000079 # write the command until it is mirrored
80 ${PassOrFail} ${Written}= Run Keyword And Ignore Error Write Until Expected Output ${cmd} expected=${cmd}
81 ... timeout=5s retry_interval=1s
TorstenThieme2ddb6e82022-02-08 14:44:24 +000082 Run Keyword If '${PassOrFail}'=='FAIL' and ${do_reconnect} Reconnect ONOS SSH Connection ${connection_list_id}
TorstenThiemeedc50672022-02-14 10:32:10 +000083 Run Keyword If '${PassOrFail}'=='FAIL' Write Until Expected Output ${cmd}${\n} expected=${cmd} timeout=5s
84 ... retry_interval=1s
85 # set up the comand - press enter key!
86 ${Written}= Write ${EMPTY}
TorstenThieme2ddb6e82022-02-08 14:44:24 +000087 ${PassOrFail} ${output}= Run Keyword And Ignore Error Read Until Prompt strip_prompt=True
TorstenThieme1d1413b2022-02-04 12:41:01 +000088 Log Result_values: ${output}
TorstenThieme1f58cac2022-02-10 15:58:38 +000089 # remove error printout from ssh library in case of failure
90 ${output}= Run Keyword If '${PassOrFail}'=='FAIL' Fetch From Right ${output} Output:
91 ... ELSE Set Variable ${output}
92 ${output}= Run Keyword If '${PassOrFail}'=='FAIL' Get Substring ${output} 1
93 ... ELSE Set Variable ${output}
TorstenThieme5fef5a52022-05-12 12:12:31 +000094 ${match} ${grp1} ${grp2} ${grp3} ${grp4} ${grp5} ${grp6} ${grp7} ${grp8} ${grp9}
95 ... ${grp10} ${grp11} ${grp12} ${grp13}= Run Keyword If '${PassOrFail}'=='FAIL'
96 ... Should Match Regexp ${output} ${regexp_prompt} SSH access failed for '${cmd}'! False
97 ${output}= Run Keyword If '${PassOrFail}'=='FAIL' Catenate SEPARATOR= ${grp1} ${grp2} ${grp3}
98 ... ${grp4} ${grp5} ${grp6} ${grp7} ${grp8} ${grp9} ${grp10} ${grp11} ${grp12} ${grp13}
99 ... ELSE Set Variable ${output}
TorstenThieme1d1413b2022-02-04 12:41:01 +0000100 # we do not use strip of escape sequences integrated in ssh lib, we do it by ourself to have it under control
101 ${output}= Remove String Using Regexp ${output} \\x1b[>=]{0,1}(?:\\[[0-?]*(?:[hlm])[~]{0,1})*
102 # remove the endless spaces and two carrige returns at the end of output
103 ${output}= Remove String Using Regexp ${output} \\s*\\r \\r
104 # now we have the plain output text
105 Log Stripped Result_values: ${output}
TorstenThieme4e2168e2021-06-22 14:01:47 +0000106 [Return] ${output}
107
108Get Conn List Id
109 [Documentation] Looks up for an Open Connection with passed host and port in conection list
110 ... First match connection will be used.
111 [Arguments] ${host} ${port}
112 ${connection_list_id}= Set Variable ${EMPTY}
113 ${match}= Set Variable False
114 ${length}= Get Length ${connection_list}
115 FOR ${INDEX} IN RANGE 0 ${length}
116 #${Item}= Get From List ${connection_list} ${INDEX}
117 ${conndata}= Get Connection ${connection_list[${INDEX}].conn_id}
118 ${match}= Set Variable If '${conndata.host}'=='${host}' and '${conndata.port}'=='${port}' True False
119 ${connection_list_id}= Set Variable If ${match} ${INDEX} ${EMPTY}
120 Exit For Loop If ${match}
121 END
122 [Return] ${connection_list_id}
123
TorstenThiemeb198c482020-12-14 19:45:23 +0000124Reconnect ONOS SSH Connection
125 [Documentation] Reconnect an SSH Connection
126 [Arguments] ${connection_list_id}
127 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
128 ${user}= Get From Dictionary ${connection_entry} user
129 ${pass}= Get From Dictionary ${connection_entry} pass
130 ${oldconndata}= Get Connection ${connection_entry.conn_id}
TorstenThieme1d1413b2022-02-04 12:41:01 +0000131 ${match}= Set Variable If
132 ... "${oldconndata.host}"=="${connection_entry.host}" and "${oldconndata.port}"=="${connection_entry.port}"
133 ... True False
134 Run Keyword If ${match} SSHLibrary.Switch Connection ${connection_entry.conn_id}
135 Run Keyword If ${match} Run Keyword And Ignore Error SSHLibrary.Close Connection
136 ${conn_id}= SSHLibrary.Open Connection ${connection_entry.host} port=${connection_entry.port}
TorstenThieme2ddb6e82022-02-08 14:44:24 +0000137 ... timeout=${ssh_read_timeout} alias=${alias}
TorstenThieme36a38a82022-02-09 15:51:30 +0000138 SSHLibrary.Login username=${user} password=${pass} keep_alive_interval=${keep_alive_interval}
TorstenThieme1d1413b2022-02-04 12:41:01 +0000139 # set excepted prompt and terminal width to suppress unwanted line feeds
TorstenThieme2ddb6e82022-02-08 14:44:24 +0000140 SSHLibrary.Set Client Configuration prompt=${ssh_prompt} width=${ssh_width}
TorstenThiemeb198c482020-12-14 19:45:23 +0000141 ${conn_list_entry}= Create Dictionary conn_id=${conn_id} user=${user} pass=${pass}
TorstenThieme1d1413b2022-02-04 12:41:01 +0000142 ... host=${connection_entry.host} port=${connection_entry.port} alias=${alias}
TorstenThiemeb198c482020-12-14 19:45:23 +0000143 Set List Value ${connection_list} ${connection_list_id} ${conn_list_entry}
144 Set Global Variable ${connection_list}
TorstenThieme1d1413b2022-02-04 12:41:01 +0000145 # disable highlighting to suppress control sequences
TorstenThieme2ddb6e82022-02-08 14:44:24 +0000146 ${output}= Execute Single ONOS CLI Command ${conn_id} ${disable_highlighter} do_reconnect=False
TorstenThiemeb198c482020-12-14 19:45:23 +0000147
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700148Close ONOS SSH Connection
149 [Documentation] Close an SSH Connection
TorstenThiemeb198c482020-12-14 19:45:23 +0000150 [Arguments] ${connection_list_id}
151 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
152 ${connection_alias}= Get From Dictionary ${connection_entry} conn_id
153 ${oldconndata}= Get Connection ${connection_entry.conn_id}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700154 SSHLibrary.Switch Connection ${connection_alias}
TorstenThiemebcf14612021-01-27 10:19:18 +0000155 Run Keyword And Ignore Error SSHLibrary.Close Connection
TorstenThiemeb198c482020-12-14 19:45:23 +0000156 Remove From List ${connection_list} ${connection_list_id}
157 Set Global Variable ${connection_list}
158
159Close All ONOS SSH Connections
160 [Documentation] Close all SSH Connection and clear connection list.
161 SSHLibrary.Close All Connections
162 @{connection_list} Create List
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700163
Kailash6f5acb62019-08-28 14:38:45 -0700164Validate OLT Device in ONOS
Zack Williamsa8fe75a2020-01-10 14:25:27 -0700165 # FIXME use volt-olts to check that the OLT is ONOS
Kailash6f5acb62019-08-28 14:38:45 -0700166 [Arguments] ${serial_number}
Zack Williamsec53a1b2019-09-16 15:50:52 -0700167 [Documentation] Checks if olt has been connected to ONOS
Kailash6f5acb62019-08-28 14:38:45 -0700168 ${resp}= Get Request ONOS onos/v1/devices
169 ${jsondata}= To Json ${resp.content}
170 Should Not Be Empty ${jsondata['devices']}
171 ${length}= Get Length ${jsondata['devices']}
172 @{serial_numbers}= Create List
Andy Bavierb63f6d22020-03-12 15:34:37 -0700173 ${matched}= Set Variable False
Zack Williamsec53a1b2019-09-16 15:50:52 -0700174 FOR ${INDEX} IN RANGE 0 ${length}
175 ${value}= Get From List ${jsondata['devices']} ${INDEX}
176 ${of_id}= Get From Dictionary ${value} id
177 ${sn}= Get From Dictionary ${value} serial
Andy Bavierb63f6d22020-03-12 15:34:37 -0700178 ${matched}= Set Variable If '${sn}' == '${serial_number}' True False
179 Exit For Loop If ${matched}
Zack Williamsec53a1b2019-09-16 15:50:52 -0700180 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700181 Should Be True ${matched} No match for ${serial_number} found
Kailash57210eb2019-08-30 13:27:19 -0700182 [Return] ${of_id}
Kailash6f5acb62019-08-28 14:38:45 -0700183
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700184Get ONU Port in ONOS
Hardik Windlass1ed2eee2021-06-25 09:51:03 +0000185 [Arguments] ${onu_serial_number} ${olt_of_id} ${onu_uni_id}=1
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700186 [Documentation] Retrieves ONU port for the ONU in ONOS
Hardik Windlass1ed2eee2021-06-25 09:51:03 +0000187 ${onu_serial_number}= Catenate SEPARATOR=- ${onu_serial_number} ${onu_uni_id}
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700188 ${resp}= Get Request ONOS onos/v1/devices/${olt_of_id}/ports
189 ${jsondata}= To Json ${resp.content}
190 Should Not Be Empty ${jsondata['ports']}
191 ${length}= Get Length ${jsondata['ports']}
192 @{ports}= Create List
Andy Bavierb63f6d22020-03-12 15:34:37 -0700193 ${matched}= Set Variable False
Zack Williamsec53a1b2019-09-16 15:50:52 -0700194 FOR ${INDEX} IN RANGE 0 ${length}
195 ${value}= Get From List ${jsondata['ports']} ${INDEX}
196 ${annotations}= Get From Dictionary ${value} annotations
197 ${onu_port}= Get From Dictionary ${value} port
198 ${portName}= Get From Dictionary ${annotations} portName
Andy Bavierb63f6d22020-03-12 15:34:37 -0700199 ${matched}= Set Variable If '${portName}' == '${onu_serial_number}' True False
200 Exit For Loop If ${matched}
Zack Williamsec53a1b2019-09-16 15:50:52 -0700201 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700202 Should Be True ${matched} No match for ${onu_serial_number} found
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700203 [Return] ${onu_port}
204
TorstenThieme9b25aab2021-12-16 15:59:45 +0000205Get Onu Ports in ONOS For ALL UNI per ONU
206 [Documentation] Retrieves ONU port(s) for the ONU in ONOS for all UNI-IDs, list of ports will return!
207 [Arguments] ${onu_serial_number} ${olt_of_id}
208 @{uni_id_list}= Create List
209 @{port_list}= Create List
210 FOR ${I} IN RANGE 0 ${num_all_onus}
211 ${src}= Set Variable ${hosts.src[${I}]}
212 Continue For Loop If "${src['onu']}" != "${onu_serial_number}"
213 ${uni_id}= Set Variable ${src['uni_id']}
214 # make sure all actions do only once per uni_id
215 ${id}= Get Index From List ${uni_id_list} ${uni_id}
216 Continue For Loop If -1 != ${id}
217 Append To List ${uni_id_list} ${uni_id}
218 ${onu_port}= Wait Until Keyword Succeeds ${timeout} 2s Get ONU Port in ONOS ${onu_serial_number}
219 ... ${olt_of_id} ${uni_id}
220 Append To List ${port_list} ${onu_port}
221 END
222 [return] ${port_list}
223
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530224Get NNI Port in ONOS
225 [Arguments] ${olt_of_id}
226 [Documentation] Retrieves NNI port for the OLT in ONOS
227 ${resp}= Get Request ONOS onos/v1/devices/${olt_of_id}/ports
228 ${jsondata}= To Json ${resp.content}
229 Should Not Be Empty ${jsondata['ports']}
230 ${length}= Get Length ${jsondata['ports']}
231 @{ports}= Create List
232 ${matched}= Set Variable False
233 FOR ${INDEX} IN RANGE 0 ${length}
234 ${value}= Get From List ${jsondata['ports']} ${INDEX}
235 ${annotations}= Get From Dictionary ${value} annotations
236 ${nni_port}= Get From Dictionary ${value} port
237 ${nniPortName}= Catenate SEPARATOR= nni- ${nni_port}
238 ${portName}= Get From Dictionary ${annotations} portName
239 ${matched}= Set Variable If '${portName}' == '${nniPortName}' True False
240 Exit For Loop If ${matched}
241 END
242 Should Be True ${matched} No match for NNI found for ${olt_of_id}
243 [Return] ${nni_port}
244
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700245Get FabricSwitch in ONOS
246 [Documentation] Returns of_id of the Fabric Switch in ONOS
247 ${resp}= Get Request ONOS onos/v1/devices
248 ${jsondata}= To Json ${resp.content}
249 Should Not Be Empty ${jsondata['devices']}
250 ${length}= Get Length ${jsondata['devices']}
Andy Bavierb63f6d22020-03-12 15:34:37 -0700251 ${matched}= Set Variable False
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700252 FOR ${INDEX} IN RANGE 0 ${length}
253 ${value}= Get From List ${jsondata['devices']} ${INDEX}
254 ${of_id}= Get From Dictionary ${value} id
255 ${type}= Get From Dictionary ${value} type
Andy Bavierb63f6d22020-03-12 15:34:37 -0700256 ${matched}= Set Variable If '${type}' == "SWITCH" True False
257 Exit For Loop If ${matched}
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700258 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700259 Should Be True ${matched} No fabric switch found
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700260 [Return] ${of_id}
261
Andrea Campanella4c404632020-08-26 14:41:36 +0200262Get Master Instace in ONOS
263 [Arguments] ${of_id}
264 [Documentation] Returns nodeId of the Master instace for a giver device in ONOS
265 ${resp}= Get Request ONOS onos/v1/mastership/${of_id}/master
266 ${jsondata}= To Json ${resp.content}
267 Should Not Be Empty ${jsondata['nodeId']}
268 ${master_node}= Get From Dictionary ${jsondata} nodeId
269 [Return] ${master_node}
270
Matteo Scandolo7bdbe2d2021-11-29 15:48:25 -0800271Verify LLDP Flow Added
272 [Arguments] ${ip} ${port} ${olt_of_id} ${expected_flows}
273 [Documentation] Matches for total number of LLDP flows added for one OLT
274 ${lldp_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
275 ... flows -s ADDED ${olt_of_id} | grep -v deviceId | grep ETH_TYPE:lldp | grep -v ETH_TYPE:arp
276 ${lldp_flows_added_count}= Get Line Count ${lldp_flows_added}
277 Should Be Equal As Integers ${lldp_flows_added_count} ${expected_flows}
278
Hardik Windlass21807632020-04-14 16:24:55 +0530279Verify Subscriber Access Flows Added for ONU
280 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${c_tag} ${s_tag}
281 [Documentation] Verifies if the Subscriber Access Flows are added in ONOS for the ONU
282 # Verify upstream table=0 flow
283 ${upstream_flow_0_cmd}= Catenate SEPARATOR=
284 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:0 |
285 ... grep VLAN_ID:${c_tag} | grep transition=TABLE:1
TorstenThieme4e2168e2021-06-22 14:01:47 +0000286 ${upstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530287 ... ${upstream_flow_0_cmd}
288 Should Not Be Empty ${upstream_flow_0_added}
289 # Verify upstream table=1 flow
290 ${flow_vlan_push_cmd}= Catenate SEPARATOR=
291 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
292 ... grep VLAN_PUSH | grep VLAN_ID:${s_tag} | grep OUTPUT:${nni_port}
TorstenThieme4e2168e2021-06-22 14:01:47 +0000293 ${upstream_flow_1_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530294 ... ${flow_vlan_push_cmd}
295 Should Not Be Empty ${upstream_flow_1_added}
296 # Verify downstream table=0 flow
297 ${flow_vlan_pop_cmd}= Catenate SEPARATOR=
298 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
299 ... grep VLAN_POP | grep transition=TABLE:1
TorstenThieme4e2168e2021-06-22 14:01:47 +0000300 ${downstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530301 ... ${flow_vlan_pop_cmd}
302 Should Not Be Empty ${downstream_flow_0_added}
303 # Verify downstream table=1 flow
304 ${downstream_flow_1_cmd}= Catenate SEPARATOR=
305 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${c_tag} |
306 ... grep VLAN_ID:0 | grep OUTPUT:${onu_port}
TorstenThieme4e2168e2021-06-22 14:01:47 +0000307 ${downstream_flow_1_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530308 ... ${downstream_flow_1_cmd}
309 Should Not Be Empty ${downstream_flow_1_added}
310 # Verify ipv4 dhcp upstream flow
311 ${upstream_flow_ipv4_cmd}= Catenate SEPARATOR=
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200312 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep ETH_TYPE:ipv4 |
Andrea Campanella08678e12020-09-18 17:40:22 +0200313 ... grep IP_PROTO:17 | grep UDP_SRC:68 | grep UDP_DST:67 | grep VLAN_ID:${c_tag} |
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200314 ... grep OUTPUT:CONTROLLER
TorstenThieme4e2168e2021-06-22 14:01:47 +0000315 ${upstream_flow_ipv4_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530316 ... ${upstream_flow_ipv4_cmd}
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200317 Should Not Be Empty ${upstream_flow_ipv4_added}
Hardik Windlass21807632020-04-14 16:24:55 +0530318 # Verify ipv4 dhcp downstream flow
319 # Note: This flow will be one per nni per olt
320 ${downstream_flow_ipv4_cmd}= Catenate SEPARATOR=
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200321 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep ETH_TYPE:ipv4 |
322 ... grep IP_PROTO:17 | grep UDP_SRC:67 | grep UDP_DST:68 | grep OUTPUT:CONTROLLER
TorstenThieme4e2168e2021-06-22 14:01:47 +0000323 ${downstream_flow_ipv4_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass21807632020-04-14 16:24:55 +0530324 ... ${downstream_flow_ipv4_cmd}
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200325 Should Not Be Empty ${downstream_flow_ipv4_added}
Hardik Windlass21807632020-04-14 16:24:55 +0530326
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530327Verify Subscriber Access Flows Added for ONU DT
Hardik Windlass25e11702020-03-30 20:05:19 +0530328 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${s_tag}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530329 [Documentation] Verifies if the Subscriber Access Flows are added in ONOS for the ONU
330 # Verify upstream table=0 flow
TorstenThieme4e2168e2021-06-22 14:01:47 +0000331 ${upstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass25e11702020-03-30 20:05:19 +0530332 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:Any | grep transition=TABLE:1
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530333 Should Not Be Empty ${upstream_flow_0_added}
334 # Verify upstream table=1 flow
335 ${flow_vlan_push_cmd}= Catenate SEPARATOR=
Hardik Windlass25e11702020-03-30 20:05:19 +0530336 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:Any |
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530337 ... grep VLAN_PUSH | grep VLAN_ID:${s_tag} | grep OUTPUT:${nni_port}
TorstenThieme4e2168e2021-06-22 14:01:47 +0000338 ${upstream_flow_1_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530339 ... ${flow_vlan_push_cmd}
340 Should Not Be Empty ${upstream_flow_1_added}
341 # Verify downstream table=0 flow
342 ${flow_vlan_pop_cmd}= Catenate SEPARATOR=
Hardik Windlass25e11702020-03-30 20:05:19 +0530343 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530344 ... grep VLAN_POP | grep transition=TABLE:1
TorstenThieme4e2168e2021-06-22 14:01:47 +0000345 ${downstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530346 ... ${flow_vlan_pop_cmd}
347 Should Not Be Empty ${downstream_flow_0_added}
348 # Verify downstream table=1 flow
TorstenThieme4e2168e2021-06-22 14:01:47 +0000349 ${downstream_flow_1_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass25e11702020-03-30 20:05:19 +0530350 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:Any | grep OUTPUT:${onu_port}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530351 Should Not Be Empty ${downstream_flow_1_added}
352
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000353Verify Subscriber Access Flows Added for DT FTTB
354 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${s_tag} ${c_tag}
355 [Documentation] Verifies if the Subscriber Access Flows are added in ONOS for the ONU
356 # Upstream
357 # ONU
358 ${us_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
359 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} | grep transition=TABLE:1
360 Should Not Be Empty ${us_flow_onu_added}
361 # OLT
362 ${us_flow_olt_cmd}= Catenate
363 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
364 ... grep VLAN_ID:${s_tag} | grep OUTPUT:${nni_port}
365 ${us_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
366 ... ${us_flow_olt_cmd}
367 Should Not Be Empty ${us_flow_olt_added}
368 # Downstream
369 # OLT
370 ${ds_flow_olt_cmd}= Catenate
371 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
372 ... grep VLAN_ID:${c_tag} | grep transition=TABLE:1
373 ${ds_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
374 ... ${ds_flow_olt_cmd}
375 Should Not Be Empty ${ds_flow_olt_added}
376 # ONU
377 ${ds_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
378 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${c_tag} | grep OUTPUT:${onu_port}
379 Should Not Be Empty ${ds_flow_onu_added}
380
381Verify DPU ANCP Flows Added for DT FTTB
382 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${s_tag} ${c_tag}
383 [Documentation] Verifies if the DPU ANCP Flows are added in ONOS for the ONU
384 # Upstream
385 # ONU
386 ${us_flow_onu_cmd}= Catenate
387 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
388 ... grep VLAN_ID:${s_tag} | grep transition=TABLE:1
389 ${us_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
390 ... ${us_flow_onu_cmd}
391 Should Not Be Empty ${us_flow_onu_added}
392 # OLT
393 ${us_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
394 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${s_tag} | grep OUTPUT:${nni_port}
395 Should Not Be Empty ${us_flow_olt_added}
396 # Downstream
397 # OLT
398 ${ds_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
399 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} | grep transition=TABLE:1
400 Should Not Be Empty ${ds_flow_olt_added}
401 # ONU
402 ${ds_flow_onu_cmd}= Catenate
403 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
404 ... grep VLAN_ID:${c_tag} | grep OUTPUT:${onu_port}
405 ${ds_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
406 ... ${ds_flow_onu_cmd}
407 Should Not Be Empty ${ds_flow_onu_added}
408
409Verify DPU MGMT Flows Added for DT FTTB
410 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${s_tag} ${c_tag}
411 [Documentation] Verifies if the DPU MGMT Flows are added in ONOS for the ONU
412 # Upstream
413 # ONU
414 ${us_flow_onu_cmd}= Catenate
415 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
416 ... grep VLAN_ID:${s_tag} | grep transition=TABLE:1
417 ${us_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
418 ... ${us_flow_onu_cmd}
419 Should Not Be Empty ${us_flow_onu_added}
420 # OLT
421 ${us_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
422 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${s_tag} | grep OUTPUT:${nni_port}
423 Should Not Be Empty ${us_flow_olt_added}
424 # Downstream
425 # OLT
426 ${ds_flow_olt_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
427 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} | grep transition=TABLE:1
428 Should Not Be Empty ${ds_flow_olt_added}
429 # ONU
430 ${ds_flow_onu_cmd}= Catenate
431 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
432 ... grep VLAN_ID:${c_tag} | grep OUTPUT:${onu_port}
433 ${ds_flow_onu_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
434 ... ${ds_flow_onu_cmd}
435 Should Not Be Empty ${ds_flow_onu_added}
436
437Verify ONOS Flows Added for DT FTTB
438 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${service}
439 [Documentation] Verifies if the Flows are added in ONOS for the ONU
440 ${num_services}= Get Length ${service}
441 FOR ${I} IN RANGE 0 ${num_services}
442 ${service_name}= Set Variable ${service[${I}]['name']}
443 ${stag}= Set Variable ${service[${I}]['s_tag']}
444 ${ctag}= Set Variable ${service[${I}]['c_tag']}
445 Run Keyword If '${service_name}' == 'FTTB_SUBSCRIBER_TRAFFIC'
446 ... Verify Subscriber Access Flows Added for DT FTTB ${ip} ${port}
447 ... ${olt_of_id} ${onu_port} ${nni_port} ${stag} ${ctag}
448 ... ELSE IF '${service_name}' == 'DPU_ANCP_TRAFFIC'
449 ... Verify DPU ANCP Flows Added for DT FTTB ${ip} ${port}
450 ... ${olt_of_id} ${onu_port} ${nni_port} ${stag} ${ctag}
451 ... ELSE IF '${service_name}' == 'DPU_MGMT_TRAFFIC'
452 ... Verify DPU MGMT Flows Added for DT FTTB ${ip} ${port}
453 ... ${olt_of_id} ${onu_port} ${nni_port} ${stag} ${ctag}
454 END
455
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530456Verify Subscriber Access Flows Added Count DT
Hardik Windlass25e11702020-03-30 20:05:19 +0530457 [Arguments] ${ip} ${port} ${olt_of_id} ${expected_flows}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530458 [Documentation] Matches for total number of subscriber access flows added for all onus
TorstenThieme4e2168e2021-06-22 14:01:47 +0000459 ${access_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700460 ... flows -s ADDED ${olt_of_id} | grep -v deviceId | grep -v ETH_TYPE:lldp | grep -v ETH_TYPE:arp
461 ${access_flows_added_count}= Get Line Count ${access_flows_added}
462 Should Be Equal As Integers ${access_flows_added_count} ${expected_flows}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530463
Andrea Speranzaa8cf80b2022-05-26 10:09:59 +0200464Verify Subscriber Access Flows Added Count TIM
465 [Arguments] ${ip} ${port} ${olt_of_id} ${expected_flows}
466 [Documentation] Matches for total number of subscriber access flows added for all onus
467 ${access_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
468 ... flows -s ADDED ${olt_of_id} | grep -v deviceId
469 ${access_flows_added_count}= Get Line Count ${access_flows_added}
470 Should Be Equal As Integers ${access_flows_added_count} ${expected_flows}
471
Huseyin Ahmet AYDIN45922c82021-05-27 12:37:32 +0000472Verify Added Flow Count for OLT TT
473 [Arguments] ${ip} ${port} ${olt_of_id} ${expected_flows}
474 [Documentation] Total number of added flows given OLT with subscriber flows
TorstenThieme4e2168e2021-06-22 14:01:47 +0000475 ${access_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700476 ... flows -s ADDED ${olt_of_id} | grep -v deviceId
477 ${access_flows_added_count}= Get Line Count ${access_flows_added}
478 Should Be Equal As Integers ${access_flows_added_count} ${expected_flows}
Huseyin Ahmet AYDIN45922c82021-05-27 12:37:32 +0000479
Emrehan UZUN2884ed52021-05-04 15:36:31 +0000480Verify Default Downstream Flows are added in ONOS for OLT TT
481 [Arguments] ${ip} ${port} ${olt_of_id} ${nni_port}
482 [Documentation] Verifies if the Default Downstream Flows are added in ONOS for the OLT
483 # Verify lldp flow
484 ${downstream_flow_lldp_cmd}= Catenate SEPARATOR=
485 ... flows -s ADDED ${olt_of_id} | grep lldp |
486 ... grep OUTPUT:CONTROLLER
TorstenThieme4e2168e2021-06-22 14:01:47 +0000487 ${downstream_flow_lldp_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Emrehan UZUN2884ed52021-05-04 15:36:31 +0000488 ... ${downstream_flow_lldp_cmd}
489 Should Not Be Empty ${downstream_flow_lldp_added}
490 # Verify downstream dhcp flow
491 ${downstream_flow_dhcp_cmd}= Catenate SEPARATOR=
492 ... flows -s ADDED ${olt_of_id} | grep IP_PROTO:17 | grep UDP_SRC:67 | grep UDP_DST:68 |
493 ... grep OUTPUT:CONTROLLER
TorstenThieme4e2168e2021-06-22 14:01:47 +0000494 ${downstream_flow_dhcp_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Emrehan UZUN2884ed52021-05-04 15:36:31 +0000495 ... ${downstream_flow_dhcp_cmd}
496 Should Not Be Empty ${downstream_flow_dhcp_added}
497 # Verify downstream igmp flow
498 ${downstream_flow_igmp_cmd}= Catenate SEPARATOR=
499 ... flows -s ADDED ${olt_of_id} | grep IP_PROTO:2 |
500 ... grep OUTPUT:CONTROLLER
TorstenThieme4e2168e2021-06-22 14:01:47 +0000501 ${downstream_flow_igmp_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Emrehan UZUN2884ed52021-05-04 15:36:31 +0000502 ... ${downstream_flow_igmp_cmd}
503 Should Not Be Empty ${downstream_flow_igmp_added}
504
Andrea Speranzaa8cf80b2022-05-26 10:09:59 +0200505Verify Downstream Flows for Single OLT NNI Port TIM
506 [Arguments] ${ip} ${port} ${olt_of_id} ${nni_port}
507 [Documentation] Verifies if the downstream flows from the NNI port to the CONTROLLER port are added in ONOS for the OLT
508
509 # Verify PPPoE downstream flow form NNI to CONTROLLER port
510 ${downstream_pppoed_cmd}= Catenate SEPARATOR=
511 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep ETH_TYPE:pppoed | grep OUTPUT:CONTROLLER
512 ${downstream_pppoed}= Execute ONOS CLI Command use single connection ${ip} ${port}
513 ... ${downstream_pppoed_cmd}
514 Should Not Be Empty ${downstream_pppoed}
515
516 # Verify IGMP downstream flow form NNI to CONTROLLER port
517 ${downstream_igmp_cmd}= Catenate SEPARATOR=
518 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep ETH_TYPE:ipv4 | grep IP_PROTO:2 | grep OUTPUT:CONTROLLER
519 ${downstream_igmp}= Execute ONOS CLI Command use single connection ${ip} ${port}
520 ... ${downstream_igmp_cmd}
521 Should Not Be Empty ${downstream_igmp}
522
523 # Verify LLDP downstream flow form NNI to CONTROLLER port
524 ${downstream_lldp_cmd}= Catenate SEPARATOR=
525 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep ETH_TYPE:lldp | grep OUTPUT:CONTROLLER
526 ${downstream_lldp}= Execute ONOS CLI Command use single connection ${ip} ${port}
527 ... ${downstream_lldp_cmd}
528 Should Not Be Empty ${downstream_lldp}
529
LupoAndreaSperanza0f3fbc22023-05-16 21:02:40 +0200530Verify Subscriber Access Flows Added For HSIA Service Single ONU Port TIM
Andrea Speranzaa8cf80b2022-05-26 10:09:59 +0200531 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${c_tag} ${uni_tag}
LupoAndreaSperanza0f3fbc22023-05-16 21:02:40 +0200532 [Documentation] Verifies if the Subscriber Access Flows for the HSIA Service are
533 ... added in ONOS in the manner way for the single consider ONU
Andrea Speranzaa8cf80b2022-05-26 10:09:59 +0200534
535 # Verify upstream pppoed flow from UNI port to CONTROLLER
536 ${upstream_flow_pppoed_added_cmd}= Catenate SEPARATOR=
537 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep ETH_TYPE:pppoed |
538 ... grep VLAN_VID:${uni_tag} | grep OUTPUT:CONTROLLER
539 ${upstream_flow_pppoed_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
540 ... ${upstream_flow_pppoed_added_cmd}
541 Should Not Be Empty ${upstream_flow_pppoed_added}
542
543 # Verify upstream table=0 flow, from UNI to TABLE 1
544 ${upstream_flow_0_added_cmd}= Catenate SEPARATOR=
545 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${uni_tag} |
546 ... grep VLAN_ID:${c_tag} | grep transition=TABLE:1
547 ${upstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
548 ... ${upstream_flow_0_added_cmd}
549 Should Not Be Empty ${upstream_flow_0_added}
550
551 # Verify upstream table=1 flow, from UNI to NNI
552 ${flow_vlan_UNI_to_NNI_cmd}= Catenate SEPARATOR=
553 ... flows -s ADDED ${olt_of_id} | grep table=1 | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
554 ... grep OUTPUT:${nni_port}
555 ${flow_vlan_UNI_to_NNI}= Execute ONOS CLI Command use single connection ${ip} ${port}
556 ... ${flow_vlan_UNI_to_NNI_cmd}
557 Should Not Be Empty ${flow_vlan_UNI_to_NNI}
558
559 # Verify downstream table=0 flow, from NNI to TABLE 1
560 ${downstream_flow_0_added_cmd}= Catenate SEPARATOR=
561 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:Any |
562 ... grep transition=TABLE:1
563 ${downstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
564 ... ${downstream_flow_0_added_cmd}
565 Should Not Be Empty ${downstream_flow_0_added}
566
567 # Verify downstream table=1 flow, from NNI to UNI
568 ${downstream_form_NNI_to_UNI_in_table_1_cmd}= Catenate SEPARATOR=
569 ... flows -s ADDED ${olt_of_id} | grep table=1 | grep IN_PORT:${nni_port} | grep VLAN_VID:${c_tag} |
570 ... grep VLAN_ID:${uni_tag} | grep OUTPUT:${onu_port}
571 ${downstream_form_NNI_to_UNI_in_table_1}= Execute ONOS CLI Command use single connection ${ip} ${port}
572 ... ${downstream_form_NNI_to_UNI_in_table_1_cmd}
573 Should Not Be Empty ${downstream_form_NNI_to_UNI_in_table_1}
574
LupoAndreaSperanza0f3fbc22023-05-16 21:02:40 +0200575Verify Subscriber Access Flows Added For VoD Service On Single ONU Port TIM
576 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${c_tag} ${uni_tag}
577 [Documentation] Verifies if the Subscriber Access Flows for the VoD Service are
578 ... added in ONOS in the manner way for the single consider ONU
579
580 # Verify upstream igmp flow from UNI port to CONTROLLER
581 ${upstream_flow_igmp_added_cmd}= Catenate SEPARATOR=
582 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep ETH_TYPE:ipv4 |
583 ... grep IP_PROTO:2 |grep VLAN_VID:${uni_tag} | grep OUTPUT:CONTROLLER
584 ${upstream_flow_igmp_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
585 ... ${upstream_flow_igmp_added_cmd}
586 Should Not Be Empty ${upstream_flow_igmp_added}
587
588 # Verify upstream table=0 flow, from UNI to TABLE 1
589 ${upstream_flow_0_added_cmd}= Catenate SEPARATOR=
590 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${uni_tag} |
591 ... grep VLAN_ID:${c_tag} | grep transition=TABLE:1
592 ${upstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
593 ... ${upstream_flow_0_added_cmd}
594 Should Not Be Empty ${upstream_flow_0_added}
595
596 # Verify upstream table=1 flow, from UNI to NNI
597 ${flow_vlan_UNI_to_NNI_cmd}= Catenate SEPARATOR=
598 ... flows -s ADDED ${olt_of_id} | grep table=1 | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
599 ... grep OUTPUT:${nni_port}
600 ${flow_vlan_UNI_to_NNI}= Execute ONOS CLI Command use single connection ${ip} ${port}
601 ... ${flow_vlan_UNI_to_NNI_cmd}
602 Should Not Be Empty ${flow_vlan_UNI_to_NNI}
603
604 # Verify downstream table=0 flow, from NNI to TABLE 1
605 ${downstream_flow_0_added_cmd}= Catenate SEPARATOR=
606 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:Any |
607 ... grep transition=TABLE:1
608 ${downstream_flow_0_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
609 ... ${downstream_flow_0_added_cmd}
610 Should Not Be Empty ${downstream_flow_0_added}
611
612 # Verify downstream table=1 flow, from NNI to UNI
613 ${downstream_from_NNI_to_UNI_in_table_1_cmd}= Catenate SEPARATOR=
614 ... flows -s ADDED ${olt_of_id} | grep table=1 | grep IN_PORT:${nni_port} | grep VLAN_VID:${c_tag} |
615 ... grep VLAN_ID:${uni_tag} | grep OUTPUT:${onu_port}
616 ${downstream_from_NNI_to_UNI_in_table_1}= Execute ONOS CLI Command use single connection ${ip} ${port}
617 ... ${downstream_from_NNI_to_UNI_in_table_1_cmd}
618 Should Not Be Empty ${downstream_from_NNI_to_UNI_in_table_1}
619
620Verify Mcast Flow Rule Subscription
621 [Arguments] ${ip} ${port} ${olt_of_id} ${mcastIP}
622 [Documentation] Verfy the creation of the Flow rule trigger by an IGMPJoin
623 ${downstream_flow_mcast_added_cmd}= Catenate SEPARATOR=
624 ... flows -s ADDED ${olt_of_id} | grep ETH_TYPE:ipv4 | grep IPV4_DST:${mcastIP}
625 ${downstram_flow_mcast_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
626 ... ${downstream_flow_mcast_added_cmd}
627 Should Not Be Empty ${downstram_flow_mcast_added}
628 [Return] ${downstram_flow_mcast_added}
629
630Verify Mcast Groups Rules generation
631 [Arguments] ${ip} ${port} ${onu_port} ${groupID}
632 [Documentation] Verfy the creation of the Group rule trigger by an IGMPJoin
633 ${downstream_flow_mcast_added_cmd}= Catenate SEPARATOR=
634 ... groups | grep id=${groupID} | grep OUTPUT:${onu_port}
635 #Ricorda ADDED sopra in production
636 #Prova poi a prenderti con il $5 o qualcosa così il gruppo
637 ${downstram_flow_mcast_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
638 ... ${downstream_flow_mcast_added_cmd}
639 Should Not Be Empty ${downstram_flow_mcast_added}
640
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530641Get Programmed Subscribers
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000642 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${filter}=${EMPTY}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530643 [Documentation] Retrieves the subscriber details at a given location
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000644 ${cmd}= Set Variable If '${filter}' == '${EMPTY}'
645 ... volt-programmed-subscribers ${olt_of_id} ${onu_port}
646 ... volt-programmed-subscribers ${olt_of_id} ${onu_port} | grep ${filter} --color=none
647 ${programmed_sub}= Execute ONOS CLI Command use single connection ${ip} ${port} ${cmd}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530648 [Return] ${programmed_sub}
649
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000650Verify Programmed Subscribers DT FTTB
651 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${service}
652 [Documentation] Verifies the subscriber is present at a given location
653 ${num_services}= Get Length ${service}
654 FOR ${I} IN RANGE 0 ${num_services}
655 ${service_name}= Set Variable ${service[${I}]['name']}
656 ${programmed_subscriber}= Get Programmed Subscribers ${ip} ${port} ${olt_of_id} ${onu_port}
657 ... ${service_name}
658 Log ${programmed_subscriber}
659 Should Not Be Empty ${programmed_subscriber}
660 END
661
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530662Get Upstream and Downstream Bandwidth Profile Name
663 [Arguments] ${programmed_sub}
664 [Documentation] Retrieves the upstream and downstream bandwidth profile name
665 ... from the programmed subscriber
666 @{programmed_sub_array}= Split String ${programmed_sub} ,
667 # Get upstream bandwidth profile name for the subscriber
668 @{param_val_pair}= Split String ${programmed_sub_array[9]} =
669 ${programmed_sub_param}= Set Variable ${param_val_pair[0]}
670 ${programmed_sub_val}= Set Variable ${param_val_pair[1]}
671 ${us_bw_profile}= Run Keyword If '${programmed_sub_param}' == ' upstreamBandwidthProfile'
672 ... Set Variable ${programmed_sub_val}
673 Log ${us_bw_profile}
674 # Get downstream bandwidth profile name for the subscriber
675 @{param_val_pair}= Split String ${programmed_sub_array[10]} =
676 ${programmed_sub_param}= Set Variable ${param_val_pair[0]}
677 ${programmed_sub_val}= Set Variable ${param_val_pair[1]}
678 ${ds_bw_profile}= Run Keyword If '${programmed_sub_param}' == ' downstreamBandwidthProfile'
679 ... Set Variable ${programmed_sub_val}
680 Log ${ds_bw_profile}
681 [Return] ${us_bw_profile} ${ds_bw_profile}
682
683Get Bandwidth Profile Details
684 [Arguments] ${ip} ${port} ${bw_profile}
685 [Documentation] Retrieves the details of the given bandwidth profile
TorstenThieme4e2168e2021-06-22 14:01:47 +0000686 ${bw_profile_values}= Execute ONOS CLI Command use single connection ${ONOS_SSH_IP} ${ONOS_SSH_PORT}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530687 ... bandwidthprofile ${bw_profile}
688 @{bw_profile_array}= Split String ${bw_profile_values} ,
689 @{param_val_pair}= Split String ${bw_profile_array[1]} =
690 ${bw_param}= Set Variable ${param_val_pair[0]}
691 ${bw_val}= Set Variable ${param_val_pair[1]}
692 ${cir} Run Keyword If '${bw_param}' == ' committedInformationRate'
693 ... Set Variable ${bw_val}
694 @{param_val_pair}= Split String ${bw_profile_array[2]} =
695 ${bw_param}= Set Variable ${param_val_pair[0]}
696 ${bw_val}= Set Variable ${param_val_pair[1]}
697 ${cbs} Run Keyword If '${bw_param}' == ' committedBurstSize'
698 ... Set Variable ${bw_val}
699 @{param_val_pair}= Split String ${bw_profile_array[3]} =
700 ${bw_param}= Set Variable ${param_val_pair[0]}
701 ${bw_val}= Set Variable ${param_val_pair[1]}
702 ${eir} Run Keyword If '${bw_param}' == ' exceededInformationRate'
703 ... Set Variable ${bw_val}
704 @{param_val_pair}= Split String ${bw_profile_array[4]} =
705 ${bw_param}= Set Variable ${param_val_pair[0]}
706 ${bw_val}= Set Variable ${param_val_pair[1]}
707 ${ebs} Run Keyword If '${bw_param}' == ' exceededBurstSize'
708 ... Set Variable ${bw_val}
709 @{param_val_pair}= Split String ${bw_profile_array[5]} =
710 ${bw_param}= Set Variable ${param_val_pair[0]}
711 ${bw_val}= Set Variable ${param_val_pair[1]}
712 @{bw_val_air}= Split String ${bw_val} }
713 ${air} Run Keyword If '${bw_param}' == ' assuredInformationRate'
714 ... Set Variable ${bw_val_air[0]}
715 [Return] ${cir} ${cbs} ${eir} ${ebs} ${air}
716
Hardik Windlassba5add42021-05-04 12:41:29 +0000717Get Bandwidth Profile Details Rest
718 [Arguments] ${bw_profile_id}
719 [Documentation] Retrieves the details of the given bandwidth profile using REST API
Girish Gowdracb8482a2021-05-27 09:06:13 -0700720 ${bw_profile_id}= Remove String ${bw_profile_id} ' "
Hardik Windlassba5add42021-05-04 12:41:29 +0000721 ${resp}= Get Request ONOS onos/sadis/bandwidthprofile/${bw_profile_id}
722 ${jsondata}= To Json ${resp.content}
723 Should Not Be Empty ${jsondata['entry']}
724 ${length}= Get Length ${jsondata['entry']}
725 ${matched}= Set Variable False
726 FOR ${INDEX} IN RANGE 0 ${length}
727 ${value}= Get From List ${jsondata['entry']} ${INDEX}
728 ${bw_id}= Get From Dictionary ${value} id
729 ${matched}= Set Variable If '${bw_id}' == '${bw_profile_id}' True False
730 ${eir}= Get From Dictionary ${value} eir
731 ${ebs}= Get From Dictionary ${value} ebs
732 ${cir}= Get From Dictionary ${value} cir
733 ${cbs}= Get From Dictionary ${value} cbs
734 ${air}= Get From Dictionary ${value} air
735 Exit For Loop If ${matched}
736 END
737 Should Be True ${matched} No bandwidth profile found for id: ${bw_profile_id}
738 [Return] ${cir} ${cbs} ${eir} ${ebs} ${air}
739
Hardik Windlass841979a2021-05-25 05:30:27 +0000740Get Bandwidth Profile Details Ietf Rest
741 [Arguments] ${bw_profile_id}
742 [Documentation] Retrieves the details of the given Ietf standard based bandwidth profile using REST API
743 ${bw_profile_id}= Remove String ${bw_profile_id} ' "
744 ${resp}= Get Request ONOS onos/sadis/bandwidthprofile/${bw_profile_id}
745 ${jsondata}= To Json ${resp.content}
746 Should Not Be Empty ${jsondata['entry']}
747 ${length}= Get Length ${jsondata['entry']}
748 ${matched}= Set Variable False
749 FOR ${INDEX} IN RANGE 0 ${length}
750 ${value}= Get From List ${jsondata['entry']} ${INDEX}
751 ${bw_id}= Get From Dictionary ${value} id
752 ${matched}= Set Variable If '${bw_id}' == '${bw_profile_id}' True False
753 ${pir}= Get From Dictionary ${value} pir
754 ${pbs}= Get From Dictionary ${value} pbs
755 ${cir}= Get From Dictionary ${value} cir
756 ${cbs}= Get From Dictionary ${value} cbs
757 ${gir}= Get From Dictionary ${value} gir
758 Exit For Loop If ${matched}
759 END
760 Should Be True ${matched} No bandwidth profile found for id: ${bw_profile_id}
761 [Return] ${cir} ${cbs} ${pir} ${pbs} ${gir}
762
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700763Verify Meters in ONOS Ietf
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000764 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${filter}=${EMPTY}
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700765 [Documentation] Verifies the meters with BW Ietf format (currently, DT workflow uses this format)
766 # Get programmed subscriber
767 ${programmed_sub}= Get Programmed Subscribers ${ip} ${port}
Hardik Windlassa7b34be2022-03-22 17:28:31 +0000768 ... ${olt_of_id} ${onu_port} ${filter}
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700769 Log ${programmed_sub}
770 ${us_bw_profile} ${ds_bw_profile} Get Upstream and Downstream Bandwidth Profile Name
771 ... ${programmed_sub}
772 # Get upstream bandwidth profile details
773 ${us_cir} ${us_cbs} ${us_pir} ${us_pbs} ${us_gir} Get Bandwidth Profile Details Ietf Rest
774 ... ${us_bw_profile}
775 # Verify meter for upstream bandwidth profile
776 ${us_meter_cmd}= Run Keyword If ${us_gir} != 0 Catenate SEPARATOR=
777 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${us_cir}, burst-size=${us_cbs}"
778 ... | grep "rate=${us_pir}, burst-size=${us_pbs}" | grep "rate=${us_gir}, burst-size=0" | wc -l
779 ... ELSE Catenate SEPARATOR=
780 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${us_cir}, burst-size=${us_cbs}"
781 ... | grep "rate=${us_pir}, burst-size=${us_pbs}" | wc -l
TorstenThieme4e2168e2021-06-22 14:01:47 +0000782 ${upstream_meter_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700783 ... ${us_meter_cmd}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700784 Should Be Equal As Integers ${upstream_meter_added} 1 Upstream meter is missing
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700785 # Get downstream bandwidth profile details
786 ${ds_cir} ${ds_cbs} ${ds_pir} ${ds_pbs} ${ds_gir} Get Bandwidth Profile Details Ietf Rest
787 ... ${ds_bw_profile}
788 # Verify meter for downstream bandwidth profile
789 ${ds_meter_cmd}= Run Keyword If ${ds_gir} != 0 Catenate SEPARATOR=
790 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${ds_cir}, burst-size=${ds_cbs}"
791 ... | grep "rate=${ds_pir}, burst-size=${ds_pbs}" | grep "rate=${ds_gir}, burst-size=0" | wc -l
792 ... ELSE Catenate SEPARATOR=
793 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${ds_cir}, burst-size=${ds_cbs}"
794 ... | grep "rate=${ds_pir}, burst-size=${ds_pbs}" | wc -l
TorstenThieme4e2168e2021-06-22 14:01:47 +0000795 ${downstream_meter_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700796 ... ${ds_meter_cmd}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700797 Should Be Equal As Integers ${downstream_meter_added} 1 Downstream meter is missing
Girish Gowdra21ec25d2021-05-24 10:07:01 -0700798
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530799Verify Meters in ONOS
800 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port}
801 [Documentation] Verifies the meters
802 # Get programmed subscriber
803 ${programmed_sub}= Get Programmed Subscribers ${ip} ${port}
804 ... ${olt_of_id} ${onu_port}
805 Log ${programmed_sub}
806 ${us_bw_profile} ${ds_bw_profile} Get Upstream and Downstream Bandwidth Profile Name
807 ... ${programmed_sub}
Matteo Scandolo2056ed72021-11-02 17:38:03 -0700808 # logging all meters to facilitate debug
809 ${all_meters}= Execute ONOS CLI Command use single connection ${ip} ${port} meters
810 Log ${all_meters}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530811 # Get upstream bandwidth profile details
812 ${us_cir} ${us_cbs} ${us_eir} ${us_ebs} ${us_air} Get Bandwidth Profile Details
813 ... ${ip} ${port} ${us_bw_profile}
814 Sleep 1s
Andrea Campanella2b367102021-05-04 19:33:46 +0200815 ${us_pbs}= Evaluate ${us_cbs}+${us_ebs}
816 ${us_pir}= Evaluate ${us_eir}+${us_cir}+${us_air}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530817 # Verify meter for upstream bandwidth profile
818 ${us_meter_cmd}= Catenate SEPARATOR=
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530819 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${us_cir}, burst-size=${us_cbs}"
Andrea Campanella2b367102021-05-04 19:33:46 +0200820 ... | grep "rate=${us_pir}, burst-size=${us_pbs}" | grep "rate=${us_air}, burst-size=0" | wc -l
TorstenThieme4e2168e2021-06-22 14:01:47 +0000821 ${upstream_meter_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530822 ... ${us_meter_cmd}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700823 Should Be Equal As Integers ${upstream_meter_added} 1 Upstream meter is missing
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530824 Sleep 1s
825 # Get downstream bandwidth profile details
826 ${ds_cir} ${ds_cbs} ${ds_eir} ${ds_ebs} ${ds_air} Get Bandwidth Profile Details
827 ... ${ip} ${port} ${ds_bw_profile}
828 Sleep 1s
829 # Verify meter for downstream bandwidth profile
Andrea Campanella2b367102021-05-04 19:33:46 +0200830 ${ds_pbs}= Evaluate ${ds_cbs}+${ds_ebs}
831 ${ds_pir}= Evaluate ${ds_eir}+${ds_cir}+${ds_air}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530832 ${ds_meter_cmd}= Catenate SEPARATOR=
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530833 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${ds_cir}, burst-size=${ds_cbs}"
Andrea Campanella2b367102021-05-04 19:33:46 +0200834 ... | grep "rate=${ds_pir}, burst-size=${ds_pbs}" | grep "rate=${ds_air}, burst-size=0" | wc -l
TorstenThieme4e2168e2021-06-22 14:01:47 +0000835 ${downstream_meter_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530836 ... ${ds_meter_cmd}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700837 Should Be Equal As Integers ${downstream_meter_added} 1 Downstream meter is missing
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530838
839Verify Default Meter Present in ONOS
840 [Arguments] ${ip} ${port} ${olt_of_id}
841 [Documentation] Verifies the single default meter entry is present
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530842 # Get default bandwidth profile details
843 ${cir} ${cbs} ${eir} ${ebs} ${air} Get Bandwidth Profile Details
844 ... ${ip} ${port} 'Default'
845 Sleep 1s
Andrea Campanella2b367102021-05-04 19:33:46 +0200846 ${pbs}= Evaluate ${cbs}+${ebs}
847 ${pir}= Evaluate ${eir}+${cir}+${air}
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530848 # Verify meter for default bandwidth profile
849 ${meter_cmd}= Catenate SEPARATOR=
850 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${cir}, burst-size=${cbs}"
Andrea Campanella2b367102021-05-04 19:33:46 +0200851 ... | grep "rate=${pir}, burst-size=${pbs}" | grep "rate=${air}, burst-size=0" | wc -l
TorstenThieme4e2168e2021-06-22 14:01:47 +0000852 ${default_meter_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530853 ... ${meter_cmd}
Matteo Scandolo2056ed72021-11-02 17:38:03 -0700854 # logging all meters to facilitate debug
855 ${all_meters}= Execute ONOS CLI Command use single connection ${ip} ${port} meters
856 Log ${all_meters}
857 # done logging all meters to facilitate debug
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700858 Should Be Equal As Integers ${default_meter_added} 1 Default Meter not present
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530859
Hardik Windlass480f3e22020-04-02 20:14:14 +0530860Verify Device Flows Removed
861 [Arguments] ${ip} ${port} ${olt_of_id}
862 [Documentation] Verifies all flows are removed from the device
TorstenThieme4e2168e2021-06-22 14:01:47 +0000863 ${device_flows}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo45645bd2021-11-02 10:09:07 -0700864 ... flows -s -f ${olt_of_id} | grep -v deviceId
865 ${flow_count}= Get Line Count ${device_flows}
866 Should Be Equal As Integers ${flow_count} 0 Flows not removed
Hardik Windlass480f3e22020-04-02 20:14:14 +0530867
Kailash6f5acb62019-08-28 14:38:45 -0700868Verify Eapol Flows Added
Andy Bavierb0c06232019-08-29 12:58:53 -0700869 [Arguments] ${ip} ${port} ${expected_flows}
Kailash6f5acb62019-08-28 14:38:45 -0700870 [Documentation] Matches for number of eapol flows based on number of onus
TorstenThieme4e2168e2021-06-22 14:01:47 +0000871 ${eapol_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port}
Gilles Depatie675a2062019-10-22 12:44:42 -0400872 ... flows -s -f ADDED | grep eapol | grep IN_PORT | wc -l
Andy Bavierb0c06232019-08-29 12:58:53 -0700873 Should Contain ${eapol_flows_added} ${expected_flows}
Kailash6f5acb62019-08-28 14:38:45 -0700874
Suchitra Vemuri9da44302020-03-04 14:24:49 -0800875Verify No Pending Flows For ONU
876 [Arguments] ${ip} ${port} ${onu_port}
877 [Documentation] Verifies that there are no flows "PENDING" state for the ONU in ONOS
TorstenThieme4e2168e2021-06-22 14:01:47 +0000878 ${pending_flows}= Execute ONOS CLI Command use single connection ${ip} ${port}
Suchitra Vemuri9da44302020-03-04 14:24:49 -0800879 ... flows -s | grep IN_PORT:${onu_port} | grep PENDING
880 Should Be Empty ${pending_flows}
881
TorstenThieme1e207df2022-05-17 10:31:34 +0000882Verify Pending Flows For ONU
883 [Arguments] ${ip} ${port} ${onu_port}
884 [Documentation] Verifies that there are flows "PENDING" state for the ONU in ONOS
885 ${pending_flows}= Execute ONOS CLI Command use single connection ${ip} ${port}
886 ... flows -s | grep IN_PORT:${onu_port} | grep PENDING
887 Should Not Be Empty ${pending_flows}
888
Suchitra Vemuri3dd2f832019-10-18 13:14:54 -0700889Verify Eapol Flows Added For ONU
Matteo Scandolo7e519fb2021-08-13 11:35:16 -0700890 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${c_tag}=4091
Suchitra Vemuri3dd2f832019-10-18 13:14:54 -0700891 [Documentation] Verifies if the Eapol Flows are added in ONOS for the ONU
Matteo Scandolo7e519fb2021-08-13 11:35:16 -0700892 ${eapol_flow_cmd}= Catenate SEPARATOR=
893 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep ETH_TYPE:eapol |
894 ... grep VLAN_ID:${c_tag} | grep OUTPUT:CONTROLLER
895 ${eapol_flows_added}= Execute ONOS CLI Command use single connection ${ip} ${port} ${eapol_flow_cmd}
Suchitra Vemuri3dd2f832019-10-18 13:14:54 -0700896 Should Not Be Empty ${eapol_flows_added}
897
Hardik Windlass39015672021-07-05 05:48:08 +0000898Verify UNI Port Is Enabled
Hardik Windlass1ed2eee2021-06-25 09:51:03 +0000899 [Arguments] ${ip} ${port} ${onu_name} ${onu_uni_id}=1
Hardik Windlass39015672021-07-05 05:48:08 +0000900 [Documentation] Verifies if the ONU's UNI port is enabled in ONOS
TorstenThieme4e2168e2021-06-22 14:01:47 +0000901 ${onu_port_enabled}= Execute ONOS CLI Command use single connection ${ip} ${port}
Hardik Windlass1ed2eee2021-06-25 09:51:03 +0000902 ... ports -e | grep portName=${onu_name}-${onu_uni_id}
Suchitra Vemuri8078b972020-02-06 19:07:41 -0800903 Log ${onu_port_enabled}
904 Should Not Be Empty ${onu_port_enabled}
905
Hardik Windlass39015672021-07-05 05:48:08 +0000906Verify UNI Port Is Disabled
Hardik Windlass1ed2eee2021-06-25 09:51:03 +0000907 [Arguments] ${ip} ${port} ${onu_name} ${onu_uni_id}=1
Hardik Windlass39015672021-07-05 05:48:08 +0000908 [Documentation] Verifies if the ONU's UNI port is disabled in ONOS
TorstenThieme4e2168e2021-06-22 14:01:47 +0000909 ${onu_port_disabled}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo02768532021-10-21 15:14:12 -0700910 ... ports | grep portName=${onu_name}-${onu_uni_id} | grep state=disabled
Hardik Windlass63d5e002020-03-06 21:07:09 +0530911 Log ${onu_port_disabled}
Matteo Scandolo02768532021-10-21 15:14:12 -0700912 Should Not Be Empty ${onu_port_disabled}
Hardik Windlass63d5e002020-03-06 21:07:09 +0530913
TorstenThieme9b25aab2021-12-16 15:59:45 +0000914Wait For All UNI Ports Are Disabled per ONU
915 [Documentation] Verifies all UNI Ports of passed ONU are disabled
916 [Arguments] ${ip} ${port} ${onu_serial_number}
917 @{uni_id_list}= Create List
918 FOR ${I} IN RANGE 0 ${num_all_onus}
919 ${src}= Set Variable ${hosts.src[${I}]}
920 Continue For Loop If "${src['onu']}" != "${onu_serial_number}"
921 ${uni_id}= Set Variable ${src['uni_id']}
922 # make sure all actions do only once per uni_id
923 ${id}= Get Index From List ${uni_id_list} ${uni_id}
924 Continue For Loop If -1 != ${id}
925 Append To List ${uni_id_list} ${uni_id}
926 Wait Until Keyword Succeeds ${timeout} 2s
927 ... Verify UNI Port Is Disabled ${ip} ${port} ${onu_serial_number} ${uni_id}
928 END
929
930Wait For All UNI Ports Are Enabled per ONU
931 [Documentation] Verifies all UNI Ports of passed ONU are enabled
932 [Arguments] ${ip} ${port} ${onu_serial_number}
933 @{uni_id_list}= Create List
934 FOR ${I} IN RANGE 0 ${num_all_onus}
935 ${src}= Set Variable ${hosts.src[${I}]}
936 Continue For Loop If "${src['onu']}" != "${onu_serial_number}"
937 ${uni_id}= Set Variable ${src['uni_id']}
938 # make sure all actions do only once per uni_id
939 ${id}= Get Index From List ${uni_id_list} ${uni_id}
940 Continue For Loop If -1 != ${id}
941 Append To List ${uni_id_list} ${uni_id}
942 Wait Until Keyword Succeeds ${timeout} 2s
943 ... Verify UNI Port Is Enabled ${ip} ${port} ${onu_serial_number} ${uni_id}
944 END
945
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -0700946Verify ONU in AAA-Users
947 [Arguments] ${ip} ${port} ${onu_port}
948 [Documentation] Verifies that the specified onu_port exists in aaa-users output
TorstenThieme4e2168e2021-06-22 14:01:47 +0000949 ${aaa_users}= Execute ONOS CLI Command use single connection ${ip} ${port}
950 ... aaa-users | grep AUTHORIZED | grep ${onu_port}
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -0700951 Should Not Be Empty ${aaa_users} ONU port ${onu_port} not found in aaa-users
952
Hardik Windlass513afd12021-02-03 15:19:46 +0000953Verify Empty Group in ONOS
954 [Documentation] Verifies zero group count on the device
TorstenThieme731a7592021-07-01 14:26:54 +0000955 [Arguments] ${ip} ${port} ${deviceId}
956 ${groups}= Execute ONOS CLI Command use single connection ${ip} ${port} groups | grep ${deviceId}
Hardik Windlass513afd12021-02-03 15:19:46 +0000957 @{groups_arr}= Split String ${groups} ,
958 @{group_count_arr}= Split String ${groups_arr[1]} =
959 ${group_count}= Set Variable ${group_count_arr[1]}
960 Should Be Equal As Integers ${group_count} 0
961
962Verify ONUs in Group Count in ONOS
963 [Documentation] Verifies there exists a group bucket list with certain entries/count
964 ... Note: Currently, this validates only if all ONUs of an OLT joined the same igmp group
TorstenThieme731a7592021-07-01 14:26:54 +0000965 [Arguments] ${ip} ${port} ${count} ${deviceId}
966 ${result}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolofd36e212021-03-02 11:36:10 -0800967 ... groups added ${deviceId} | grep bucket | wc -l
968 Should Be Equal As Integers ${result} ${count} Bucket list count for a group: Found=${result} Expected=${count}
Hardik Windlass513afd12021-02-03 15:19:46 +0000969
970Verify ONU in Group Bucket
971 [Documentation] Matches if ONU port in Group Bucket
972 [Arguments] ${group_bucket_values} ${onu_port}
973 ${len}= Get Length ${group_bucket_values}
974 ${matched}= Set Variable False
975 FOR ${INDEX} IN RANGE 0 ${len}
976 ${value_bucket}= Get From List ${group_bucket_values} ${INDEX}
977 ${treatment}= Get From Dictionary ${value_bucket} treatment
978 ${instructions}= Get From Dictionary ${treatment} instructions
979 ${instructions_val}= Get From List ${instructions} 0
980 ${port}= Get From Dictionary ${instructions_val} port
981 ${matched}= Set Variable If '${port}'=='${onu_port}' True False
982 Exit For Loop If ${matched}
983 END
984 [Return] ${matched}
985
Matteo Scandoloa80b4732020-09-04 13:51:10 -0700986Verify ONU in Groups
987 [Arguments] ${ip_onos} ${port_onos} ${deviceId} ${onu_port} ${group_exist}=True
988 [Documentation] Verifies that the specified onu_port exists in groups output
TorstenThieme4e2168e2021-06-22 14:01:47 +0000989 ${result}= Execute ONOS CLI Command use single connection ${ip_onos} ${port_onos} groups -j
Matteo Scandoloa80b4732020-09-04 13:51:10 -0700990 Log Groups: ${result}
991 ${groups}= To Json ${result}
992 ${length}= Get Length ${groups}
993 ${buckets}= Create List
994 ${matched}= Set Variable False
995 FOR ${INDEX} IN RANGE 0 ${length}
996 ${value}= Get From List ${groups} ${INDEX}
997 ${devId}= Get From Dictionary ${value} deviceId
998 ${bucket}= Get From Dictionary ${value} buckets
999 Run Keyword If '${devId}'=='${deviceId}'
1000 ... Append To List ${buckets} ${bucket}
1001 END
1002 ${bucket_len}= Get Length ${buckets}
Hardik Windlass513afd12021-02-03 15:19:46 +00001003 FOR ${INDEX_1} IN RANGE 0 ${bucket_len}
1004 ${value}= Get From List ${buckets} ${INDEX_1}
1005 ${matched}= Verify ONU in Group Bucket ${value} ${onu_port}
Matteo Scandoloa80b4732020-09-04 13:51:10 -07001006 Exit For Loop If ${matched}
1007 END
1008 Run Keyword If ${group_exist}
1009 ... Should Be True ${matched} No match for ${deviceId} and ${onu_port} found in ONOS groups
1010 ... ELSE
1011 ... Should Be True '${matched}'=='False' Match for ${deviceId} and ${onu_port} found in ONOS groups
1012
Matteo Scandolo142e6272020-04-29 17:36:59 -07001013Assert Number of AAA-Users
TorstenThieme731a7592021-07-01 14:26:54 +00001014 [Arguments] ${ip} ${port} ${expected_onus} ${deviceId}
Kailash6f5acb62019-08-28 14:38:45 -07001015 [Documentation] Matches for number of aaa-users authorized based on number of onus
TorstenThieme731a7592021-07-01 14:26:54 +00001016 ${aaa_users}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001017 ... aaa-users | grep ${deviceId} | grep AUTHORIZED | wc -l
1018 Log Found ${aaa_users} of ${expected_onus} expected authenticated users on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001019 Should Be Equal As Integers ${aaa_users} ${expected_onus}
Kailash6f5acb62019-08-28 14:38:45 -07001020
1021Validate DHCP Allocations
TorstenThieme731a7592021-07-01 14:26:54 +00001022 [Arguments] ${ip} ${port} ${count} ${workflow} ${deviceId}
Kailash6f5acb62019-08-28 14:38:45 -07001023 [Documentation] Matches for number of dhcpacks based on number of onus
TorstenThieme731a7592021-07-01 14:26:54 +00001024 ${allocations}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001025 ... dhcpl2relay-allocations | grep ${deviceId} | grep DHCPACK | wc -l
Matteo Scandoloda854b02020-09-01 16:20:51 -07001026 # if the workflow is TT we'll have 2 allocations for each ONU
1027 ${ttAllocations}= Evaluate (${count} * 2)
1028 ${count}= Set Variable If $workflow=='tt' ${ttAllocations} ${count}
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001029 Log Found ${allocations} of ${count} expected DHCPACK on device ${deviceId}
Matteo Scandoloda854b02020-09-01 16:20:51 -07001030 Should Be Equal As Integers ${allocations} ${count}
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -07001031
1032Validate Subscriber DHCP Allocation
Suchitra Vemuri42819412020-10-01 17:45:43 -07001033 [Arguments] ${ip} ${port} ${onu_port} ${vlan}=''
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -07001034 [Documentation] Verifies that the specified subscriber is found in DHCP allocations
1035 ##TODO: Enhance the keyword to include DHCP allocated address is not 0.0.0.0
TorstenThieme4e2168e2021-06-22 14:01:47 +00001036 ${allocations}= Execute ONOS CLI Command use single connection ${ip} ${port}
Suchitra Vemuri42819412020-10-01 17:45:43 -07001037 ... dhcpl2relay-allocations | grep DHCPACK | grep ${onu_port} | grep ${vlan}
Gilles Depatie675a2062019-10-22 12:44:42 -04001038 Should Not Be Empty ${allocations} ONU port ${onu_port} not found in dhcpl2relay-allocations
David Bainbridgef81cd642019-11-20 00:14:47 +00001039
Hardik Windlassc609eb02022-02-22 11:28:37 +00001040Validate Mac Learner Mapping in ONOS
1041 [Arguments] ${ip} ${port} ${dev_id} ${onu_port} ${vlan}
1042 [Documentation] Verifies the MAC mapping for the client
1043 ${mac}= Execute ONOS CLI Command use single connection ${ip} ${port}
1044 ... mac-learner-get-mapping ${dev_id} ${onu_port} ${vlan} | grep -v INFO
1045 Should Not Be Empty ${mac}
1046 ... No client mac-mapping found with vlan-id: ${vlan} that uses port: ${onu_port} of device: ${dev_id}
1047
David Bainbridgef81cd642019-11-20 00:14:47 +00001048Device Is Available In ONOS
Matteo Scandolo3218d5b2021-05-26 11:50:10 -07001049 [Arguments] ${url} ${dpid} ${available}=true
1050 [Documentation] Validates the device exists and it has the expected availability in ONOS
David Bainbridgef81cd642019-11-20 00:14:47 +00001051 ${rc} ${json} Run And Return Rc And Output curl --fail -sSL ${url}/onos/v1/devices/${dpid}
1052 Should Be Equal As Integers 0 ${rc}
1053 ${rc} ${value} Run And Return Rc And Output echo '${json}' | jq -r .available
1054 Should Be Equal As Integers 0 ${rc}
Matteo Scandolo3218d5b2021-05-26 11:50:10 -07001055 Should Be Equal ${available} ${value}
David Bainbridgef81cd642019-11-20 00:14:47 +00001056
1057Remove All Devices From ONOS
1058 [Arguments] ${url}
1059 [Documentation] Executes the device-remove command on each device in ONOS
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001060 ${rc} ${output} Run And Return Rc And Output
Zack Williamsa8fe75a2020-01-10 14:25:27 -07001061 ... curl --fail -sSL ${url}/onos/v1/devices | jq -r '.devices[].id'
David Bainbridgef81cd642019-11-20 00:14:47 +00001062 Should Be Equal As Integers ${rc} 0
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001063 @{dpids} Split String ${output}
David Bainbridgef81cd642019-11-20 00:14:47 +00001064 ${count}= Get length ${dpids}
Zack Williamsa8fe75a2020-01-10 14:25:27 -07001065 FOR ${dpid} IN @{dpids}
1066 ${rc}= Run Keyword If '${dpid}' != ''
1067 ... Run And Return Rc curl -XDELETE --fail -sSL ${url}/onos/v1/devices/${dpid}
1068 Run Keyword If '${dpid}' != ''
1069 ... Should Be Equal As Integers ${rc} 0
1070 END
Matteo Scandolo142e6272020-04-29 17:36:59 -07001071
TorstenThieme440b7c02020-12-18 15:42:57 +00001072Assert ONU Port Is Disabled
TorstenThieme731a7592021-07-01 14:26:54 +00001073 [Arguments] ${ip} ${port} ${deviceId} ${onu_port}
TorstenThieme440b7c02020-12-18 15:42:57 +00001074 [Documentation] Verifies if the ONU port is disabled in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001075 ${onu_port_disabled}= Execute ONOS CLI Command use single connection ${ip} ${port}
TorstenThieme440b7c02020-12-18 15:42:57 +00001076 ... ports -d ${deviceId} | grep port=${onu_port}
1077 Log ${onu_port_disabled}
1078 Should Not Be Empty ${onu_port_disabled}
1079
Matteo Scandolo7d1a80d2021-04-09 14:30:43 -07001080Assert Olts in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001081 [Arguments] ${ip} ${port} ${count}
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001082 [Documentation] DEPRECATED use Assert Olt in ONOS
1083 ... Check that a certain number of olts are known to ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001084 ${olts}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001085 ... volt-olts | wc -l
Matteo Scandolo7d1a80d2021-04-09 14:30:43 -07001086 Log Found ${olts} of ${count} expected Olts
1087 Should Be Equal As Integers ${olts} ${count}
1088
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001089Assert Olt in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001090 [Arguments] ${ip} ${port} ${deviceId}
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001091 [Documentation] Check that a particular olt is known to ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001092 ${olts}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001093 ... volt-olts | grep ${deviceId} | wc -l
1094 Should Be Equal As Integers ${olts} 1 "Device ${deviceId} is not recognized as an OLT"
1095
Matteo Scandolo7d1a80d2021-04-09 14:30:43 -07001096Wait for Olts in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001097 [Arguments] ${ip} ${port} ${count} ${max_wait_time}=10m
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001098 [Documentation] DEPRECATED use Wait for Olt in ONOS
1099 ... Waits untill a certain number of ports are enabled in ONOS for a particular deviceId
Matteo Scandolo7d1a80d2021-04-09 14:30:43 -07001100 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Olts in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001101 ... ${ip} ${port} ${count}
Matteo Scandolo7d1a80d2021-04-09 14:30:43 -07001102
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001103Wait for Olt in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001104 [Arguments] ${ip} ${port} ${deviceId} ${max_wait_time}=10m
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001105 [Documentation] Waits until a particular deviceId is recognized by ONOS as an OLT
1106 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Olt in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001107 ... ${ip} ${port} ${deviceId}
Matteo Scandolo520f77e2021-06-01 16:14:47 -07001108
Matteo Scandolo142e6272020-04-29 17:36:59 -07001109Assert Ports in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001110 [Arguments] ${ip} ${port} ${count} ${deviceId} ${filter}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001111 [Documentation] Check that a certain number of ports are enabled in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001112 ${ports}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001113 ... ports -e ${deviceId} | grep ${filter} | wc -l
1114 Log Found ${ports} of ${count} expected ports on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001115 Should Be Equal As Integers ${ports} ${count}
1116
1117Wait for Ports in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001118 [Arguments] ${ip} ${port} ${count} ${deviceId} ${filter} ${max_wait_time}=10m
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001119 [Documentation] Waits untill a certain number of ports are enabled in ONOS for a particular deviceId
TorstenThiemed4f48962020-12-08 12:17:19 +00001120 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Ports in ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001121 ... ${ip} ${port} ${count} ${deviceId} ${filter}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001122
1123Wait for AAA Authentication
TorstenThieme731a7592021-07-01 14:26:54 +00001124 [Arguments] ${ip} ${port} ${count} ${deviceId} ${max_wait_time}=10m
Matteo Scandolo142e6272020-04-29 17:36:59 -07001125 [Documentation] Waits untill a certain number of subscribers are authenticated in ONOS
TorstenThiemed4f48962020-12-08 12:17:19 +00001126 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Number of AAA-Users
TorstenThieme731a7592021-07-01 14:26:54 +00001127 ... ${ip} ${port} ${count} ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001128
1129Wait for DHCP Ack
TorstenThieme731a7592021-07-01 14:26:54 +00001130 [Arguments] ${ip} ${port} ${count} ${workflow} ${deviceId} ${max_wait_time}=10m
Matteo Scandolo142e6272020-04-29 17:36:59 -07001131 [Documentation] Waits untill a certain number of subscribers have received a DHCP_ACK
TorstenThiemed4f48962020-12-08 12:17:19 +00001132 Wait Until Keyword Succeeds ${max_wait_time} 5s Validate DHCP Allocations
TorstenThieme731a7592021-07-01 14:26:54 +00001133 ... ${ip} ${port} ${count} ${workflow} ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001134
Matteo Scandolo96dbe432020-05-28 10:51:57 -07001135Provision subscriber REST
1136 [Documentation] Uses the rest APIs to provision a subscriber
TorstenThieme731a7592021-07-01 14:26:54 +00001137 [Arguments] ${of_id} ${onu_port}
Matteo Scandolo96dbe432020-05-28 10:51:57 -07001138 ${resp}= Post Request ONOS
1139 ... /onos/olt/oltapp/${of_id}/${onu_port}
1140 Should Be Equal As Strings ${resp.status_code} 200
1141
Hardik Windlassea4caf72021-07-30 07:22:12 +00001142Count Enabled UNI Ports
1143 [Documentation] Count all the UNI Ports on a Device
1144 [Arguments] ${ip} ${port} ${of_id}
1145 ${count}= Execute ONOS CLI Command use single connection ${ip} ${port}
1146 ... ports -e ${of_id} | grep -v SWITCH | grep -v nni | wc -l
1147 Log ${count}
1148 [Return] ${count}
1149
Matteo Scandolo142e6272020-04-29 17:36:59 -07001150List Enabled UNI Ports
1151 [Documentation] List all the UNI Ports, the only way we have is to filter out the one called NNI
1152 ... Creates a list of dictionaries
TorstenThieme731a7592021-07-01 14:26:54 +00001153 [Arguments] ${ip} ${port} ${of_id}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001154 [Return] [{'port': '16', 'of_id': 'of:00000a0a0a0a0a00'}, {'port': '32', 'of_id': 'of:00000a0a0a0a0a00'}]
1155 ${result}= Create List
TorstenThieme731a7592021-07-01 14:26:54 +00001156 ${out}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001157 ... ports -e ${of_id} | grep -v SWITCH | grep -v nni
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001158 @{unis}= Split To Lines ${out}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001159 FOR ${uni} IN @{unis}
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001160 ${matches} = Get Regexp Matches ${uni} .*port=([0-9]+),.* 1
Matteo Scandolo142e6272020-04-29 17:36:59 -07001161 &{portDict} Create Dictionary of_id=${of_id} port=${matches[0]}
1162 Append To List ${result} ${portDict}
1163 END
1164 Log ${result}
1165 Return From Keyword ${result}
1166
1167Provision all subscribers on device
Matteo Scandolo96dbe432020-05-28 10:51:57 -07001168 [Documentation] Provisions a subscriber in ONOS for all the enabled UNI ports on a particular device
TorstenThieme731a7592021-07-01 14:26:54 +00001169 [Arguments] ${ip} ${port} ${onos_ip} ${onos_rest_port} ${of_id}
1170 ${unis}= List Enabled UNI Ports ${ip} ${port} ${of_id}
Matteo Scandolo96dbe432020-05-28 10:51:57 -07001171 ${onos_auth}= Create List karaf karaf
1172 Create Session ONOS http://${onos_ip}:${onos_rest_port} auth=${onos_auth}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001173 FOR ${uni} IN @{unis}
TorstenThieme731a7592021-07-01 14:26:54 +00001174 Provision Subscriber REST ${uni['of_id']} ${uni['port']}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001175 END
1176
1177List OLTs
Matteo Scandolo50be75c2020-11-12 11:14:12 -08001178 # NOTE this method is not currently used but it can come useful in the future
1179 [Documentation] Returns a list of all OLTs known to ONOS
TorstenThieme731a7592021-07-01 14:26:54 +00001180 [Arguments] ${ip} ${port}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001181 [Return] ['of:00000a0a0a0a0a00', 'of:00000a0a0a0a0a01']
1182 ${result}= Create List
TorstenThieme731a7592021-07-01 14:26:54 +00001183 ${out}= Execute ONOS CLI Command use single connection ${ip} ${port}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001184 ... volt-olts
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001185 @{olts}= Split To Lines ${out}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001186 FOR ${olt} IN @{olts}
1187 Log ${olt}
TorstenThiemebccd3ae2020-02-20 12:56:44 +00001188 ${matches} = Get Regexp Matches ${olt} ^OLT (.+)$ 1
Matteo Scandolo142e6272020-04-29 17:36:59 -07001189 # there may be some logs mixed with the output so only append if we have a match
1190 ${matches_length}= Get Length ${matches}
1191 Run Keyword If ${matches_length}==1
1192 ... Append To List ${result} ${matches[0]}
1193 END
1194 Return From Keyword ${result}
1195
Matteo Scandolo75911092021-11-16 17:05:36 -08001196Count flows
1197 [Documentation] Count flows in a particular ${state} in ONOS
TorstenThiemef7cd2be2021-12-06 14:30:11 +00001198 ... Optionally for a certain onu-port.
1199 [Arguments] ${ip} ${port} ${deviceId} ${state} ${onu_port}=${EMPTY}
1200 ${cmd}= Catenate SEPARATOR= flows -s ${state} ${deviceId} | grep -v deviceId
1201 ${cmd}= Run Keyword If "${onu_port}"!="${EMPTY}" Catenate SEPARATOR= ${cmd} | grep ${onu_port}
1202 ... ELSE Set Variable ${cmd}
1203 ${cmd}= Catenate SEPARATOR= ${cmd} | wc -l
1204 ${flows}= Execute ONOS CLI Command use single connection ${ip} ${port} ${cmd}
1205 [return] ${flows}
1206
1207Validate number of flows
1208 [Documentation] Validates number of flows in a particular ${state} in ONOS
1209 ... Optionally for a certain onu-port.
1210 [Arguments] ${ip} ${port} ${targetFlows} ${deviceId} ${state} ${onu_port}=${EMPTY}
1211 ${flows}= Count flows ${ip} ${port} ${deviceId} ${state} ${onu_port}
Matteo Scandolo75911092021-11-16 17:05:36 -08001212 Log Found ${state} ${flows} of ${targetFlows} expected flows on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001213 Should Be Equal As Integers ${targetFlows} ${flows}
1214
1215Wait for all flows to in ADDED state
1216 [Documentation] Waits until the flows have been provisioned
TorstenThieme731a7592021-07-01 14:26:54 +00001217 [Arguments] ${ip} ${port} ${deviceId} ${workflow} ${uni_count} ${olt_count}
TorstenThiemeb198c482020-12-14 19:45:23 +00001218 ... ${provisioned} ${withEapol} ${withDhcp} ${withIgmp} ${withLldp}
Matteo Scandolo142e6272020-04-29 17:36:59 -07001219 ${targetFlows}= Calculate flows by workflow ${workflow} ${uni_count} ${olt_count} ${provisioned}
Andrea Campanella70cf0a72020-05-27 10:55:15 +02001220 ... ${withEapol} ${withDhcp} ${withIgmp} ${withLldp}
TorstenThiemef7cd2be2021-12-06 14:30:11 +00001221 Wait Until Keyword Succeeds 10m 5s Validate number of flows
Matteo Scandolo75911092021-11-16 17:05:36 -08001222 ... ${ip} ${port} ${targetFlows} ${deviceId} added
1223
1224Wait for all flows to be removed
1225 [Documentation] Wait for all flows to be removed from a particular device
1226 [Arguments] ${ip} ${port} ${deviceId}
TorstenThiemef7cd2be2021-12-06 14:30:11 +00001227 Wait Until Keyword Succeeds 10m 5s Validate number of flows
Matteo Scandolo75911092021-11-16 17:05:36 -08001228 ... ${ip} ${port} 0 ${deviceId} any
1229
TorstenThieme700ccbf2022-02-11 10:24:05 +00001230Check All Flows Removed
1231 [Documentation] Checks all flows removed per OLT
1232 FOR ${I} IN RANGE 0 ${num_olts}
1233 ${olt_serial_number}= Set Variable ${list_olts}[${I}][sn]
1234 ${onu_port_list}= Get ONU Ports per OLT ${olt_serial_number}
1235 ${of_id}= Wait Until Keyword Succeeds ${timeout} 15s Validate OLT Device in ONOS ${olt_serial_number}
1236 Check All Flows Removed per OLT ${of_id} ${onu_port_list}
1237 END
1238
1239Check All Flows Removed per OLT
1240 [Documentation] Checks all flows removed per OLT, in case of flow remove, not after delete device!
1241 ... Attention: For ATT there must be the eapol flow still available!
1242 [Arguments] ${of_id} ${onu_port_list}
1243 ${expected_flows_onu}= Set Variable If "${workflow}"=="ATT" 1 0
1244 FOR ${onu_port} IN @{onu_port_list}
1245 Wait Until Keyword Succeeds ${timeout} 2s Validate number of flows ${ONOS_SSH_IP} ${ONOS_SSH_PORT}
1246 ... ${expected_flows_onu} ${of_id} any ${onu_port}
1247 END
1248
1249Get ONU Ports per OLT
1250 [Documentation] Collects all ONU ports per OLT
1251 [Arguments] ${olt}
1252 ${onu_port_list} Create List
1253 FOR ${I} IN RANGE 0 ${num_all_onus}
1254 ${src}= Set Variable ${hosts.src[${I}]}
1255 Continue For Loop If "${olt}"!="${src['olt']}"
1256 ${of_id}= Wait Until Keyword Succeeds ${timeout} 15s Validate OLT Device in ONOS ${src['olt']}
1257 ${onu_port}= Wait Until Keyword Succeeds ${timeout} 2s Get ONU Port in ONOS ${src['onu']}
1258 ... ${of_id} ${src['uni_id']}
1259 ${port_id}= Get Index From List ${onu_port_list} ${onu_port}
1260 Continue For Loop If -1 != ${port_id}
1261 Append To List ${onu_port_list} ${onu_port}
1262 END
1263 [return] ${onu_port_list}
Gayathri.Selvan92d16862020-03-19 14:47:58 +00001264
Girish Gowdrad769b412021-05-16 11:09:46 -07001265Get Limiting Bandwidth Details
Gayathri.Selvan92d16862020-03-19 14:47:58 +00001266 [Arguments] ${bandwidth_profile_name}
1267 [Documentation] Collects the bandwidth profile details for the given bandwidth profile and
1268 ... returns the limiting bandwidth
Girish Gowdracb8482a2021-05-27 09:06:13 -07001269 ${cir} ${cbs} ${eir} ${ebs} ${air}= Get Bandwidth Profile Details Rest
1270 ... ${bandwidth_profile_name}
Girish Gowdrad769b412021-05-16 11:09:46 -07001271 ${limiting_BW}= Evaluate ${eir}+${cir}+${air}
Gayathri.Selvan92d16862020-03-19 14:47:58 +00001272 [Return] ${limiting_BW}
Hardik Windlasse8b99222021-01-25 10:03:14 +00001273
Emrehan UZUNd6f85892021-07-01 13:54:26 +00001274Get Limiting Bandwidth Details for Fixed and Committed
1275 [Arguments] ${bandwidth_profile_name}
1276 [Documentation] Collects the bandwidth profile details for the given bandwidth profile and
1277 ... returns the limiting bandwidth for fixed and committed
1278 ${cir} ${cbs} ${eir} ${ebs} ${air}= Get Bandwidth Profile Details Rest
1279 ... ${bandwidth_profile_name}
1280 ${limiting_BW}= Evaluate ${cir}+${air}
1281 [Return] ${limiting_BW}
1282
Hardik Windlasse8b99222021-01-25 10:03:14 +00001283Validate Deleted Device Cleanup In ONOS
Hardik Windlassc609eb02022-02-22 11:28:37 +00001284 [Arguments] ${ip} ${port} ${olt_serial_number} ${maclearning_enabled}=False
Hardik Windlasse8b99222021-01-25 10:03:14 +00001285 [Documentation] The keyword verifies that ports, flows, meters, subscribers, dhcp are all cleared in ONOS
1286 # Fetch OF Id for OLT
1287 ${olt_of_id}= Wait Until Keyword Succeeds ${timeout} 5s Validate OLT Device in ONOS ${olt_serial_number}
Hardik Windlasse8b99222021-01-25 10:03:14 +00001288 # Verify Ports are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001289 ${ports}= Execute ONOS CLI Command use single connection ${ip} ${port}
1290 ... ports ${olt_of_id} | grep -v ${olt_of_id}
1291 ${port_count}= Get Line Count ${ports}
1292 Should Be Equal As Integers ${port_count} 0 Ports have not been removed from ONOS after cleanup
Hardik Windlasse8b99222021-01-25 10:03:14 +00001293 # Verify Subscribers are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001294 ${sub}= Execute ONOS CLI Command use single connection ${ip} ${port}
1295 ... volt-programmed-subscribers | grep ${olt_of_id}
1296 ${sub_count}= Get Line Count ${sub}
1297 Should Be Equal As Integers ${sub_count} 0 Subscribers have not been removed from ONOS after cleanup
Hardik Windlasse8b99222021-01-25 10:03:14 +00001298 # Verify Flows are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001299 ${flow}= Execute ONOS CLI Command use single connection ${ip} ${port}
1300 ... flows -s -f ${olt_of_id} | grep -v deviceId
1301 ${flow_count}= Get Line Count ${flow}
1302 Should Be Equal As Integers ${flow_count} 0 Flows have not been removed from ONOS after cleanup
Hardik Windlasse8b99222021-01-25 10:03:14 +00001303 # Verify Meters are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001304 ${meter}= Execute ONOS CLI Command use single connection ${ip} ${port}
1305 ... meters ${olt_of_id}
1306 ${meter_count}= Get Line Count ${meter}
1307 Should Be Equal As Integers ${meter_count} 0 Meters have not been removed from ONOS after cleanup
Hardik Windlasse8b99222021-01-25 10:03:14 +00001308 # Verify AAA-Users are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001309 ${aaa}= Execute ONOS CLI Command use single connection ${ip} ${port}
1310 ... aaa-users ${olt_of_id}
1311 ${aaa_count}= Get Line Count ${aaa}
1312 Should Be Equal As Integers ${aaa_count} 0 AAA Users have not been removed from ONOS after cleanup
Hardik Windlasse8b99222021-01-25 10:03:14 +00001313 # Verify Dhcp-Allocations are Removed
Matteo Scandolo45645bd2021-11-02 10:09:07 -07001314 ${dhcp}= Execute ONOS CLI Command use single connection ${ip} ${port}
1315 ... dhcpl2relay-allocations ${olt_of_id}
1316 ${dhcp_count}= Get Line Count ${dhcp}
1317 Should Be Equal As Integers ${dhcp_count} 0 DHCP Allocations have not been removed from ONOS after cleanup
Hardik Windlassc609eb02022-02-22 11:28:37 +00001318 # Verify MAC Learner Mappings are Removed
1319 ${mac}= Run Keyword If ${maclearning_enabled} Execute ONOS CLI Command use single connection ${ip} ${port}
1320 ... mac-learner-get-mapping | grep -v INFO
1321 ${mac_count}= Run Keyword If ${maclearning_enabled} Get Line Count ${mac}
1322 ... ELSE Set Variable 0
1323 Should Be Equal As Integers ${mac_count} 0 Client MAC Learner Mappings have not been removed from ONOS after cleanup
Hardik Windlassdd1a9a12021-02-23 15:34:50 +00001324
1325Delete ONOS App
1326 [Arguments] ${url} ${app_name}
1327 [Documentation] This keyword deactivates and uninstalls the given ONOS App
1328 ${rc}= Run And Return Rc curl --fail -sSL -X DELETE ${url}/onos/v1/applications/${app_name}
Matteo Scandolo2769d2b2021-04-14 10:29:24 -07001329 Should Be Equal As Integers ${rc} 0 Can't delete ${app_name} from ONOS
Hardik Windlassdd1a9a12021-02-23 15:34:50 +00001330
1331Verify ONOS App Active
1332 [Arguments] ${url} ${app_name} ${app_version}=${EMPTY}
1333 [Documentation] This keyword verifies that the given ONOS App status is Active
1334 ${rc} ${output} Run And Return Rc And Output
1335 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name} | jq -r .state
1336 Should Be Equal As Integers ${rc} 0
1337 Should Be Equal '${output}' 'ACTIVE'
1338 ${rc1} ${output1} Run And Return Rc And Output
1339 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name} | jq -r .version
1340 Run Keyword If '${app_version}'!='${EMPTY}'
1341 ... Run Keywords
Matteo Scandolo2769d2b2021-04-14 10:29:24 -07001342 ... Should Be Equal As Integers ${rc1} 0 Can't read app ${app_name} status from ONOS
Hardik Windlassdd1a9a12021-02-23 15:34:50 +00001343 ... AND Should Be Equal '${output1}' '${app_version}'
1344
1345Install And Activate ONOS App
1346 [Arguments] ${url} ${app_oar_file}
1347 [Documentation] This keyword installs and activates the given ONOS App
1348 ${cmd}= Catenate SEPARATOR=
1349 ... curl --fail -sSL -H Content-Type:application/octet-stream -
1350 ... X POST ${url}/onos/v1/applications?activate=true --data-binary \@${app_oar_file}
1351 ${rc} ${output} Run And Return Rc And Output ${cmd}
Matteo Scandolo2769d2b2021-04-14 10:29:24 -07001352 Should Be Equal As Integers ${rc} 0 Can't load onos app ${app_oar_file} to ONOS"
Hardik Windlassdd1a9a12021-02-23 15:34:50 +00001353 Log ${output}
Hardik Windlassdc2610f2021-03-09 07:33:51 +00001354
1355Get ONOS App Details
1356 [Arguments] ${url} ${app_name}
1357 [Documentation] Retrieves ONOS App Details
1358 ${rc} ${output} Run And Return Rc And Output
1359 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name}
Matteo Scandolo2769d2b2021-04-14 10:29:24 -07001360 Should Be Equal As Integers ${rc} 0 Can't read app ${app_name} details from ONOS
Hardik Windlassdc2610f2021-03-09 07:33:51 +00001361 [Return] ${output}
Hardik Windlass88075f92022-01-25 12:19:45 +00001362
1363Verify UniTag Subscriber
1364 [Documentation] Verifies the unitag subscriber is provisioned/un-provisioned
1365 [Arguments] ${ip} ${port} ${dev_id} ${onu_port} ${stag} ${ctag} ${tpid} ${sub_added}=True
1366 ${cmd}= Catenate SEPARATOR=
1367 ... volt-programmed-subscribers ${dev_id} ${onu_port} | grep "ponCTag=${ctag}, ponSTag=${stag}" | grep technologyProfileId
1368 ... =${tpid} --color=none
1369 ${subscriber}= Execute ONOS CLI Command use single connection ${ip} ${port} ${cmd}
1370 Log ${subscriber}
1371 ${sub_count}= Get Line Count ${subscriber}
1372 Run Keyword If ${sub_added}
1373 ... Should Be Equal As Integers ${sub_count} 1 UniTag Subscriber Not Added
1374 ... ELSE
1375 ... Should Be Equal As Integers ${sub_count} 0 UniTag Subscriber Not Removed