blob: ffc30daa651452d3b85a25fd967291ddcbd96168 [file] [log] [blame]
Kailash6f5acb62019-08-28 14:38:45 -07001# Copyright 2017-present Open Networking Foundation
2#
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}
29
Kailash6f5acb62019-08-28 14:38:45 -070030*** Keywords ***
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070031
32Open ONOS SSH Connection
33 [Documentation] Establishes an ssh connection to ONOS contoller
34 [Arguments] ${host} ${port} ${user}=karaf ${pass}=karaf
35 ${conn_id}= SSHLibrary.Open Connection ${host} port=${port} timeout=300s alias=ONOS_SSH
36 SSHLibrary.Login ${user} ${pass}
TorstenThiemeb198c482020-12-14 19:45:23 +000037 ${conn_list_entry}= Create Dictionary conn_id=${conn_id} user=${user} pass=${pass}
38 Append To List ${connection_list} ${conn_list_entry}
39 ${conn_list_id}= Get Index From List ${connection_list} ${conn_list_entry}
40 Set Global Variable ${connection_list}
41 [Return] ${conn_list_id}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070042
43Execute ONOS CLI Command on open connection
44 [Documentation] Execute ONOS CLI Command On an Open Connection
TorstenThiemeb198c482020-12-14 19:45:23 +000045 [Arguments] ${connection_list_id} ${cmd}
46 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
47 SSHLibrary.Switch Connection ${connection_entry.conn_id}
48 ${PassOrFail} @{result_values} Run Keyword And Ignore Error SSHLibrary.Execute Command ${cmd}
49 ... return_rc=True return_stderr=True return_stdout=True
50 Run Keyword If '${PassOrFail}'=='FAIL' Reconnect ONOS SSH Connection ${connection_list_id}
51 @{result_values}= Run Keyword If '${PassOrFail}'=='FAIL'
52 ... SSHLibrary.Execute Command ${cmd} return_rc=True return_stderr=True return_stdout=True
53 ... ELSE Set Variable @{result_values}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070054 ${output} Set Variable @{result_values}[0]
Matteo Scandolo50be75c2020-11-12 11:14:12 -080055 Log Command output: ${output}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070056 Should Be Empty @{result_values}[1]
57 Should Be Equal As Integers @{result_values}[2] 0
58 [Return] ${output}
59
TorstenThiemeb198c482020-12-14 19:45:23 +000060Reconnect ONOS SSH Connection
61 [Documentation] Reconnect an SSH Connection
62 [Arguments] ${connection_list_id}
63 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
64 ${user}= Get From Dictionary ${connection_entry} user
65 ${pass}= Get From Dictionary ${connection_entry} pass
66 ${oldconndata}= Get Connection ${connection_entry.conn_id}
67 SSHLibrary.Switch Connection ${connection_entry.conn_id}
TorstenThiemebcf14612021-01-27 10:19:18 +000068 Run Keyword And Ignore Error SSHLibrary.Close Connection
TorstenThiemeb198c482020-12-14 19:45:23 +000069 ${conn_id}= SSHLibrary.Open Connection ${oldconndata.host} port=${oldconndata.port}
70 ... timeout=300s alias=ONOS_SSH
71 SSHLibrary.Login ${user} ${pass}
72 ${conn_list_entry}= Create Dictionary conn_id=${conn_id} user=${user} pass=${pass}
73 Set List Value ${connection_list} ${connection_list_id} ${conn_list_entry}
74 Set Global Variable ${connection_list}
75
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070076Close ONOS SSH Connection
77 [Documentation] Close an SSH Connection
TorstenThiemeb198c482020-12-14 19:45:23 +000078 [Arguments] ${connection_list_id}
79 ${connection_entry}= Get From List ${connection_list} ${connection_list_id}
80 ${connection_alias}= Get From Dictionary ${connection_entry} conn_id
81 ${oldconndata}= Get Connection ${connection_entry.conn_id}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070082 SSHLibrary.Switch Connection ${connection_alias}
TorstenThiemebcf14612021-01-27 10:19:18 +000083 Run Keyword And Ignore Error SSHLibrary.Close Connection
TorstenThiemeb198c482020-12-14 19:45:23 +000084 Remove From List ${connection_list} ${connection_list_id}
85 Set Global Variable ${connection_list}
86
87Close All ONOS SSH Connections
88 [Documentation] Close all SSH Connection and clear connection list.
89 SSHLibrary.Close All Connections
90 @{connection_list} Create List
Matteo Scandolo37bca8d2020-07-31 11:28:40 -070091
Kailash6f5acb62019-08-28 14:38:45 -070092Validate OLT Device in ONOS
Zack Williamsa8fe75a2020-01-10 14:25:27 -070093 # FIXME use volt-olts to check that the OLT is ONOS
Kailash6f5acb62019-08-28 14:38:45 -070094 [Arguments] ${serial_number}
Zack Williamsec53a1b2019-09-16 15:50:52 -070095 [Documentation] Checks if olt has been connected to ONOS
Kailash6f5acb62019-08-28 14:38:45 -070096 ${resp}= Get Request ONOS onos/v1/devices
97 ${jsondata}= To Json ${resp.content}
98 Should Not Be Empty ${jsondata['devices']}
99 ${length}= Get Length ${jsondata['devices']}
100 @{serial_numbers}= Create List
Andy Bavierb63f6d22020-03-12 15:34:37 -0700101 ${matched}= Set Variable False
Zack Williamsec53a1b2019-09-16 15:50:52 -0700102 FOR ${INDEX} IN RANGE 0 ${length}
103 ${value}= Get From List ${jsondata['devices']} ${INDEX}
104 ${of_id}= Get From Dictionary ${value} id
105 ${sn}= Get From Dictionary ${value} serial
Andy Bavierb63f6d22020-03-12 15:34:37 -0700106 ${matched}= Set Variable If '${sn}' == '${serial_number}' True False
107 Exit For Loop If ${matched}
Zack Williamsec53a1b2019-09-16 15:50:52 -0700108 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700109 Should Be True ${matched} No match for ${serial_number} found
Kailash57210eb2019-08-30 13:27:19 -0700110 [Return] ${of_id}
Kailash6f5acb62019-08-28 14:38:45 -0700111
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700112Get ONU Port in ONOS
Zack Williamsec53a1b2019-09-16 15:50:52 -0700113 [Arguments] ${onu_serial_number} ${olt_of_id}
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700114 [Documentation] Retrieves ONU port for the ONU in ONOS
Suchitra Vemuria50c1c12019-09-30 19:54:26 -0700115 ${onu_serial_number}= Catenate SEPARATOR=- ${onu_serial_number} 1
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700116 ${resp}= Get Request ONOS onos/v1/devices/${olt_of_id}/ports
117 ${jsondata}= To Json ${resp.content}
118 Should Not Be Empty ${jsondata['ports']}
119 ${length}= Get Length ${jsondata['ports']}
120 @{ports}= Create List
Andy Bavierb63f6d22020-03-12 15:34:37 -0700121 ${matched}= Set Variable False
Zack Williamsec53a1b2019-09-16 15:50:52 -0700122 FOR ${INDEX} IN RANGE 0 ${length}
123 ${value}= Get From List ${jsondata['ports']} ${INDEX}
124 ${annotations}= Get From Dictionary ${value} annotations
125 ${onu_port}= Get From Dictionary ${value} port
126 ${portName}= Get From Dictionary ${annotations} portName
Andy Bavierb63f6d22020-03-12 15:34:37 -0700127 ${matched}= Set Variable If '${portName}' == '${onu_serial_number}' True False
128 Exit For Loop If ${matched}
Zack Williamsec53a1b2019-09-16 15:50:52 -0700129 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700130 Should Be True ${matched} No match for ${onu_serial_number} found
Suchitra Vemuri102912a2019-09-24 00:35:42 -0700131 [Return] ${onu_port}
132
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530133Get NNI Port in ONOS
134 [Arguments] ${olt_of_id}
135 [Documentation] Retrieves NNI port for the OLT in ONOS
136 ${resp}= Get Request ONOS onos/v1/devices/${olt_of_id}/ports
137 ${jsondata}= To Json ${resp.content}
138 Should Not Be Empty ${jsondata['ports']}
139 ${length}= Get Length ${jsondata['ports']}
140 @{ports}= Create List
141 ${matched}= Set Variable False
142 FOR ${INDEX} IN RANGE 0 ${length}
143 ${value}= Get From List ${jsondata['ports']} ${INDEX}
144 ${annotations}= Get From Dictionary ${value} annotations
145 ${nni_port}= Get From Dictionary ${value} port
146 ${nniPortName}= Catenate SEPARATOR= nni- ${nni_port}
147 ${portName}= Get From Dictionary ${annotations} portName
148 ${matched}= Set Variable If '${portName}' == '${nniPortName}' True False
149 Exit For Loop If ${matched}
150 END
151 Should Be True ${matched} No match for NNI found for ${olt_of_id}
152 [Return] ${nni_port}
153
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700154Get FabricSwitch in ONOS
155 [Documentation] Returns of_id of the Fabric Switch in ONOS
156 ${resp}= Get Request ONOS onos/v1/devices
157 ${jsondata}= To Json ${resp.content}
158 Should Not Be Empty ${jsondata['devices']}
159 ${length}= Get Length ${jsondata['devices']}
Andy Bavierb63f6d22020-03-12 15:34:37 -0700160 ${matched}= Set Variable False
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700161 FOR ${INDEX} IN RANGE 0 ${length}
162 ${value}= Get From List ${jsondata['devices']} ${INDEX}
163 ${of_id}= Get From Dictionary ${value} id
164 ${type}= Get From Dictionary ${value} type
Andy Bavierb63f6d22020-03-12 15:34:37 -0700165 ${matched}= Set Variable If '${type}' == "SWITCH" True False
166 Exit For Loop If ${matched}
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700167 END
Andy Bavierb63f6d22020-03-12 15:34:37 -0700168 Should Be True ${matched} No fabric switch found
Suchitra Vemuri532f67a2019-09-25 11:50:42 -0700169 [Return] ${of_id}
170
Andrea Campanella4c404632020-08-26 14:41:36 +0200171Get Master Instace in ONOS
172 [Arguments] ${of_id}
173 [Documentation] Returns nodeId of the Master instace for a giver device in ONOS
174 ${resp}= Get Request ONOS onos/v1/mastership/${of_id}/master
175 ${jsondata}= To Json ${resp.content}
176 Should Not Be Empty ${jsondata['nodeId']}
177 ${master_node}= Get From Dictionary ${jsondata} nodeId
178 [Return] ${master_node}
179
Hardik Windlass21807632020-04-14 16:24:55 +0530180Verify Subscriber Access Flows Added for ONU
181 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${c_tag} ${s_tag}
182 [Documentation] Verifies if the Subscriber Access Flows are added in ONOS for the ONU
183 # Verify upstream table=0 flow
184 ${upstream_flow_0_cmd}= Catenate SEPARATOR=
185 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:0 |
186 ... grep VLAN_ID:${c_tag} | grep transition=TABLE:1
187 ${upstream_flow_0_added}= Execute ONOS CLI Command ${ip} ${port}
188 ... ${upstream_flow_0_cmd}
189 Should Not Be Empty ${upstream_flow_0_added}
190 # Verify upstream table=1 flow
191 ${flow_vlan_push_cmd}= Catenate SEPARATOR=
192 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:${c_tag} |
193 ... grep VLAN_PUSH | grep VLAN_ID:${s_tag} | grep OUTPUT:${nni_port}
194 ${upstream_flow_1_added}= Execute ONOS CLI Command ${ip} ${port}
195 ... ${flow_vlan_push_cmd}
196 Should Not Be Empty ${upstream_flow_1_added}
197 # Verify downstream table=0 flow
198 ${flow_vlan_pop_cmd}= Catenate SEPARATOR=
199 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
200 ... grep VLAN_POP | grep transition=TABLE:1
201 ${downstream_flow_0_added}= Execute ONOS CLI Command ${ip} ${port}
202 ... ${flow_vlan_pop_cmd}
203 Should Not Be Empty ${downstream_flow_0_added}
204 # Verify downstream table=1 flow
205 ${downstream_flow_1_cmd}= Catenate SEPARATOR=
206 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${c_tag} |
207 ... grep VLAN_ID:0 | grep OUTPUT:${onu_port}
208 ${downstream_flow_1_added}= Execute ONOS CLI Command ${ip} ${port}
209 ... ${downstream_flow_1_cmd}
210 Should Not Be Empty ${downstream_flow_1_added}
211 # Verify ipv4 dhcp upstream flow
212 ${upstream_flow_ipv4_cmd}= Catenate SEPARATOR=
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200213 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep ETH_TYPE:ipv4 |
Andrea Campanella08678e12020-09-18 17:40:22 +0200214 ... grep IP_PROTO:17 | grep UDP_SRC:68 | grep UDP_DST:67 | grep VLAN_ID:${c_tag} |
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200215 ... grep OUTPUT:CONTROLLER
Hardik Windlass21807632020-04-14 16:24:55 +0530216 ${upstream_flow_ipv4_added}= Execute ONOS CLI Command ${ip} ${port}
217 ... ${upstream_flow_ipv4_cmd}
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200218 Should Not Be Empty ${upstream_flow_ipv4_added}
Hardik Windlass21807632020-04-14 16:24:55 +0530219 # Verify ipv4 dhcp downstream flow
220 # Note: This flow will be one per nni per olt
221 ${downstream_flow_ipv4_cmd}= Catenate SEPARATOR=
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200222 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep ETH_TYPE:ipv4 |
223 ... grep IP_PROTO:17 | grep UDP_SRC:67 | grep UDP_DST:68 | grep OUTPUT:CONTROLLER
Hardik Windlass21807632020-04-14 16:24:55 +0530224 ${downstream_flow_ipv4_added}= Execute ONOS CLI Command ${ip} ${port}
225 ... ${downstream_flow_ipv4_cmd}
Andrea Campanella5e9051c2020-04-30 14:38:35 +0200226 Should Not Be Empty ${downstream_flow_ipv4_added}
Hardik Windlass21807632020-04-14 16:24:55 +0530227
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530228Verify Subscriber Access Flows Added for ONU DT
Hardik Windlass25e11702020-03-30 20:05:19 +0530229 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port} ${nni_port} ${s_tag}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530230 [Documentation] Verifies if the Subscriber Access Flows are added in ONOS for the ONU
231 # Verify upstream table=0 flow
232 ${upstream_flow_0_added}= Execute ONOS CLI Command ${ip} ${port}
Hardik Windlass25e11702020-03-30 20:05:19 +0530233 ... 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 +0530234 Should Not Be Empty ${upstream_flow_0_added}
235 # Verify upstream table=1 flow
236 ${flow_vlan_push_cmd}= Catenate SEPARATOR=
Hardik Windlass25e11702020-03-30 20:05:19 +0530237 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${onu_port} | grep VLAN_VID:Any |
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530238 ... grep VLAN_PUSH | grep VLAN_ID:${s_tag} | grep OUTPUT:${nni_port}
239 ${upstream_flow_1_added}= Execute ONOS CLI Command ${ip} ${port}
240 ... ${flow_vlan_push_cmd}
241 Should Not Be Empty ${upstream_flow_1_added}
242 # Verify downstream table=0 flow
243 ${flow_vlan_pop_cmd}= Catenate SEPARATOR=
Hardik Windlass25e11702020-03-30 20:05:19 +0530244 ... flows -s ADDED ${olt_of_id} | grep IN_PORT:${nni_port} | grep VLAN_VID:${s_tag} |
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530245 ... grep VLAN_POP | grep transition=TABLE:1
246 ${downstream_flow_0_added}= Execute ONOS CLI Command ${ip} ${port}
247 ... ${flow_vlan_pop_cmd}
248 Should Not Be Empty ${downstream_flow_0_added}
249 # Verify downstream table=1 flow
250 ${downstream_flow_1_added}= Execute ONOS CLI Command ${ip} ${port}
Hardik Windlass25e11702020-03-30 20:05:19 +0530251 ... 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 +0530252 Should Not Be Empty ${downstream_flow_1_added}
253
254Verify Subscriber Access Flows Added Count DT
Hardik Windlass25e11702020-03-30 20:05:19 +0530255 [Arguments] ${ip} ${port} ${olt_of_id} ${expected_flows}
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530256 [Documentation] Matches for total number of subscriber access flows added for all onus
257 ${access_flows_added}= Execute ONOS CLI Command ${ip} ${port}
Girish Gowdra89f73772021-03-08 14:29:36 -0800258 ... flows -s ADDED ${olt_of_id} | grep -v deviceId | grep -v ETH_TYPE:lldp | grep -v ETH_TYPE:arp | wc -l
Hardik Windlassfb5eace2020-03-26 14:49:01 +0530259 Should Be Equal As Integers ${access_flows_added} ${expected_flows}
260
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530261Get Programmed Subscribers
262 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port}
263 [Documentation] Retrieves the subscriber details at a given location
264 ${sub_location}= Catenate SEPARATOR=/ ${olt_of_id} ${onu_port}
265 ${programmed_sub}= Execute ONOS CLI Command ${ip} ${port}
266 ... volt-programmed-subscribers | grep ${sub_location}
267 [Return] ${programmed_sub}
268
269Get Upstream and Downstream Bandwidth Profile Name
270 [Arguments] ${programmed_sub}
271 [Documentation] Retrieves the upstream and downstream bandwidth profile name
272 ... from the programmed subscriber
273 @{programmed_sub_array}= Split String ${programmed_sub} ,
274 # Get upstream bandwidth profile name for the subscriber
275 @{param_val_pair}= Split String ${programmed_sub_array[9]} =
276 ${programmed_sub_param}= Set Variable ${param_val_pair[0]}
277 ${programmed_sub_val}= Set Variable ${param_val_pair[1]}
278 ${us_bw_profile}= Run Keyword If '${programmed_sub_param}' == ' upstreamBandwidthProfile'
279 ... Set Variable ${programmed_sub_val}
280 Log ${us_bw_profile}
281 # Get downstream bandwidth profile name for the subscriber
282 @{param_val_pair}= Split String ${programmed_sub_array[10]} =
283 ${programmed_sub_param}= Set Variable ${param_val_pair[0]}
284 ${programmed_sub_val}= Set Variable ${param_val_pair[1]}
285 ${ds_bw_profile}= Run Keyword If '${programmed_sub_param}' == ' downstreamBandwidthProfile'
286 ... Set Variable ${programmed_sub_val}
287 Log ${ds_bw_profile}
288 [Return] ${us_bw_profile} ${ds_bw_profile}
289
290Get Bandwidth Profile Details
291 [Arguments] ${ip} ${port} ${bw_profile}
292 [Documentation] Retrieves the details of the given bandwidth profile
293 ${bw_profile_values}= Execute ONOS CLI Command ${ONOS_SSH_IP} ${ONOS_SSH_PORT}
294 ... bandwidthprofile ${bw_profile}
295 @{bw_profile_array}= Split String ${bw_profile_values} ,
296 @{param_val_pair}= Split String ${bw_profile_array[1]} =
297 ${bw_param}= Set Variable ${param_val_pair[0]}
298 ${bw_val}= Set Variable ${param_val_pair[1]}
299 ${cir} Run Keyword If '${bw_param}' == ' committedInformationRate'
300 ... Set Variable ${bw_val}
301 @{param_val_pair}= Split String ${bw_profile_array[2]} =
302 ${bw_param}= Set Variable ${param_val_pair[0]}
303 ${bw_val}= Set Variable ${param_val_pair[1]}
304 ${cbs} Run Keyword If '${bw_param}' == ' committedBurstSize'
305 ... Set Variable ${bw_val}
306 @{param_val_pair}= Split String ${bw_profile_array[3]} =
307 ${bw_param}= Set Variable ${param_val_pair[0]}
308 ${bw_val}= Set Variable ${param_val_pair[1]}
309 ${eir} Run Keyword If '${bw_param}' == ' exceededInformationRate'
310 ... Set Variable ${bw_val}
311 @{param_val_pair}= Split String ${bw_profile_array[4]} =
312 ${bw_param}= Set Variable ${param_val_pair[0]}
313 ${bw_val}= Set Variable ${param_val_pair[1]}
314 ${ebs} Run Keyword If '${bw_param}' == ' exceededBurstSize'
315 ... Set Variable ${bw_val}
316 @{param_val_pair}= Split String ${bw_profile_array[5]} =
317 ${bw_param}= Set Variable ${param_val_pair[0]}
318 ${bw_val}= Set Variable ${param_val_pair[1]}
319 @{bw_val_air}= Split String ${bw_val} }
320 ${air} Run Keyword If '${bw_param}' == ' assuredInformationRate'
321 ... Set Variable ${bw_val_air[0]}
322 [Return] ${cir} ${cbs} ${eir} ${ebs} ${air}
323
324Verify Meters in ONOS
325 [Arguments] ${ip} ${port} ${olt_of_id} ${onu_port}
326 [Documentation] Verifies the meters
327 # Get programmed subscriber
328 ${programmed_sub}= Get Programmed Subscribers ${ip} ${port}
329 ... ${olt_of_id} ${onu_port}
330 Log ${programmed_sub}
331 ${us_bw_profile} ${ds_bw_profile} Get Upstream and Downstream Bandwidth Profile Name
332 ... ${programmed_sub}
333 # Get upstream bandwidth profile details
334 ${us_cir} ${us_cbs} ${us_eir} ${us_ebs} ${us_air} Get Bandwidth Profile Details
335 ... ${ip} ${port} ${us_bw_profile}
336 Sleep 1s
337 # Verify meter for upstream bandwidth profile
338 ${us_meter_cmd}= Catenate SEPARATOR=
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530339 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${us_cir}, burst-size=${us_cbs}"
340 ... | grep "rate=${us_eir}, burst-size=${us_ebs}" | grep "rate=${us_air}, burst-size=0" | wc -l
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530341 ${upstream_meter_added}= Execute ONOS CLI Command ${ip} ${port}
342 ... ${us_meter_cmd}
343 Should Be Equal As Integers ${upstream_meter_added} 1
344 Sleep 1s
345 # Get downstream bandwidth profile details
346 ${ds_cir} ${ds_cbs} ${ds_eir} ${ds_ebs} ${ds_air} Get Bandwidth Profile Details
347 ... ${ip} ${port} ${ds_bw_profile}
348 Sleep 1s
349 # Verify meter for downstream bandwidth profile
350 ${ds_meter_cmd}= Catenate SEPARATOR=
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530351 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${ds_cir}, burst-size=${ds_cbs}"
352 ... | grep "rate=${ds_eir}, burst-size=${ds_ebs}" | grep "rate=${ds_air}, burst-size=0" | wc -l
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530353 ${downstream_meter_added}= Execute ONOS CLI Command ${ip} ${port}
354 ... ${ds_meter_cmd}
355 Should Be Equal As Integers ${downstream_meter_added} 1
356
357Verify Default Meter Present in ONOS
358 [Arguments] ${ip} ${port} ${olt_of_id}
359 [Documentation] Verifies the single default meter entry is present
Hardik Windlasse380bdb2020-07-30 19:09:25 +0530360 # Get default bandwidth profile details
361 ${cir} ${cbs} ${eir} ${ebs} ${air} Get Bandwidth Profile Details
362 ... ${ip} ${port} 'Default'
363 Sleep 1s
364 # Verify meter for default bandwidth profile
365 ${meter_cmd}= Catenate SEPARATOR=
366 ... meters ${olt_of_id} | grep state=ADDED | grep "rate=${cir}, burst-size=${cbs}"
367 ... | grep "rate=${eir}, burst-size=${ebs}" | grep "rate=${air}, burst-size=0" | wc -l
368 ${default_meter_added}= Execute ONOS CLI Command ${ip} ${port}
369 ... ${meter_cmd}
370 Should Be Equal As Integers ${default_meter_added} 1
Hardik Windlass2a9b1592020-07-23 18:28:13 +0530371
Hardik Windlass480f3e22020-04-02 20:14:14 +0530372Verify Device Flows Removed
373 [Arguments] ${ip} ${port} ${olt_of_id}
374 [Documentation] Verifies all flows are removed from the device
375 ${device_flows}= Execute ONOS CLI Command ${ip} ${port}
376 ... flows -s -f ${olt_of_id} | grep -v deviceId | wc -l
377 Should Be Equal As Integers ${device_flows} 0
378
Kailash6f5acb62019-08-28 14:38:45 -0700379Verify Eapol Flows Added
Andy Bavierb0c06232019-08-29 12:58:53 -0700380 [Arguments] ${ip} ${port} ${expected_flows}
Kailash6f5acb62019-08-28 14:38:45 -0700381 [Documentation] Matches for number of eapol flows based on number of onus
Gilles Depatie675a2062019-10-22 12:44:42 -0400382 ${eapol_flows_added}= Execute ONOS CLI Command ${ip} ${port}
383 ... flows -s -f ADDED | grep eapol | grep IN_PORT | wc -l
Andy Bavierb0c06232019-08-29 12:58:53 -0700384 Should Contain ${eapol_flows_added} ${expected_flows}
Kailash6f5acb62019-08-28 14:38:45 -0700385
Suchitra Vemuri9da44302020-03-04 14:24:49 -0800386Verify No Pending Flows For ONU
387 [Arguments] ${ip} ${port} ${onu_port}
388 [Documentation] Verifies that there are no flows "PENDING" state for the ONU in ONOS
389 ${pending_flows}= Execute ONOS CLI Command ${ip} ${port}
390 ... flows -s | grep IN_PORT:${onu_port} | grep PENDING
391 Should Be Empty ${pending_flows}
392
Suchitra Vemuri3dd2f832019-10-18 13:14:54 -0700393Verify Eapol Flows Added For ONU
394 [Arguments] ${ip} ${port} ${onu_port}
395 [Documentation] Verifies if the Eapol Flows are added in ONOS for the ONU
Gilles Depatie675a2062019-10-22 12:44:42 -0400396 ${eapol_flows_added}= Execute ONOS CLI Command ${ip} ${port}
397 ... flows -s -f ADDED | grep eapol | grep IN_PORT:${onu_port}
Suchitra Vemuri3dd2f832019-10-18 13:14:54 -0700398 Should Not Be Empty ${eapol_flows_added}
399
Suchitra Vemuri8078b972020-02-06 19:07:41 -0800400Verify ONU Port Is Enabled
Suchitra Vemuri760bdd32020-06-17 12:34:48 -0700401 [Arguments] ${ip} ${port} ${onu_name}
Suchitra Vemuri8078b972020-02-06 19:07:41 -0800402 [Documentation] Verifies if the ONU port is enabled in ONOS
403 ${onu_port_enabled}= Execute ONOS CLI Command ${ip} ${port}
Suchitra Vemuri760bdd32020-06-17 12:34:48 -0700404 ... ports -e | grep portName=${onu_name}
Suchitra Vemuri8078b972020-02-06 19:07:41 -0800405 Log ${onu_port_enabled}
406 Should Not Be Empty ${onu_port_enabled}
407
Hardik Windlass63d5e002020-03-06 21:07:09 +0530408Verify ONU Port Is Disabled
Suchitra Vemuri760bdd32020-06-17 12:34:48 -0700409 [Arguments] ${ip} ${port} ${onu_name}
Hardik Windlass63d5e002020-03-06 21:07:09 +0530410 [Documentation] Verifies if the ONU port is disabled in ONOS
411 ${onu_port_disabled}= Execute ONOS CLI Command ${ip} ${port}
Suchitra Vemuri760bdd32020-06-17 12:34:48 -0700412 ... ports -e | grep portName=${onu_name}
Hardik Windlass63d5e002020-03-06 21:07:09 +0530413 Log ${onu_port_disabled}
414 Should Be Empty ${onu_port_disabled}
415
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -0700416Verify ONU in AAA-Users
417 [Arguments] ${ip} ${port} ${onu_port}
418 [Documentation] Verifies that the specified onu_port exists in aaa-users output
419 ${aaa_users}= Execute ONOS CLI Command ${ip} ${port} aaa-users | grep AUTHORIZED | grep ${onu_port}
420 Should Not Be Empty ${aaa_users} ONU port ${onu_port} not found in aaa-users
421
Hardik Windlass513afd12021-02-03 15:19:46 +0000422Verify Empty Group in ONOS
423 [Documentation] Verifies zero group count on the device
424 [Arguments] ${onos_ssh_connection} ${deviceId}
425 ${groups}= Execute ONOS CLI Command on open connection ${onos_ssh_connection} groups | grep ${deviceId}
426 @{groups_arr}= Split String ${groups} ,
427 @{group_count_arr}= Split String ${groups_arr[1]} =
428 ${group_count}= Set Variable ${group_count_arr[1]}
429 Should Be Equal As Integers ${group_count} 0
430
431Verify ONUs in Group Count in ONOS
432 [Documentation] Verifies there exists a group bucket list with certain entries/count
433 ... Note: Currently, this validates only if all ONUs of an OLT joined the same igmp group
434 [Arguments] ${onos_ssh_connection} ${count} ${deviceId}
Matteo Scandolofd36e212021-03-02 11:36:10 -0800435 ${result}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
436 ... groups added ${deviceId} | grep bucket | wc -l
437 Should Be Equal As Integers ${result} ${count} Bucket list count for a group: Found=${result} Expected=${count}
Hardik Windlass513afd12021-02-03 15:19:46 +0000438
439Verify ONU in Group Bucket
440 [Documentation] Matches if ONU port in Group Bucket
441 [Arguments] ${group_bucket_values} ${onu_port}
442 ${len}= Get Length ${group_bucket_values}
443 ${matched}= Set Variable False
444 FOR ${INDEX} IN RANGE 0 ${len}
445 ${value_bucket}= Get From List ${group_bucket_values} ${INDEX}
446 ${treatment}= Get From Dictionary ${value_bucket} treatment
447 ${instructions}= Get From Dictionary ${treatment} instructions
448 ${instructions_val}= Get From List ${instructions} 0
449 ${port}= Get From Dictionary ${instructions_val} port
450 ${matched}= Set Variable If '${port}'=='${onu_port}' True False
451 Exit For Loop If ${matched}
452 END
453 [Return] ${matched}
454
Matteo Scandoloa80b4732020-09-04 13:51:10 -0700455Verify ONU in Groups
456 [Arguments] ${ip_onos} ${port_onos} ${deviceId} ${onu_port} ${group_exist}=True
457 [Documentation] Verifies that the specified onu_port exists in groups output
458 ${result}= Execute ONOS CLI Command ${ip_onos} ${port_onos} groups -j
459 Log Groups: ${result}
460 ${groups}= To Json ${result}
461 ${length}= Get Length ${groups}
462 ${buckets}= Create List
463 ${matched}= Set Variable False
464 FOR ${INDEX} IN RANGE 0 ${length}
465 ${value}= Get From List ${groups} ${INDEX}
466 ${devId}= Get From Dictionary ${value} deviceId
467 ${bucket}= Get From Dictionary ${value} buckets
468 Run Keyword If '${devId}'=='${deviceId}'
469 ... Append To List ${buckets} ${bucket}
470 END
471 ${bucket_len}= Get Length ${buckets}
Hardik Windlass513afd12021-02-03 15:19:46 +0000472 FOR ${INDEX_1} IN RANGE 0 ${bucket_len}
473 ${value}= Get From List ${buckets} ${INDEX_1}
474 ${matched}= Verify ONU in Group Bucket ${value} ${onu_port}
Matteo Scandoloa80b4732020-09-04 13:51:10 -0700475 Exit For Loop If ${matched}
476 END
477 Run Keyword If ${group_exist}
478 ... Should Be True ${matched} No match for ${deviceId} and ${onu_port} found in ONOS groups
479 ... ELSE
480 ... Should Be True '${matched}'=='False' Match for ${deviceId} and ${onu_port} found in ONOS groups
481
Matteo Scandolo142e6272020-04-29 17:36:59 -0700482Assert Number of AAA-Users
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800483 [Arguments] ${onos_ssh_connection} ${expected_onus} ${deviceId}
Kailash6f5acb62019-08-28 14:38:45 -0700484 [Documentation] Matches for number of aaa-users authorized based on number of onus
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700485 ${aaa_users}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800486 ... aaa-users | grep ${deviceId} | grep AUTHORIZED | wc -l
487 Log Found ${aaa_users} of ${expected_onus} expected authenticated users on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700488 Should Be Equal As Integers ${aaa_users} ${expected_onus}
Kailash6f5acb62019-08-28 14:38:45 -0700489
490Validate DHCP Allocations
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800491 [Arguments] ${onos_ssh_connection} ${count} ${workflow} ${deviceId}
Kailash6f5acb62019-08-28 14:38:45 -0700492 [Documentation] Matches for number of dhcpacks based on number of onus
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700493 ${allocations}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800494 ... dhcpl2relay-allocations | grep ${deviceId} | grep DHCPACK | wc -l
Matteo Scandoloda854b02020-09-01 16:20:51 -0700495 # if the workflow is TT we'll have 2 allocations for each ONU
496 ${ttAllocations}= Evaluate (${count} * 2)
497 ${count}= Set Variable If $workflow=='tt' ${ttAllocations} ${count}
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800498 Log Found ${allocations} of ${count} expected DHCPACK on device ${deviceId}
Matteo Scandoloda854b02020-09-01 16:20:51 -0700499 Should Be Equal As Integers ${allocations} ${count}
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -0700500
501Validate Subscriber DHCP Allocation
Suchitra Vemuri42819412020-10-01 17:45:43 -0700502 [Arguments] ${ip} ${port} ${onu_port} ${vlan}=''
Suchitra Vemuri8a9c3782019-10-23 12:43:01 -0700503 [Documentation] Verifies that the specified subscriber is found in DHCP allocations
504 ##TODO: Enhance the keyword to include DHCP allocated address is not 0.0.0.0
Gilles Depatie675a2062019-10-22 12:44:42 -0400505 ${allocations}= Execute ONOS CLI Command ${ip} ${port}
Suchitra Vemuri42819412020-10-01 17:45:43 -0700506 ... dhcpl2relay-allocations | grep DHCPACK | grep ${onu_port} | grep ${vlan}
Gilles Depatie675a2062019-10-22 12:44:42 -0400507 Should Not Be Empty ${allocations} ONU port ${onu_port} not found in dhcpl2relay-allocations
David Bainbridgef81cd642019-11-20 00:14:47 +0000508
509Device Is Available In ONOS
510 [Arguments] ${url} ${dpid}
511 [Documentation] Validates the device exists and it available in ONOS
512 ${rc} ${json} Run And Return Rc And Output curl --fail -sSL ${url}/onos/v1/devices/${dpid}
513 Should Be Equal As Integers 0 ${rc}
514 ${rc} ${value} Run And Return Rc And Output echo '${json}' | jq -r .available
515 Should Be Equal As Integers 0 ${rc}
516 Should Be Equal 'true' '${value}'
517
518Remove All Devices From ONOS
519 [Arguments] ${url}
520 [Documentation] Executes the device-remove command on each device in ONOS
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000521 ${rc} ${output} Run And Return Rc And Output
Zack Williamsa8fe75a2020-01-10 14:25:27 -0700522 ... curl --fail -sSL ${url}/onos/v1/devices | jq -r '.devices[].id'
David Bainbridgef81cd642019-11-20 00:14:47 +0000523 Should Be Equal As Integers ${rc} 0
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000524 @{dpids} Split String ${output}
David Bainbridgef81cd642019-11-20 00:14:47 +0000525 ${count}= Get length ${dpids}
Zack Williamsa8fe75a2020-01-10 14:25:27 -0700526 FOR ${dpid} IN @{dpids}
527 ${rc}= Run Keyword If '${dpid}' != ''
528 ... Run And Return Rc curl -XDELETE --fail -sSL ${url}/onos/v1/devices/${dpid}
529 Run Keyword If '${dpid}' != ''
530 ... Should Be Equal As Integers ${rc} 0
531 END
Matteo Scandolo142e6272020-04-29 17:36:59 -0700532
TorstenThieme440b7c02020-12-18 15:42:57 +0000533Assert ONU Port Is Disabled
534 [Arguments] ${onos_ssh_connection} ${deviceId} ${onu_port}
535 [Documentation] Verifies if the ONU port is disabled in ONOS
536 ${onu_port_disabled}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
537 ... ports -d ${deviceId} | grep port=${onu_port}
538 Log ${onu_port_disabled}
539 Should Not Be Empty ${onu_port_disabled}
540
Matteo Scandolo142e6272020-04-29 17:36:59 -0700541Assert Ports in ONOS
TorstenThiemed4f48962020-12-08 12:17:19 +0000542 [Arguments] ${onos_ssh_connection} ${count} ${deviceId} ${filter}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700543 [Documentation] Check that a certain number of ports are enabled in ONOS
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700544 ${ports}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800545 ... ports -e ${deviceId} | grep ${filter} | wc -l
546 Log Found ${ports} of ${count} expected ports on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700547 Should Be Equal As Integers ${ports} ${count}
548
549Wait for Ports in ONOS
TorstenThiemed4f48962020-12-08 12:17:19 +0000550 [Arguments] ${onos_ssh_connection} ${count} ${deviceId} ${filter} ${max_wait_time}=10m
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800551 [Documentation] Waits untill a certain number of ports are enabled in ONOS for a particular deviceId
TorstenThiemed4f48962020-12-08 12:17:19 +0000552 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Ports in ONOS
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800553 ... ${onos_ssh_connection} ${count} ${deviceId} ${filter}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700554
555Wait for AAA Authentication
TorstenThiemed4f48962020-12-08 12:17:19 +0000556 [Arguments] ${onos_ssh_connection} ${count} ${deviceId} ${max_wait_time}=10m
Matteo Scandolo142e6272020-04-29 17:36:59 -0700557 [Documentation] Waits untill a certain number of subscribers are authenticated in ONOS
TorstenThiemed4f48962020-12-08 12:17:19 +0000558 Wait Until Keyword Succeeds ${max_wait_time} 5s Assert Number of AAA-Users
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800559 ... ${onos_ssh_connection} ${count} ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700560
561Wait for DHCP Ack
TorstenThiemed4f48962020-12-08 12:17:19 +0000562 [Arguments] ${onos_ssh_connection} ${count} ${workflow} ${deviceId} ${max_wait_time}=10m
Matteo Scandolo142e6272020-04-29 17:36:59 -0700563 [Documentation] Waits untill a certain number of subscribers have received a DHCP_ACK
TorstenThiemed4f48962020-12-08 12:17:19 +0000564 Wait Until Keyword Succeeds ${max_wait_time} 5s Validate DHCP Allocations
565 ... ${onos_ssh_connection} ${count} ${workflow} ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700566
567Provision subscriber
568 [Documentation] Calls volt-add-subscriber-access in ONOS
569 [Arguments] ${onos_ip} ${onos_port} ${of_id} ${onu_port}
570 Execute ONOS CLI Command ${ONOS_SSH_IP} ${ONOS_SSH_PORT}
571 ... volt-add-subscriber-access ${of_id} ${onu_port}
572
Matteo Scandolo96dbe432020-05-28 10:51:57 -0700573Provision subscriber REST
574 [Documentation] Uses the rest APIs to provision a subscriber
575 [Arguments] ${onos_ip} ${onos_port} ${of_id} ${onu_port}
576 ${resp}= Post Request ONOS
577 ... /onos/olt/oltapp/${of_id}/${onu_port}
578 Should Be Equal As Strings ${resp.status_code} 200
579
580
Matteo Scandolo142e6272020-04-29 17:36:59 -0700581List Enabled UNI Ports
582 [Documentation] List all the UNI Ports, the only way we have is to filter out the one called NNI
583 ... Creates a list of dictionaries
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700584 [Arguments] ${onos_ssh_connection} ${of_id}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700585 [Return] [{'port': '16', 'of_id': 'of:00000a0a0a0a0a00'}, {'port': '32', 'of_id': 'of:00000a0a0a0a0a00'}]
586 ${result}= Create List
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700587 ${out}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700588 ... ports -e ${of_id} | grep -v SWITCH | grep -v nni
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000589 @{unis}= Split To Lines ${out}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700590 FOR ${uni} IN @{unis}
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000591 ${matches} = Get Regexp Matches ${uni} .*port=([0-9]+),.* 1
Matteo Scandolo142e6272020-04-29 17:36:59 -0700592 &{portDict} Create Dictionary of_id=${of_id} port=${matches[0]}
593 Append To List ${result} ${portDict}
594 END
595 Log ${result}
596 Return From Keyword ${result}
597
598Provision all subscribers on device
Matteo Scandolo96dbe432020-05-28 10:51:57 -0700599 [Documentation] Provisions a subscriber in ONOS for all the enabled UNI ports on a particular device
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700600 [Arguments] ${onos_ssh_connection} ${onos_ip} ${onos_rest_port} ${of_id}
601 ${unis}= List Enabled UNI Ports ${onos_ssh_connection} ${of_id}
Matteo Scandolo96dbe432020-05-28 10:51:57 -0700602 ${onos_auth}= Create List karaf karaf
603 Create Session ONOS http://${onos_ip}:${onos_rest_port} auth=${onos_auth}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700604 FOR ${uni} IN @{unis}
Matteo Scandolo96dbe432020-05-28 10:51:57 -0700605 Provision Subscriber REST ${onos_ip} ${onos_rest_port} ${uni['of_id']} ${uni['port']}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700606 END
607
608List OLTs
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800609 # NOTE this method is not currently used but it can come useful in the future
610 [Documentation] Returns a list of all OLTs known to ONOS
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700611 [Arguments] ${onos_ssh_connection}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700612 [Return] ['of:00000a0a0a0a0a00', 'of:00000a0a0a0a0a01']
613 ${result}= Create List
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700614 ${out}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700615 ... volt-olts
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000616 @{olts}= Split To Lines ${out}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700617 FOR ${olt} IN @{olts}
618 Log ${olt}
TorstenThiemebccd3ae2020-02-20 12:56:44 +0000619 ${matches} = Get Regexp Matches ${olt} ^OLT (.+)$ 1
Matteo Scandolo142e6272020-04-29 17:36:59 -0700620 # there may be some logs mixed with the output so only append if we have a match
621 ${matches_length}= Get Length ${matches}
622 Run Keyword If ${matches_length}==1
623 ... Append To List ${result} ${matches[0]}
624 END
625 Return From Keyword ${result}
626
627Count ADDED flows
628 [Documentation] Count the flows in ADDED state in ONOS
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800629 [Arguments] ${onos_ssh_connection} ${targetFlows} ${deviceId}
Matteo Scandolo37bca8d2020-07-31 11:28:40 -0700630 ${flows}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800631 ... flows -s any ${deviceId} | grep ADDED | wc -l
632 Log Found ${flows} of ${targetFlows} expected flows on device ${deviceId}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700633 Should Be Equal As Integers ${targetFlows} ${flows}
634
635Wait for all flows to in ADDED state
636 [Documentation] Waits until the flows have been provisioned
TorstenThiemeb198c482020-12-14 19:45:23 +0000637 [Arguments] ${onos_ssh_connection} ${deviceId} ${workflow} ${uni_count} ${olt_count}
638 ... ${provisioned} ${withEapol} ${withDhcp} ${withIgmp} ${withLldp}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700639 ${targetFlows}= Calculate flows by workflow ${workflow} ${uni_count} ${olt_count} ${provisioned}
Andrea Campanella70cf0a72020-05-27 10:55:15 +0200640 ... ${withEapol} ${withDhcp} ${withIgmp} ${withLldp}
Matteo Scandolo142e6272020-04-29 17:36:59 -0700641 Wait Until Keyword Succeeds 10m 5s Count ADDED flows
Matteo Scandolo50be75c2020-11-12 11:14:12 -0800642 ... ${onos_ssh_connection} ${targetFlows} ${deviceId}
Gayathri.Selvan92d16862020-03-19 14:47:58 +0000643
644Get Bandwidth Details
645 [Arguments] ${bandwidth_profile_name}
646 [Documentation] Collects the bandwidth profile details for the given bandwidth profile and
647 ... returns the limiting bandwidth
648 ${bandwidth_profile_values}= Execute ONOS CLI Command ${ONOS_SSH_IP} ${ONOS_SSH_PORT}
649 ... bandwidthprofile ${bandwidth_profile_name}
650 @{bandwidth_profile_array}= Split String ${bandwidth_profile_values} ,
651 @{parameter_value_pair}= Split String ${bandwidth_profile_array[1]} =
652 ${bandwidthparameter}= Set Variable ${parameter_value_pair[0]}
653 ${value}= Set Variable ${parameter_value_pair[1]}
654 ${cir_value} Run Keyword If '${bandwidthparameter}' == ' committedInformationRate'
655 ... Set Variable ${value}
656 @{parameter_value_pair}= Split String ${bandwidth_profile_array[2]} =
657 ${bandwidthparameter}= Set Variable ${parameter_value_pair[0]}
658 ${value}= Set Variable ${parameter_value_pair[1]}
659 ${cbs_value} Run Keyword If '${bandwidthparameter}' == ' committedBurstSize' Set Variable ${value}
660 @{parameter_value_pair}= Split String ${bandwidth_profile_array[3]} =
661 ${bandwidthparameter}= Set Variable ${parameter_value_pair[0]}
662 ${value}= Set Variable ${parameter_value_pair[1]}
663 ${eir_value} Run Keyword If '${bandwidthparameter}' == ' exceededInformationRate' Set Variable ${value}
664 @{parameter_value_pair}= Split String ${bandwidth_profile_array[4]} =
665 ${bandwidthparameter}= Set Variable ${parameter_value_pair[0]}
666 ${value}= Set Variable ${parameter_value_pair[1]}
667 ${ebs_value} Run Keyword If '${bandwidthparameter}' == ' exceededBurstSize' Set Variable ${value}
668 ${limiting_BW}= Evaluate ${cir_value}+${eir_value}
669 [Return] ${limiting_BW}
Hardik Windlasse8b99222021-01-25 10:03:14 +0000670
671Validate Deleted Device Cleanup In ONOS
672 [Arguments] ${ip} ${port} ${olt_serial_number}
673 [Documentation] The keyword verifies that ports, flows, meters, subscribers, dhcp are all cleared in ONOS
674 # Fetch OF Id for OLT
675 ${olt_of_id}= Wait Until Keyword Succeeds ${timeout} 5s Validate OLT Device in ONOS ${olt_serial_number}
676 # Open ONOS SSH Connection
677 ${onos_ssh_connection} Open ONOS SSH Connection ${ip} ${port}
678 # Verify Ports are Removed
679 ${port_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
680 ... ports ${olt_of_id} | grep -v ${olt_of_id} | wc -l
681 Should Be Equal As Integers ${port_count} 0
682 # Verify Subscribers are Removed
683 ${sub_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
684 ... volt-programmed-subscribers | grep ${olt_of_id} | wc -l
685 Should Be Equal As Integers ${sub_count} 0
686 # Verify Flows are Removed
687 ${flow_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
688 ... flows -s -f ${olt_of_id} | grep -v deviceId | wc -l
689 Should Be Equal As Integers ${flow_count} 0
690 # Verify Meters are Removed
691 ${meter_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
692 ... meters ${olt_of_id} | wc -l
693 Should Be Equal As Integers ${meter_count} 0
694 # Verify AAA-Users are Removed
695 ${aaa_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
696 ... aaa-users ${olt_of_id} | wc -l
697 Should Be Equal As Integers ${aaa_count} 0
698 # Verify Dhcp-Allocations are Removed
699 ${dhcp_count}= Execute ONOS CLI Command on open connection ${onos_ssh_connection}
700 ... dhcpl2relay-allocations ${olt_of_id} | wc -l
701 Should Be Equal As Integers ${dhcp_count} 0
702 # Close ONOS SSH Connection
703 Close ONOS SSH Connection ${onos_ssh_connection}
Hardik Windlassdd1a9a12021-02-23 15:34:50 +0000704
705Delete ONOS App
706 [Arguments] ${url} ${app_name}
707 [Documentation] This keyword deactivates and uninstalls the given ONOS App
708 ${rc}= Run And Return Rc curl --fail -sSL -X DELETE ${url}/onos/v1/applications/${app_name}
709 Should Be Equal As Integers ${rc} 0
710
711Verify ONOS App Active
712 [Arguments] ${url} ${app_name} ${app_version}=${EMPTY}
713 [Documentation] This keyword verifies that the given ONOS App status is Active
714 ${rc} ${output} Run And Return Rc And Output
715 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name} | jq -r .state
716 Should Be Equal As Integers ${rc} 0
717 Should Be Equal '${output}' 'ACTIVE'
718 ${rc1} ${output1} Run And Return Rc And Output
719 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name} | jq -r .version
720 Run Keyword If '${app_version}'!='${EMPTY}'
721 ... Run Keywords
722 ... Should Be Equal As Integers ${rc1} 0
723 ... AND Should Be Equal '${output1}' '${app_version}'
724
725Install And Activate ONOS App
726 [Arguments] ${url} ${app_oar_file}
727 [Documentation] This keyword installs and activates the given ONOS App
728 ${cmd}= Catenate SEPARATOR=
729 ... curl --fail -sSL -H Content-Type:application/octet-stream -
730 ... X POST ${url}/onos/v1/applications?activate=true --data-binary \@${app_oar_file}
731 ${rc} ${output} Run And Return Rc And Output ${cmd}
732 Should Be Equal As Integers ${rc} 0
733 Log ${output}
Hardik Windlassdc2610f2021-03-09 07:33:51 +0000734
735Get ONOS App Details
736 [Arguments] ${url} ${app_name}
737 [Documentation] Retrieves ONOS App Details
738 ${rc} ${output} Run And Return Rc And Output
739 ... curl --fail -sSL ${url}/onos/v1/applications/${app_name}
740 Should Be Equal As Integers ${rc} 0
741 [Return] ${output}