${SuiteFastFail} = False ${SuiteFastFail} False Makes a variable available everywhere within the scope of the current suite. Set suite to not fail fast. ${already_done} = False ${already_done} \${ClusterManagement__has_setup_run} False Returns variable value or ``default`` if the variable does not exist. ${ClusterManagement__has_setup_run} = True \${ClusterManagement__has_setup_run} True Makes a variable available everywhere within the scope of the current suite. ${cluster_size} = 1 ${cluster_size} \${NUM_ODL_SYSTEM} 1 Returns variable value or ``default`` if the variable does not exist. ${cluster_size} Converts the given item to an integer number. ${status} = PASS ${possibly_int_of_members} = 1 ${status} ${possibly_int_of_members} BuiltIn.Convert_To_Integer ${cluster_size} Runs the given keyword with the given arguments and ignores possible error. ${int_of_members} = 1 ${int_of_members} '${status}' != 'PASS' ${1} ${possibly_int_of_members} Sets variable based on the given condition. @{member_index_list} = [ ] @{member_index_list} Returns a list containing given items. @{session_list} = [ ] @{session_list} Returns a list containing given items. &{index_to_ip_mapping} = { } &{index_to_ip_mapping} Creates and returns a dictionary based on the given ``items``. ${member_index_list} ${index} Adds ``values`` to the end of ``list``. ${member_ip} = 10.30.170.35 ${member_ip} ${ODL_SYSTEM_${index}_IP} Returns the given values which can then be assigned to a variables. ${index_to_ip_mapping} ${index} ${member_ip} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. ${session} = ClusterManagement__session_1 ${session} ClusterManagement__session_${member_index} Returns the given values which can then be assigned to a variables. ${session} ${session_alias} = ClusterManagement__session_1 ${session_alias} member_index=${index} Return RequestsLibrary session alias pointing to node of given index. Creating Session using : alias=ClusterManagement__session_1, url=http://10.30.170.35:8181, headers={}, cookies={}, auth=<requests.auth.HTTPBasicAuth object at 0x75a06a5c3f50>, timeout=5, proxies=None, verify=False, debug=0 ${session_alias} http://${member_ip}:${RESTCONFPORT} auth=${AUTH} timeout=${http_timeout} max_retries=${http_retries} Create Session: create a HTTP session to a server ${session_list} ${session_alias} Adds ``values`` to the end of ``list``. ${index} ${member_index_list} ${session_list} ${index_to_ip_mapping} http_timeout=${http_timeout} http_retries=${http_retries} Add a corresponding item based on index into the last three arguments. Create the Http session whose alias is added to list. 1 ${index} 1 ${int_of_members+1} ${ClusterManagement__member_index_list} = [1] \${ClusterManagement__member_index_list} ${member_index_list} Makes a variable available everywhere within the scope of the current suite. ${ClusterManagement__index_to_ip_mapping} = {1: '10.30.170.35'} \${ClusterManagement__index_to_ip_mapping} ${index_to_ip_mapping} Makes a variable available everywhere within the scope of the current suite. ${ClusterManagement__session_list} = ['ClusterManagement__session_1'] \${ClusterManagement__session_list} ${session_list} Makes a variable available everywhere within the scope of the current suite. int_of_members=${int_of_members} http_timeout=${http_timeout} http_retries=${http_retries} Construct index list, session list and IP mapping, publish them as suite variables. http_timeout=${http_timeout} Detect repeated call, or detect number of members and initialize derived suite variables. Http sessions are created with parameters to not waste time when ODL is no accepting connections properly. Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. ${member_ip} = 10.30.170.35 ${member_ip} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_connection} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_connection} Returns information about the connection. At least one of {return_stdout} or {return_stderr} args should be set to True Fails the test with the given message and optionally alters its tags. index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection} Returns information about the connection. Attempting to execute command "iptables -I INPUT -p tcp --dport 8101 -j ACCEPT; iptables-save" on remote system "10.30.170.35" by user "jenkins" with keyfile pass "any" and prompt ">" and password "" Attempting to execute command "${cmd}" on remote system "${system}" by user "${user}" with keyfile pass "${keyfile_pass}" and prompt "${prompt}" and password "${password}" Logs the given message with the given level. ${conn_id} = 1 ${conn_id} ${system} prompt=${prompt} timeout=${prompt_timeout} Opens a new SSH connection to the given ``host`` and ``port``. Length is 0. ${pwd_length} = 0 ${pwd_length} ${password} Returns and logs the length of the given item as an integer. ${pwd_length} > 0 SSHLibrary.Login ${user} ${password} delay=${delay} Runs the specified keyword and returns from the enclosing user keyword. Logging into '10.30.170.35:22' as 'jenkins'. Read output: Welcome to Ubuntu 22.04.5 LTS (GNU/Linux 5.15.0-171-generic x86_64) * Documentation: https://help.ubuntu.com * Management: https://landscape.canonical.com * Support: https://ubuntu.com/pro System information as of Sun Apr 19 00:24:26 UTC 2026 System load: 0.04 Processes: 123 Usage of /: 10.3% of 77.35GB Users logged in: 0 Memory usage: 2% IPv4 address for ens3: 10.30.170.35 Swap usage: 0% Expanded Security Maintenance for Applications is not enabled. 0 updates can be applied immediately. 10 additional security updates can be applied with ESM Apps. Learn more about enabling ESM Apps service at https://ubuntu.com/esm The list of available updates is more than a week old. To check for new updates run: sudo apt update New release '24.04.4 LTS' available. Run 'do-release-upgrade' to upgrade to it. [?2004h[jenkins@releng-38670-37-0-builder-0 ~]> ${user} ${USER_HOME}/.ssh/${SSH_KEY} ${KEYFILE_PASS} delay=${delay} Logs into the SSH server using key-based authentication. Returning from the enclosing user keyword. SSHLibrary.Login With Public Key ${user} ${USER_HOME}/.ssh/${SSH_KEY} ${KEYFILE_PASS} delay=${delay} Runs the specified keyword and returns from the enclosing user keyword. ${user} ${password} On active SSH session: if given non-empty password, do Login, else do Login With Public Key. Executing command 'iptables -I INPUT -p tcp --dport 8101 -j ACCEPT; iptables-save'. Command exited with return code 4. ${stdout} = ${stderr} = iptables v1.8.7 (nf_tables): unknown option "--dport" Try `iptables -h' or 'iptables --help' for more information. iptables-save v1.8.7 (nf_tables): Could not fetch rule set generation id: Permission ... ${stdout} ${stderr} ${cmd} return_stderr=True Executes ``command`` on the remote machine and returns its outputs. Closes the current connection. iptables v1.8.7 (nf_tables): unknown option "--dport" Try `iptables -h' or 'iptables --help' for more information. iptables-save v1.8.7 (nf_tables): Could not fetch rule set generation id: Permission denied (you must be root) ${stderr} Logs the given message with the given level. ${stderr} ${stdout} ${stdout} ${stderr} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection.index} Restore active SSH connection in SSHLibrary to given index. ${system} ${cmd} ${user} ${password} prompt=${prompt} Reduces the common work of running a command on a remote system to a single higher level robot keyword, taking care to log in with a public key and. The command given is written and the return value depends on the passed argument values of return_stdout (default: True) and return_stderr (default: False). At least one should be True, or the keyword will exit and FAIL. If both are True, the resulting return value will be a two element list containing both. Otherwise the resulting return value is a string. No test conditions are checked. Returning from the enclosing user keyword. Run Command On Remote System ${system} ${cmd} ${user} ${password} prompt=${prompt} Runs the specified keyword and returns from the enclosing user keyword. @{args} &{kwargs} Call Run Comand On Remote System, but with default values suitable for Controller machine. Returning from the enclosing user keyword. ${keyword_name} @{args} &{kwargs} Runs the specified keyword and returns from the enclosing user keyword. ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection.index} Restore active SSH connection in SSHLibrary to given index. ${output} = ${output} Utils.Run_Command_On_Controller ${member_ip} ${command} Store current connection index, run keyword returning its result, restore connection in teardown. Note that in order to avoid "got positional argument after named arguments", it is safer to use positional (not named) arguments on call. ${output} Logs the given message with the given level. ${output} command=${command} member_index=${index} Obtain IP, call Utils and return output. This keeps previous ssh session active. 1 ${index} @{index_list} iptables -I INPUT -p tcp --dport ${KARAF_SHELL_PORT} -j ACCEPT; iptables-save Cycle through indices (or all), run command on each. First connections to Karaf console may fail, so WUKS is used. TODO: Track as a Bug. Displays the given messages in the log file as keyword arguments. Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. Dictionary does not contain key '1'. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. Dictionary does not contain key '1'. ${status} = FAIL ${old_connection_index} = Dictionary does not contain key '1'. ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=4 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=4 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 4} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 4 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=6 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=6 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 6} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 6 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=8 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=8 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 8} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 8 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=10 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=10 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Keyword 'Open_Controller_Karaf_Console_On_Background' failed after retrying for 3 seconds. The last error was: NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 3s 1s Open_Controller_Karaf_Console_On_Background member_index=${index} Runs the specified keyword and retries if it fails. Keyword 'Open_Controller_Karaf_Console_On_Background' failed after retrying for 3 seconds. The last error was: NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 BuiltIn.Wait_Until_Keyword_Succeeds 3s 1s Open_Controller_Karaf_Console_On_Background member_index=${index} Runs the given keyword with the given arguments and ignores possible error. 1 ${index} @{ClusterManagement__member_index_list} http_timeout=${http_timeout} Initialize ClusterManagement. Open ssh karaf connections to each ODL. Not A Karaf App Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. Not A Karaf App Not A Karaf App ${karaf_connection_index} = 10 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robot" Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robot" Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robot" Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robot" ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robot" ${status} = FAIL ${message} = Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/010_crud_mdsal_perf.robo... ${status} ${message} Execute_Controller_Karaf_Command_On_Background ${command} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${message} Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 10} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 10 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=13 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=13 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. ${member_index} If there is a stored ssh connection index of connection to the controller's karaf console for 1, close the previous connection. In any case create a new connection to karaf console for 1, set correct prompt set and login to karaf console. Store connection index for 1 and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${message} ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. ${message} log:log "ROBOT MESSAGE: ${message}" member_index=${index} Attemp to send command to karaf for ${member_index}, if fail then open connection and try again. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} = FAIL ${output} = NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} ${output} Execute_Controller_Karaf_Command_With_Retry_On_Background log:log "ROBOT MESSAGE: ${message}" member_index=${index} Runs the given keyword with the given arguments and ignores possible error. ${output} Fails the test with the given message and optionally alters its tags. 1 ${index} @{index_list} Starting suite ${SUITE_SOURCE} ${member_index_list} Make sure this resource is initialized. Send a message into the controller's karaf log file on every node listed (or all). By default, failure while processing a node is silently ignored, unless ${tolerate_failure} is False. Log suite name to karaf log, useful in suite setup. KarafKeywords.Log_Test_Suite_Start_To_Controller_Karaf Runs the given keyword with the given arguments and ignores possible error. Prepare both FailFast and Karaf logging, log that the caller suite has started. This keyword is to be used in suite setup, and without it the other keywords may not work properly. Not A Karaf App ${karaf_connection_index} = 13 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:set INFO Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:set INFO Failed to send the command: log:set INFO Failed to send the command: log:set INFO ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. log:set ${CONTROLLER_LOG_LEVEL} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:set INFO ${mininet_conn_id} ${TOOLS_SYSTEM_IP} prompt=${TOOLS_SYSTEM_PROMPT} timeout=6s Opens a new SSH connection to the given ``host`` and ``port``. ${mininet_conn_id} Makes a variable available everywhere within the scope of the current suite. ${TOOLS_SYSTEM_USER} Call Flexible SSH Login, but with default values suitable for Mininet machine. /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/OneNode_Datastore/../../../../tools/odl-mdsal-clustering-tests/scripts/cluster_rest_script.py . Uploads file(s) from the local machine to the remote machine. ${stdout} ${stderr} ${rc} ls return_stdout=True return_stderr=True return_rc=True Executes ``command`` on the remote machine and returns its outputs. session http://${ODL_SYSTEM_IP}:${RESTCONFPORT} auth=${AUTH} Create Session: create a HTTP session to a server Suite setup keyword. Failed to send the command: log:set INFO Request to add 10000 cars (timeout in 11m). Parent suite setup failed: Failed to send the command: log:set INFO Store logs and verify result Parent suite setup failed: Failed to send the command: log:set INFO Request to add 10000 people (timeout in 11m). Parent suite setup failed: Failed to send the command: log:set INFO Store logs and verify result Parent suite setup failed: Failed to send the command: log:set INFO Request to purchase 10000 cars (timeout in 11m). Parent suite setup failed: Failed to send the command: log:set INFO Store logs and verify result Parent suite setup failed: Failed to send the command: log:set INFO Remove cars from the datastore Parent suite setup failed: Failed to send the command: log:set INFO Remove people from the datastore Parent suite setup failed: Failed to send the command: log:set INFO Remove car-people entries from the datastore Parent suite setup failed: Failed to send the command: log:set INFO Closes all open connections. Deleting All Sessions Removes all the session objects Suite teardown keyword Test for measuring execution time of MD-SAL DataStore operations. Copyright (c) 2015-2017 Cisco Systems, Inc. and others. All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html This test suite requires odl-restconf and odl-clustering-test-app modules. The script cluster_rest_script.py is used for generating requests for operations on people, car and car-people DataStore test models. (see the https://wiki.opendaylight.org/view/MD-SAL_Clustering_Test_Plan) TODO: Decide whether keyword names should contain spaces or underscores. Suite setup failed: Failed to send the command: log:set INFO ${SuiteFastFail} = False ${SuiteFastFail} False Makes a variable available everywhere within the scope of the current suite. Set suite to not fail fast. ${already_done} = False ${already_done} \${ClusterManagement__has_setup_run} False Returns variable value or ``default`` if the variable does not exist. ${ClusterManagement__has_setup_run} = True \${ClusterManagement__has_setup_run} True Makes a variable available everywhere within the scope of the current suite. ${cluster_size} = 1 ${cluster_size} \${NUM_ODL_SYSTEM} 1 Returns variable value or ``default`` if the variable does not exist. ${cluster_size} Converts the given item to an integer number. ${status} = PASS ${possibly_int_of_members} = 1 ${status} ${possibly_int_of_members} BuiltIn.Convert_To_Integer ${cluster_size} Runs the given keyword with the given arguments and ignores possible error. ${int_of_members} = 1 ${int_of_members} '${status}' != 'PASS' ${1} ${possibly_int_of_members} Sets variable based on the given condition. @{member_index_list} = [ ] @{member_index_list} Returns a list containing given items. @{session_list} = [ ] @{session_list} Returns a list containing given items. &{index_to_ip_mapping} = { } &{index_to_ip_mapping} Creates and returns a dictionary based on the given ``items``. ${member_index_list} ${index} Adds ``values`` to the end of ``list``. ${member_ip} = 10.30.170.35 ${member_ip} ${ODL_SYSTEM_${index}_IP} Returns the given values which can then be assigned to a variables. ${index_to_ip_mapping} ${index} ${member_ip} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. ${session} = ClusterManagement__session_1 ${session} ClusterManagement__session_${member_index} Returns the given values which can then be assigned to a variables. ${session} ${session_alias} = ClusterManagement__session_1 ${session_alias} member_index=${index} Return RequestsLibrary session alias pointing to node of given index. Creating Session using : alias=ClusterManagement__session_1, url=http://10.30.170.35:8181, headers={}, cookies={}, auth=<requests.auth.HTTPBasicAuth object at 0x75a06915b890>, timeout=125, proxies=None, verify=False, debug=0 ${session_alias} http://${member_ip}:${RESTCONFPORT} auth=${AUTH} timeout=${http_timeout} max_retries=${http_retries} Create Session: create a HTTP session to a server ${session_list} ${session_alias} Adds ``values`` to the end of ``list``. ${index} ${member_index_list} ${session_list} ${index_to_ip_mapping} http_timeout=${http_timeout} http_retries=${http_retries} Add a corresponding item based on index into the last three arguments. Create the Http session whose alias is added to list. 1 ${index} 1 ${int_of_members+1} ${ClusterManagement__member_index_list} = [1] \${ClusterManagement__member_index_list} ${member_index_list} Makes a variable available everywhere within the scope of the current suite. ${ClusterManagement__index_to_ip_mapping} = {1: '10.30.170.35'} \${ClusterManagement__index_to_ip_mapping} ${index_to_ip_mapping} Makes a variable available everywhere within the scope of the current suite. ${ClusterManagement__session_list} = ['ClusterManagement__session_1'] \${ClusterManagement__session_list} ${session_list} Makes a variable available everywhere within the scope of the current suite. int_of_members=${int_of_members} http_timeout=${http_timeout} http_retries=${http_retries} Construct index list, session list and IP mapping, publish them as suite variables. http_timeout=${http_timeout} Detect repeated call, or detect number of members and initialize derived suite variables. Http sessions are created with parameters to not waste time when ODL is no accepting connections properly. Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. ${member_ip} = 10.30.170.35 ${member_ip} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_connection} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_connection} Returns information about the connection. At least one of {return_stdout} or {return_stderr} args should be set to True Fails the test with the given message and optionally alters its tags. index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection} Returns information about the connection. Attempting to execute command "iptables -I INPUT -p tcp --dport 8101 -j ACCEPT; iptables-save" on remote system "10.30.170.35" by user "jenkins" with keyfile pass "any" and prompt ">" and password "" Attempting to execute command "${cmd}" on remote system "${system}" by user "${user}" with keyfile pass "${keyfile_pass}" and prompt "${prompt}" and password "${password}" Logs the given message with the given level. ${conn_id} = 1 ${conn_id} ${system} prompt=${prompt} timeout=${prompt_timeout} Opens a new SSH connection to the given ``host`` and ``port``. Length is 0. ${pwd_length} = 0 ${pwd_length} ${password} Returns and logs the length of the given item as an integer. ${pwd_length} > 0 SSHLibrary.Login ${user} ${password} delay=${delay} Runs the specified keyword and returns from the enclosing user keyword. Logging into '10.30.170.35:22' as 'jenkins'. Read output: Welcome to Ubuntu 22.04.5 LTS (GNU/Linux 5.15.0-171-generic x86_64) * Documentation: https://help.ubuntu.com * Management: https://landscape.canonical.com * Support: https://ubuntu.com/pro System information as of Sun Apr 19 00:24:26 UTC 2026 System load: 0.04 Processes: 123 Usage of /: 10.3% of 77.35GB Users logged in: 0 Memory usage: 2% IPv4 address for ens3: 10.30.170.35 Swap usage: 0% Expanded Security Maintenance for Applications is not enabled. 0 updates can be applied immediately. 10 additional security updates can be applied with ESM Apps. Learn more about enabling ESM Apps service at https://ubuntu.com/esm The list of available updates is more than a week old. To check for new updates run: sudo apt update New release '24.04.4 LTS' available. Run 'do-release-upgrade' to upgrade to it. Last login: Sun Apr 19 00:24:28 2026 from 10.30.171.127 [?2004h[jenkins@releng-38670-37-0-builder-0 ~]> ${user} ${USER_HOME}/.ssh/${SSH_KEY} ${KEYFILE_PASS} delay=${delay} Logs into the SSH server using key-based authentication. Returning from the enclosing user keyword. SSHLibrary.Login With Public Key ${user} ${USER_HOME}/.ssh/${SSH_KEY} ${KEYFILE_PASS} delay=${delay} Runs the specified keyword and returns from the enclosing user keyword. ${user} ${password} On active SSH session: if given non-empty password, do Login, else do Login With Public Key. Executing command 'iptables -I INPUT -p tcp --dport 8101 -j ACCEPT; iptables-save'. Command exited with return code 4. ${stdout} = ${stderr} = iptables v1.8.7 (nf_tables): unknown option "--dport" Try `iptables -h' or 'iptables --help' for more information. iptables-save v1.8.7 (nf_tables): Could not fetch rule set generation id: Permission ... ${stdout} ${stderr} ${cmd} return_stderr=True Executes ``command`` on the remote machine and returns its outputs. Closes the current connection. iptables v1.8.7 (nf_tables): unknown option "--dport" Try `iptables -h' or 'iptables --help' for more information. iptables-save v1.8.7 (nf_tables): Could not fetch rule set generation id: Permission denied (you must be root) ${stderr} Logs the given message with the given level. ${stderr} ${stdout} ${stdout} ${stderr} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection.index} Restore active SSH connection in SSHLibrary to given index. ${system} ${cmd} ${user} ${password} prompt=${prompt} Reduces the common work of running a command on a remote system to a single higher level robot keyword, taking care to log in with a public key and. The command given is written and the return value depends on the passed argument values of return_stdout (default: True) and return_stderr (default: False). At least one should be True, or the keyword will exit and FAIL. If both are True, the resulting return value will be a two element list containing both. Otherwise the resulting return value is a string. No test conditions are checked. Returning from the enclosing user keyword. Run Command On Remote System ${system} ${cmd} ${user} ${password} prompt=${prompt} Runs the specified keyword and returns from the enclosing user keyword. @{args} &{kwargs} Call Run Comand On Remote System, but with default values suitable for Controller machine. Returning from the enclosing user keyword. ${keyword_name} @{args} &{kwargs} Runs the specified keyword and returns from the enclosing user keyword. ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection.index} Restore active SSH connection in SSHLibrary to given index. ${output} = ${output} Utils.Run_Command_On_Controller ${member_ip} ${command} Store current connection index, run keyword returning its result, restore connection in teardown. Note that in order to avoid "got positional argument after named arguments", it is safer to use positional (not named) arguments on call. ${output} Logs the given message with the given level. ${output} command=${command} member_index=${index} Obtain IP, call Utils and return output. This keeps previous ssh session active. 1 ${index} @{index_list} iptables -I INPUT -p tcp --dport ${KARAF_SHELL_PORT} -j ACCEPT; iptables-save Cycle through indices (or all), run command on each. First connections to Karaf console may fail, so WUKS is used. TODO: Track as a Bug. Displays the given messages in the log file as keyword arguments. Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. Dictionary does not contain key '1'. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. Dictionary does not contain key '1'. ${status} = FAIL ${old_connection_index} = Dictionary does not contain key '1'. ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=4 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=4 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 4} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 4 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=6 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=6 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 6} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 6 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=8 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=8 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_error... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 8} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 8 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=10 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=10 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. member_index=${index} If there is a stored ssh connection index of connection to the controller's karaf console for ${member_index}, close the previous connection. In any case create a new connection to karaf console for ${member_index}, set correct prompt set and login to karaf console. Store connection index for ${member_index} and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 Keyword 'Open_Controller_Karaf_Console_On_Background' failed after retrying for 3 seconds. The last error was: NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 3s 1s Open_Controller_Karaf_Console_On_Background member_index=${index} Runs the specified keyword and retries if it fails. Keyword 'Open_Controller_Karaf_Console_On_Background' failed after retrying for 3 seconds. The last error was: NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 BuiltIn.Wait_Until_Keyword_Succeeds 3s 1s Open_Controller_Karaf_Console_On_Background member_index=${index} Runs the given keyword with the given arguments and ignores possible error. 1 ${index} @{ClusterManagement__member_index_list} http_timeout=${http_timeout} Initialize ClusterManagement. Open ssh karaf connections to each ODL. Not A Karaf App Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. Not A Karaf App Not A Karaf App ${karaf_connection_index} = 10 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.robot" Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.robot" Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.robot" Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.robot" ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.robot" ${status} = FAIL ${message} = Failed to send the command: log:log "ROBOT MESSAGE: Starting suite /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/suites/controller/dom_notification_broker/noloss_rate_1node.... ${status} ${message} Execute_Controller_Karaf_Command_On_Background ${command} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${message} Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 10} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 10 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=13 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=13 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. ${member_index} If there is a stored ssh connection index of connection to the controller's karaf console for 1, close the previous connection. In any case create a new connection to karaf console for 1, set correct prompt set and login to karaf console. Store connection index for 1 and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${message} ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. ${message} log:log "ROBOT MESSAGE: ${message}" member_index=${index} Attemp to send command to karaf for ${member_index}, if fail then open connection and try again. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} = FAIL ${output} = NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} ${output} Execute_Controller_Karaf_Command_With_Retry_On_Background log:log "ROBOT MESSAGE: ${message}" member_index=${index} Runs the given keyword with the given arguments and ignores possible error. ${output} Fails the test with the given message and optionally alters its tags. 1 ${index} @{index_list} Starting suite ${SUITE_SOURCE} ${member_index_list} Make sure this resource is initialized. Send a message into the controller's karaf log file on every node listed (or all). By default, failure while processing a node is silently ignored, unless ${tolerate_failure} is False. Log suite name to karaf log, useful in suite setup. KarafKeywords.Log_Test_Suite_Start_To_Controller_Karaf Runs the given keyword with the given arguments and ignores possible error. http_timeout=125 Prepare both FailFast and Karaf logging, log that the caller suite has started. This keyword is to be used in suite setup, and without it the other keywords may not work properly. Does absolutely nothing. This is just a more readable 'None' to override [Setup]. Not A Karaf App Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. Not A Karaf App Not A Karaf App ${karaf_connection_index} = 13 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" ${status} = FAIL ${message} = Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_5k" ${status} ${message} Execute_Controller_Karaf_Command_On_Background ${command} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${message} Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 13} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 13 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=16 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=16 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. ${member_index} If there is a stored ssh connection index of connection to the controller's karaf console for 1, close the previous connection. In any case create a new connection to karaf console for 1, set correct prompt set and login to karaf console. Store connection index for 1 and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${message} ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. ${message} log:log "ROBOT MESSAGE: ${message}" member_index=${index} Attemp to send command to karaf for ${member_index}, if fail then open connection and try again. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} = FAIL ${output} = NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} ${output} Execute_Controller_Karaf_Command_With_Retry_On_Background log:log "ROBOT MESSAGE: ${message}" member_index=${index} Runs the given keyword with the given arguments and ignores possible error. ${output} Fails the test with the given message and optionally alters its tags. 1 ${index} @{index_list} Starting test ${SUITE_NAME}.${TEST_NAME} ${member_index_list} Make sure this resource is initialized. Send a message into the controller's karaf log file on every node listed (or all). By default, failure while processing a node is silently ignored, unless ${tolerate_failure} is False. member_index_list=${member_index_list} Log test case name to karaf log, useful in test case setup. KarafKeywords.Log_Testcase_Start_To_Controller_Karaf member_index_list=${member_index_list} Runs the given keyword with the given arguments and ignores possible error. Test case setup which explicitly ignores previous failure and logs test case name to Karaf log. Needed if the recommended default is to be overriden. Overall requested rate: 5000, test duration: 300 seconds. Overall requested rate: ${total_notification_rate}, test duration: ${test_duration_in_seconds} seconds. Logs the given message with the given level. ${keyword} ${args} ${kwargs} ${sc_fail} = ['BuiltIn.Fail', [], {}] ${sc_fail} BuiltIn.Fail Turn keyword with given arguments into a scalar closure. ${ScalarClosures__fail} = ['BuiltIn.Fail', [], {}] ${ScalarClosures__fail} ${sc_fail} Makes a variable available everywhere within the scope of the current suite. ${keyword} ${args} ${kwargs} ${sc_identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${sc_identity} BuiltIn.Set_Variable placeholder Turn keyword with given arguments into a scalar closure. ${ScalarClosures__identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${ScalarClosures__identity} ${sc_identity} Makes a variable available everywhere within the scope of the current suite. Resource setup. Create closures and assign them to suite variables. Call dependency setup. Perhaps needed. ${count} = 0 ${count} ${0} Returns the given values which can then be assigned to a variables. ${count} = 1 ${count} ${count}+1 Evaluates the given expression in Python and returns the result. ${session} = ClusterManagement__session_1 ${session} ClusterManagement__session_${member_index} Returns the given values which can then be assigned to a variables. ${session} ${session} = ClusterManagement__session_1 ${session} member_index=${member_index} Return RequestsLibrary session alias pointing to node of given index. &{mapping} = { ID=working-pair-1 } &{mapping} ID=${gid} Creates and returns a dictionary based on the given ``items``. ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri</a>'. ${template} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} ${file_path} Returns the contents of a specified file. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} Logs the given message with the given level. mapping: {'ID': 'working-pair-1'} mapping: ${mapping} Logs the given message with the given level. ${encoded_mapping} = {} ${encoded_mapping} Creates and returns a dictionary based on the given ``items``. ${value} = working-pair-1 ${value} ${value} Converts the given item to a Unicode string. ${encoded} = working-pair-1 ${encoded} ${value} : %3A Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${encoded} ${encoded_value} = working-pair-1 ${encoded_value} ${value} Percent encodes reserved characters in the given string so it can be used as part of url. ${encoded_mapping} ${key} ${encoded_value} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. ID working-pair-1 ${key} ${value} &{mapping} ${encoded_mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${uri} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} folder=${folder} base_name=location extension=uri mapping=${mapping} percent_encode=True Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml</a>'. ${template} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} ${file_path} Returns the contents of a specified file. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} Logs the given message with the given level. ${mapping_to_use} ${mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${data} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} folder=${folder} name_prefix=post_ base_name=${base_name} extension=${extension} mapping=${mapping} endline=${endline} iterations=${iterations} iter_start=${iter_start} iter_j_offset=${iter_j_offset} Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${folder}${/}jmespath.expr Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${read_jmes_file} = False ${read_jmes_file} OperatingSystem.File Should Exist ${folder}${/}jmespath.expr Runs the specified keyword and returns the status as a Boolean value. ${jmes_expression} ${folder}${/}jmespath.expr Returns the contents of a specified file. ${jmes_expression} = None ${jmes_expression} ${None} Returns the given values which can then be assigned to a variables. ${expression} = ${expression} ${read_jmes_file} == ${true} ${jmes_expression} ${EMPTY} Sets variable based on the given condition. ${expression} ${jmes_expression} = ${jmes_expression} ${folder} Reads JMES path from file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr if the file exists and returns the JMES path. Empty string is returned otherwise. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} Logs the given message with the given level. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} Logs the given message with the given level. {'Content-Type': 'application/xml'} ${content_type} Logs the given message with the given level. {'Accept': 'application/xml'} ${accept} Logs the given message with the given level. ${accumulator} = {'Content-Type': 'application/xml'} ${accumulator} ${first} Returns a copy of the given dictionary. ${items_to_add} = ['Accept', 'application/xml'] ${items_to_add} ${second} Returns items of the given ``dictionary`` as a list. ${accumulator} @{items_to_add} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${accumulator} Logs the given message with the given level. ${accumulator} ${headers} = {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${headers} first=${content_type} second=${accept} Take two dicts, join them, return result. Second argument values take precedence. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} timeout=${http_timeout} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} Log response text, check status_code is one of allowed ones. In cases where this keyword is called in a WUKS it could end up logging tons of data and it may be desired to skip the logging by passing log_response=False, but by default it remains True. ${response.text} ${text_normalized} ${response.text} jmes_path=${jmes_path} Attempt to return sorted indented JSON string. ${text_normalized} ${response_text} uri=${uri} data=${data} content_type=${content_type} accept=${accept} session=${session} jmes_path=${jmes_expression} normalize_json=${normalize_json} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} POST data to given URI, check status code and return response text. ${content_type} and ${accept} are mandatory Python objects with headers to use. If ${normalize_json}, normalize text before returning. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response_text} ${response_text} folder=${folder} base_name=data extension=xml accept=${ACCEPT_XML} content_type=${HEADERS_XML} mapping=${mapping} session=${session} normalize_json=False endline=${\n} iterations=${iterations} iter_start=${iter_start} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} iter_j_offset=${iter_j_offset} Resolve URI and data from folder, call Post_To_Uri, return response text. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) response=${response_text} folder=${folder} base_name=response mapping=${mapping} iter_j_offset=${iter_j_offset} Resolve expected XML data, should be equal to provided ${response}. Endline set to empty, as this Resource does not support indented XML comparison. ${response_text} ${SUBSCRIBE_YNL_DIR} mapping=${mapping} session=${session} Add arguments sensible for XML data, return Post_Templated response text. Optionally, verification against response.xml (no iteration) is called. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${count} Subscribe listener for the notifications with identifier ${gid}. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) 5000 ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${suffix} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ${total_notification_rate}+1 ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${count} ${count} Converts the given item to an integer number. ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} ${test_duration_in_seconds} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Start publishing notifications by invoking publish-notifications rpc. ${index} 1 ${count}+1 ${getter} Get_Notifications_Active_Status ${DNB_TESTED_MEMBER_INDEX} ${count} Turn keyword with given arguments into a scalar closure. ${validator} Check_Notifications_Active_Status data_holder Turn keyword with given arguments into a scalar closure. ${validation_timeout_in_seconds} ${test_duration_in_seconds}+${DNB_CHECK_TOLERANCE_IN_SECONDS} Evaluates the given expression in Python and returns the result. timeout=${validation_timeout_in_seconds}s period=${DNB_CHECK_PERIOD_IN_SECONDS}s getter=${getter} stateless_validator=${validator} Repeatedly run getter and plug its output to validator. If both pass, return validator message. If getter fails, fail. If validator fails, repeat in WUKS fashion (fail when timeout is exceeded). FIXME: Cover this keyword in WaitUtilTest.robot ${sum_local_number} ${0} Returns the given values which can then be assigned to a variables. ${low_limit_pair_rate} 0.9*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${high_limit_pair_rate} 1.1*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${all_not} ${id_not} ${err_not} ${local_number} ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} Unsubscribe listener for the ${gid} identifier. Return statistics of the publishing process. ${err_not} ${0} Fails if objects are unequal after converting them to real numbers. ${local_number} ${0} Fails if objects are equal after converting them to real numbers. ${id_not} ${local_number} Fails if objects are unequal after converting them to real numbers. ${rate} ${local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${rate} > ${low_limit_pair_rate} Fails if the given condition is not true. ${rate} < ${high_limit_pair_rate} Fails if the given condition is not true. ${sum_local_number} ${sum_local_number}+${local_number} Evaluates the given expression in Python and returns the result. ${index} 1 ${count}+1 ${final_rate} ${sum_local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${low_limit_final_rate} 0.9*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${high_limit_final_rate} 1.1*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${final_rate} > ${low_limit_final_rate} Fails if the given condition is not true. ${final_rate} < ${high_limit_final_rate} Fails if the given condition is not true. ${5000} ${TC_DURATION_IN_SECONDS} Test case template. Input parameter ${total_notification_rate} determines, how many publisher/subscriber pais take part in the test case. For every 5000 one pair is created. The test case itself firstly subscribe listeners, then run publishers and at the end unsubscribe listeners and check achieved rates. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${SetupUtils__Known_Bug_ID} Report that a test failed due to a known Bugzilla bug whose number is provided as an argument. Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. '${SetupUtils__Known_Bug_ID}' != '' Set_Known_Bug_Id ${EMPTY} Runs the specified keyword and returns from the enclosing user keyword. ${test_skipped} = False ${test_skipped} len(re.findall('SKIPPED', """${TEST_MESSAGE}""")) > 0 modules=re Evaluates the given expression in Python and returns the result. ${newline} = ${newline} chr(10) Evaluates the given expression in Python and returns the result. ${reference} = controller_rest_cars_perf_txt_Noloss_Rate_1Node_Notifications_rate_5k ${reference} ${SUITE_NAME}_${TEST_NAME} [ /\.-] _ Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${reference} = controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k ${reference} ${reference} Converts string to lower case. ${msg} = ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k" reference somewhere inside) ${msg} ... click for list of related bugs or create a new one if needed (with the${newline}"${reference}"${newline}reference somewhere inside) Returns the given values which can then be assigned to a variables. ${bugs} = "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k&order=bug_status" ${bugs} "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=${reference}&order=bug_status" Returns the given values which can then be assigned to a variables. Set test message to: ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${msg}${newline}${bugs}${newline}${newline}${TEST_MESSAGE} Sets message for the current test case. ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k&order=bug_status" ${msg}${newline}${bugs} Logs the given message with the given level. Report that a test failed and point to linked Bugzilla bug(s). Linked bugs must contain the ${reference} inside comments (workaround becasue of currently missing suitable field for external references and not correctly working the CONTENT MATCHES filter). Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. Test case teardown. Show linked bugs in case of failure. critical ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_5k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) Does absolutely nothing. This is just a more readable 'None' to override [Setup]. Not A Karaf App Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. Not A Karaf App Not A Karaf App ${karaf_connection_index} = 16 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" ${status} = FAIL ${message} = Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_20k" ${status} ${message} Execute_Controller_Karaf_Command_On_Background ${command} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${message} Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 16} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 16 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=19 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=19 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. ${member_index} If there is a stored ssh connection index of connection to the controller's karaf console for 1, close the previous connection. In any case create a new connection to karaf console for 1, set correct prompt set and login to karaf console. Store connection index for 1 and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${message} ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. ${message} log:log "ROBOT MESSAGE: ${message}" member_index=${index} Attemp to send command to karaf for ${member_index}, if fail then open connection and try again. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} = FAIL ${output} = NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} ${output} Execute_Controller_Karaf_Command_With_Retry_On_Background log:log "ROBOT MESSAGE: ${message}" member_index=${index} Runs the given keyword with the given arguments and ignores possible error. ${output} Fails the test with the given message and optionally alters its tags. 1 ${index} @{index_list} Starting test ${SUITE_NAME}.${TEST_NAME} ${member_index_list} Make sure this resource is initialized. Send a message into the controller's karaf log file on every node listed (or all). By default, failure while processing a node is silently ignored, unless ${tolerate_failure} is False. member_index_list=${member_index_list} Log test case name to karaf log, useful in test case setup. KarafKeywords.Log_Testcase_Start_To_Controller_Karaf member_index_list=${member_index_list} Runs the given keyword with the given arguments and ignores possible error. Test case setup which explicitly ignores previous failure and logs test case name to Karaf log. Needed if the recommended default is to be overriden. Overall requested rate: 20000, test duration: 300 seconds. Overall requested rate: ${total_notification_rate}, test duration: ${test_duration_in_seconds} seconds. Logs the given message with the given level. ${keyword} ${args} ${kwargs} ${sc_fail} = ['BuiltIn.Fail', [], {}] ${sc_fail} BuiltIn.Fail Turn keyword with given arguments into a scalar closure. ${ScalarClosures__fail} = ['BuiltIn.Fail', [], {}] ${ScalarClosures__fail} ${sc_fail} Makes a variable available everywhere within the scope of the current suite. ${keyword} ${args} ${kwargs} ${sc_identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${sc_identity} BuiltIn.Set_Variable placeholder Turn keyword with given arguments into a scalar closure. ${ScalarClosures__identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${ScalarClosures__identity} ${sc_identity} Makes a variable available everywhere within the scope of the current suite. Resource setup. Create closures and assign them to suite variables. Call dependency setup. Perhaps needed. ${count} = 0 ${count} ${0} Returns the given values which can then be assigned to a variables. ${count} = 1 ${count} ${count}+1 Evaluates the given expression in Python and returns the result. ${session} = ClusterManagement__session_1 ${session} ClusterManagement__session_${member_index} Returns the given values which can then be assigned to a variables. ${session} ${session} = ClusterManagement__session_1 ${session} member_index=${member_index} Return RequestsLibrary session alias pointing to node of given index. &{mapping} = { ID=working-pair-1 } &{mapping} ID=${gid} Creates and returns a dictionary based on the given ``items``. ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri</a>'. ${template} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} ${file_path} Returns the contents of a specified file. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} Logs the given message with the given level. mapping: {'ID': 'working-pair-1'} mapping: ${mapping} Logs the given message with the given level. ${encoded_mapping} = {} ${encoded_mapping} Creates and returns a dictionary based on the given ``items``. ${value} = working-pair-1 ${value} ${value} Converts the given item to a Unicode string. ${encoded} = working-pair-1 ${encoded} ${value} : %3A Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${encoded} ${encoded_value} = working-pair-1 ${encoded_value} ${value} Percent encodes reserved characters in the given string so it can be used as part of url. ${encoded_mapping} ${key} ${encoded_value} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. ID working-pair-1 ${key} ${value} &{mapping} ${encoded_mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${uri} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} folder=${folder} base_name=location extension=uri mapping=${mapping} percent_encode=True Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml</a>'. ${template} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} ${file_path} Returns the contents of a specified file. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} Logs the given message with the given level. ${mapping_to_use} ${mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${data} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} folder=${folder} name_prefix=post_ base_name=${base_name} extension=${extension} mapping=${mapping} endline=${endline} iterations=${iterations} iter_start=${iter_start} iter_j_offset=${iter_j_offset} Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${folder}${/}jmespath.expr Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${read_jmes_file} = False ${read_jmes_file} OperatingSystem.File Should Exist ${folder}${/}jmespath.expr Runs the specified keyword and returns the status as a Boolean value. ${jmes_expression} ${folder}${/}jmespath.expr Returns the contents of a specified file. ${jmes_expression} = None ${jmes_expression} ${None} Returns the given values which can then be assigned to a variables. ${expression} = ${expression} ${read_jmes_file} == ${true} ${jmes_expression} ${EMPTY} Sets variable based on the given condition. ${expression} ${jmes_expression} = ${jmes_expression} ${folder} Reads JMES path from file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr if the file exists and returns the JMES path. Empty string is returned otherwise. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} Logs the given message with the given level. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} Logs the given message with the given level. {'Content-Type': 'application/xml'} ${content_type} Logs the given message with the given level. {'Accept': 'application/xml'} ${accept} Logs the given message with the given level. ${accumulator} = {'Content-Type': 'application/xml'} ${accumulator} ${first} Returns a copy of the given dictionary. ${items_to_add} = ['Accept', 'application/xml'] ${items_to_add} ${second} Returns items of the given ``dictionary`` as a list. ${accumulator} @{items_to_add} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${accumulator} Logs the given message with the given level. ${accumulator} ${headers} = {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${headers} first=${content_type} second=${accept} Take two dicts, join them, return result. Second argument values take precedence. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} timeout=${http_timeout} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} Log response text, check status_code is one of allowed ones. In cases where this keyword is called in a WUKS it could end up logging tons of data and it may be desired to skip the logging by passing log_response=False, but by default it remains True. ${response.text} ${text_normalized} ${response.text} jmes_path=${jmes_path} Attempt to return sorted indented JSON string. ${text_normalized} ${response_text} uri=${uri} data=${data} content_type=${content_type} accept=${accept} session=${session} jmes_path=${jmes_expression} normalize_json=${normalize_json} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} POST data to given URI, check status code and return response text. ${content_type} and ${accept} are mandatory Python objects with headers to use. If ${normalize_json}, normalize text before returning. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response_text} ${response_text} folder=${folder} base_name=data extension=xml accept=${ACCEPT_XML} content_type=${HEADERS_XML} mapping=${mapping} session=${session} normalize_json=False endline=${\n} iterations=${iterations} iter_start=${iter_start} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} iter_j_offset=${iter_j_offset} Resolve URI and data from folder, call Post_To_Uri, return response text. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) response=${response_text} folder=${folder} base_name=response mapping=${mapping} iter_j_offset=${iter_j_offset} Resolve expected XML data, should be equal to provided ${response}. Endline set to empty, as this Resource does not support indented XML comparison. ${response_text} ${SUBSCRIBE_YNL_DIR} mapping=${mapping} session=${session} Add arguments sensible for XML data, return Post_Templated response text. Optionally, verification against response.xml (no iteration) is called. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${count} Subscribe listener for the notifications with identifier ${gid}. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) 5000 ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${suffix} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ${total_notification_rate}+1 ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${count} ${count} Converts the given item to an integer number. ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} ${test_duration_in_seconds} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Start publishing notifications by invoking publish-notifications rpc. ${index} 1 ${count}+1 ${getter} Get_Notifications_Active_Status ${DNB_TESTED_MEMBER_INDEX} ${count} Turn keyword with given arguments into a scalar closure. ${validator} Check_Notifications_Active_Status data_holder Turn keyword with given arguments into a scalar closure. ${validation_timeout_in_seconds} ${test_duration_in_seconds}+${DNB_CHECK_TOLERANCE_IN_SECONDS} Evaluates the given expression in Python and returns the result. timeout=${validation_timeout_in_seconds}s period=${DNB_CHECK_PERIOD_IN_SECONDS}s getter=${getter} stateless_validator=${validator} Repeatedly run getter and plug its output to validator. If both pass, return validator message. If getter fails, fail. If validator fails, repeat in WUKS fashion (fail when timeout is exceeded). FIXME: Cover this keyword in WaitUtilTest.robot ${sum_local_number} ${0} Returns the given values which can then be assigned to a variables. ${low_limit_pair_rate} 0.9*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${high_limit_pair_rate} 1.1*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${all_not} ${id_not} ${err_not} ${local_number} ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} Unsubscribe listener for the ${gid} identifier. Return statistics of the publishing process. ${err_not} ${0} Fails if objects are unequal after converting them to real numbers. ${local_number} ${0} Fails if objects are equal after converting them to real numbers. ${id_not} ${local_number} Fails if objects are unequal after converting them to real numbers. ${rate} ${local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${rate} > ${low_limit_pair_rate} Fails if the given condition is not true. ${rate} < ${high_limit_pair_rate} Fails if the given condition is not true. ${sum_local_number} ${sum_local_number}+${local_number} Evaluates the given expression in Python and returns the result. ${index} 1 ${count}+1 ${final_rate} ${sum_local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${low_limit_final_rate} 0.9*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${high_limit_final_rate} 1.1*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${final_rate} > ${low_limit_final_rate} Fails if the given condition is not true. ${final_rate} < ${high_limit_final_rate} Fails if the given condition is not true. ${20000} ${TC_DURATION_IN_SECONDS} Test case template. Input parameter ${total_notification_rate} determines, how many publisher/subscriber pais take part in the test case. For every 5000 one pair is created. The test case itself firstly subscribe listeners, then run publishers and at the end unsubscribe listeners and check achieved rates. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${SetupUtils__Known_Bug_ID} Report that a test failed due to a known Bugzilla bug whose number is provided as an argument. Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. '${SetupUtils__Known_Bug_ID}' != '' Set_Known_Bug_Id ${EMPTY} Runs the specified keyword and returns from the enclosing user keyword. ${test_skipped} = False ${test_skipped} len(re.findall('SKIPPED', """${TEST_MESSAGE}""")) > 0 modules=re Evaluates the given expression in Python and returns the result. ${newline} = ${newline} chr(10) Evaluates the given expression in Python and returns the result. ${reference} = controller_rest_cars_perf_txt_Noloss_Rate_1Node_Notifications_rate_20k ${reference} ${SUITE_NAME}_${TEST_NAME} [ /\.-] _ Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${reference} = controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k ${reference} ${reference} Converts string to lower case. ${msg} = ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k" reference somewhere inside) ${msg} ... click for list of related bugs or create a new one if needed (with the${newline}"${reference}"${newline}reference somewhere inside) Returns the given values which can then be assigned to a variables. ${bugs} = "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k&order=bug_status" ${bugs} "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=${reference}&order=bug_status" Returns the given values which can then be assigned to a variables. Set test message to: ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${msg}${newline}${bugs}${newline}${newline}${TEST_MESSAGE} Sets message for the current test case. ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k&order=bug_status" ${msg}${newline}${bugs} Logs the given message with the given level. Report that a test failed and point to linked Bugzilla bug(s). Linked bugs must contain the ${reference} inside comments (workaround becasue of currently missing suitable field for external references and not correctly working the CONTENT MATCHES filter). Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. Test case teardown. Show linked bugs in case of failure. critical ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_20k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) Does absolutely nothing. This is just a more readable 'None' to override [Setup]. Not A Karaf App Not A Karaf App ${return_list_reference} = [1] ${return_list_reference} """${given_list}""" != "" ${given_list} ${ClusterManagement__member_index_list} Sets variable based on the given condition. ${return_list_copy} = [1] ${return_list_copy} @{return_list_reference} Returns a list containing given items. ${return_list_copy} ${index_list} = [1] ${index_list} given_list=${member_index_list} Utility to allow ${EMPTY} as default argument value, as the internal list is computed at runtime. This keyword always returns a (shallow) copy of given or default list, so operations with the returned list should not affect other lists. Also note that this keyword does not consider empty list to be ${EMPTY}. Not A Karaf App Not A Karaf App ${karaf_connection_index} = 19 ${karaf_connection_index} ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${current_connection_index} = None ${current_connection_index} ${karaf_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. ${command} Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. ${status_write} = FAIL ${message_write} = Cannot open session, you need to establish a connection first. ${status_write} ${message_write} SSHLibrary.Write ${command} Runs the given keyword with the given arguments and ignores possible error. Cannot open session, you need to establish a connection first. ${KARAF_PROMPT} Consumes and returns the server output until a match to ``regexp`` is found. Cannot open session, you need to establish a connection first. ${status_wait} = FAIL ${message_wait} = Cannot open session, you need to establish a connection first. ${status_wait} ${message_wait} SSHLibrary.Read_Until_Regexp ${KARAF_PROMPT} Runs the given keyword with the given arguments and ignores possible error. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" Failed to send the command: ${command} Fails the test with the given message and optionally alters its tags. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" ${message_wait} Logs the given message with the given level. Failed to see prompt after sending the command: ${command} Fails the test with the given message and optionally alters its tags. ${message_wait} ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_connection_index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_connection_index} Runs the given keyword with the given arguments, if ``condition`` is true. ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" ${status} = FAIL ${message} = Failed to send the command: log:log "ROBOT MESSAGE: Starting test controller-rest-cars-perf.txt.Noloss Rate 1Node.Notifications_rate_60k" ${status} ${message} Execute_Controller_Karaf_Command_On_Background ${command} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${message} Not A Karaf App index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} = index=None host=None alias=None port=22 timeout=3 seconds newline= prompt=None term_type=vt100 width=80 height=24 path_separator=/ encoding=utf8 escape_ansi=False encoding_errors=strict ${current_ssh_connection_object} Returns information about the connection. {1: 19} ${connection_index_dict} Logs the given message with the given level. 1 ${member_index} Logs the given message with the given level. ${connection_index_dict} ${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${status} = PASS ${old_connection_index} = 19 ${status} ${old_connection_index} Get From Dictionary ${connection_index_dict} ${member_index} Runs the given keyword with the given arguments and ignores possible error. ${old_connection_index} Switches the active connection by index or alias. Cannot open session, you need to establish a connection first. logout Writes the given ``text`` on the remote machine and appends a newline. Cannot open session, you need to establish a connection first. SSHLibrary.Write logout Runs the given keyword with the given arguments and ignores possible error. Closes the current connection. SSHLibrary.Close_Connection Runs the given keyword with the given arguments and ignores possible error. SSHLibrary.Switch_Connection ${old_connection_index} AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Write logout AND BuiltIn.Run_Keyword_And_Ignore_Error SSHLibrary.Close_Connection Executes all the given keywords in a sequence. ${ip_address} = 10.30.170.35 ${ip_address} dictionary=${ClusterManagement__index_to_ip_mapping} key=${member_index} Returns a value from the given ``dictionary`` based on the given ``key``. ${ip_address} ${odl_ip} = 10.30.170.35 ${odl_ip} ${member_index} Return node IP address of given index. ${odl_ip} port=${KARAF_SHELL_PORT} prompt=${KARAF_PROMPT_LOGIN} timeout=${timeout} Opens a new SSH connection to the given ``host`` and ``port``. index=22 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_errors=strict ${karaf_connection_object} = index=22 host=10.30.170.35 alias=None port=8101 timeout=10 seconds newline= prompt=opendaylight-user term_type=vt100 width=80 height=24 path_separator=/ encoding=UTF-8 escape_ansi=False encoding_erro... ${karaf_connection_object} Returns information about the connection. ${connection_index_dict} ${member_index} ${karaf_connection_object.index} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. Logging into '10.30.170.35:8101' as 'karaf'. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${KARAF_USER} ${KARAF_PASSWORD} loglevel=${loglevel} Logs into the SSH server with the given ``username`` and ``password``. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${connection_index} is not None SSHLibrary.Switch Connection ${connection_index} Runs the specified keyword and returns from the enclosing user keyword. 127.0.0.1 Opens a new SSH connection to the given ``host`` and ``port``. Closes the current connection. ${current_ssh_connection_object.index} Restore active SSH connection in SSHLibrary to given index. '${IS_KARAF_APPL}' == 'True' SSHKeywords.Restore_Current_Ssh_Connection_From_Index ${current_ssh_connection_object.index} Runs the given keyword with the given arguments, if ``condition`` is true. ${member_index} If there is a stored ssh connection index of connection to the controller's karaf console for 1, close the previous connection. In any case create a new connection to karaf console for 1, set correct prompt set and login to karaf console. Store connection index for 1 and restore the previous active connection. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${message} ${command} ${member_index} Send command to karaf without affecting current SSH connection. Read, log and return response. ${message} log:log "ROBOT MESSAGE: ${message}" member_index=${index} Attemp to send command to karaf for ${member_index}, if fail then open connection and try again. NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} = FAIL ${output} = NoValidConnectionsError: [Errno None] Unable to connect to port 8101 on 10.30.170.35 ${status} ${output} Execute_Controller_Karaf_Command_With_Retry_On_Background log:log "ROBOT MESSAGE: ${message}" member_index=${index} Runs the given keyword with the given arguments and ignores possible error. ${output} Fails the test with the given message and optionally alters its tags. 1 ${index} @{index_list} Starting test ${SUITE_NAME}.${TEST_NAME} ${member_index_list} Make sure this resource is initialized. Send a message into the controller's karaf log file on every node listed (or all). By default, failure while processing a node is silently ignored, unless ${tolerate_failure} is False. member_index_list=${member_index_list} Log test case name to karaf log, useful in test case setup. KarafKeywords.Log_Testcase_Start_To_Controller_Karaf member_index_list=${member_index_list} Runs the given keyword with the given arguments and ignores possible error. Test case setup which explicitly ignores previous failure and logs test case name to Karaf log. Needed if the recommended default is to be overriden. Overall requested rate: 60000, test duration: 300 seconds. Overall requested rate: ${total_notification_rate}, test duration: ${test_duration_in_seconds} seconds. Logs the given message with the given level. ${keyword} ${args} ${kwargs} ${sc_fail} = ['BuiltIn.Fail', [], {}] ${sc_fail} BuiltIn.Fail Turn keyword with given arguments into a scalar closure. ${ScalarClosures__fail} = ['BuiltIn.Fail', [], {}] ${ScalarClosures__fail} ${sc_fail} Makes a variable available everywhere within the scope of the current suite. ${keyword} ${args} ${kwargs} ${sc_identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${sc_identity} BuiltIn.Set_Variable placeholder Turn keyword with given arguments into a scalar closure. ${ScalarClosures__identity} = ['BuiltIn.Set_Variable', ['placeholder'], {}] ${ScalarClosures__identity} ${sc_identity} Makes a variable available everywhere within the scope of the current suite. Resource setup. Create closures and assign them to suite variables. Call dependency setup. Perhaps needed. ${count} = 0 ${count} ${0} Returns the given values which can then be assigned to a variables. ${count} = 1 ${count} ${count}+1 Evaluates the given expression in Python and returns the result. ${session} = ClusterManagement__session_1 ${session} ClusterManagement__session_${member_index} Returns the given values which can then be assigned to a variables. ${session} ${session} = ClusterManagement__session_1 ${session} member_index=${member_index} Return RequestsLibrary session alias pointing to node of given index. &{mapping} = { ID=working-pair-1 } &{mapping} ID=${gid} Creates and returns a dictionary based on the given ``items``. ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/location.uri' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/location.uri</a>'. ${template} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} ${file_path} Returns the contents of a specified file. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${template} Logs the given message with the given level. mapping: {'ID': 'working-pair-1'} mapping: ${mapping} Logs the given message with the given level. ${encoded_mapping} = {} ${encoded_mapping} Creates and returns a dictionary based on the given ``items``. ${value} = working-pair-1 ${value} ${value} Converts the given item to a Unicode string. ${encoded} = working-pair-1 ${encoded} ${value} : %3A Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${encoded} ${encoded_value} = working-pair-1 ${encoded_value} ${value} Percent encodes reserved characters in the given string so it can be used as part of url. ${encoded_mapping} ${key} ${encoded_value} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. ID working-pair-1 ${key} ${value} &{mapping} ${encoded_mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${uri} = /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} folder=${folder} base_name=location extension=uri mapping=${mapping} percent_encode=True Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) ${file_path_stream} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml ${file_path_stream} ${folder}.${ODL_STREAM}${/}${file_name} Returns the given values which can then be assigned to a variables. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_path_stream} Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/post_data.xml' does not exist. ${file_stream_exists} = False ${file_stream_exists} OperatingSystem.File Should Exist ${file_path_stream} Runs the specified keyword and returns the status as a Boolean value. ${file_path} = /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml ${file_path} ${file_stream_exists} ${file_path_stream} ${folder}${/}${file_name} Sets variable based on the given condition. Getting file '<a href="file:///w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml">/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/post_data.xml</a>'. ${template} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} ${file_path} Returns the contents of a specified file. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>$ID</id> </input> ${template} Logs the given message with the given level. ${mapping_to_use} ${mapping} ${mapping_to_use} = {'ID': 'working-pair-1'} ${mapping_to_use} ${mapping} Returns the given values which can then be assigned to a variables. ${final_text} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${final_text} string.Template('''${template}'''.rstrip()).safe_substitute(${mapping_to_use}) modules=string Evaluates the given expression in Python and returns the result. ${final_text} folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. Returning from the enclosing user keyword. not "${iterations}" Resolve_Text_From_Template_File folder=${folder} file_name=${name_prefix}${base_name}.${extension} mapping=${mapping} percent_encode=${percent_encode} Runs the specified keyword and returns from the enclosing user keyword. ${prolog} folder=${folder} file_name=${name_prefix}${base_name}.prolog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${epilog} folder=${folder} file_name=${name_prefix}${base_name}.epilog.${extension} mapping=${mapping} percent_encode=${percent_encode} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${item_template} folder=${folder} file_name=${base_name}.item.${extension} mapping=${mapping} Check if /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name} exists. If yes read and Log contents of file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl.vanadium/${file_name}, remove endline, perform safe substitution, return result. If no do it with the default /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/${file_name}. ${items} Returns a list containing given items. ${separator} '${extension}' != 'json' ${endline} ,${endline} Sets variable based on the given condition. ${items} ${separator} Adds ``values`` to the end of ``list``. ${j} ${iteration}+${iter_j_offset} Evaluates the given expression in Python and returns the result. ${item} string.Template('''${item_template}''').substitute({"i":"${iteration}", "j":${j}}) modules=string Evaluates the given expression in Python and returns the result. ${items} ${item} Adds ``values`` to the end of ``list``. ${iteration} ${iter_start} ${iterations}+${iter_start} ${final_text} SEPARATOR= ${prolog} ${endline} @{items} ${endline} ${epilog} Catenates the given items together and returns the resulted string. ${final_text} ${data} = <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} folder=${folder} name_prefix=post_ base_name=${base_name} extension=${extension} mapping=${mapping} endline=${endline} iterations=${iterations} iter_start=${iter_start} iter_j_offset=${iter_j_offset} Read a template from folder, strip endline, make changes according to mapping, return the result. If ${iterations} value is present, put text together from "prolog", "item" and "epilog" parts, where additional template variable ${i} goes from 1, by one times. Template variable ${j} is calculated as ${i} incremented by offset 0 ( j = i + iter_j_offset ) used to create non uniform data in order to be able to validate UPDATE operations. POST (as opposed to PUT) needs slightly different data, ${name_prefix} may be used to distinguish. (Actually, it is GET who formats data differently when URI is a top-level container.) File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${folder}${/}jmespath.expr Fails unless the given ``path`` points to an existing file. File '/w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr' does not exist. ${read_jmes_file} = False ${read_jmes_file} OperatingSystem.File Should Exist ${folder}${/}jmespath.expr Runs the specified keyword and returns the status as a Boolean value. ${jmes_expression} ${folder}${/}jmespath.expr Returns the contents of a specified file. ${jmes_expression} = None ${jmes_expression} ${None} Returns the given values which can then be assigned to a variables. ${expression} = ${expression} ${read_jmes_file} == ${true} ${jmes_expression} ${EMPTY} Sets variable based on the given condition. ${expression} ${jmes_expression} = ${jmes_expression} ${folder} Reads JMES path from file /w/workspace/controller-csit-1node-rest-cars-perf-all-vanadium/test/csit/libraries/../variables/mdsal/lowlevelrpc/subscribe_ynl/jmespath.expr if the file exists and returns the JMES path. Empty string is returned otherwise. /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl ${uri} Logs the given message with the given level. <input xmlns="tag:opendaylight.org,2017:controller:yang:lowlevel:control"> <id>working-pair-1</id> </input> ${data} Logs the given message with the given level. {'Content-Type': 'application/xml'} ${content_type} Logs the given message with the given level. {'Accept': 'application/xml'} ${accept} Logs the given message with the given level. ${accumulator} = {'Content-Type': 'application/xml'} ${accumulator} ${first} Returns a copy of the given dictionary. ${items_to_add} = ['Accept', 'application/xml'] ${items_to_add} ${second} Returns items of the given ``dictionary`` as a list. ${accumulator} @{items_to_add} Adds the given ``key_value_pairs`` and/or ``items`` to the ``dictionary``. {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${accumulator} Logs the given message with the given level. ${accumulator} ${headers} = {'Content-Type': 'application/xml', 'Accept': 'application/xml'} ${headers} first=${content_type} second=${accept} Take two dicts, join them, return result. Second argument values take precedence. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} ${session} ${uri} data=${data} headers=${headers} timeout=${http_timeout} Sends a POST request on a previously created HTTP Session. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} Log response text, check status_code is one of allowed ones. In cases where this keyword is called in a WUKS it could end up logging tons of data and it may be desired to skip the logging by passing log_response=False, but by default it remains True. ${response.text} ${text_normalized} ${response.text} jmes_path=${jmes_path} Attempt to return sorted indented JSON string. ${text_normalized} ${response_text} uri=${uri} data=${data} content_type=${content_type} accept=${accept} session=${session} jmes_path=${jmes_expression} normalize_json=${normalize_json} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} POST data to given URI, check status code and return response text. ${content_type} and ${accept} are mandatory Python objects with headers to use. If ${normalize_json}, normalize text before returning. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${response_text} ${response_text} folder=${folder} base_name=data extension=xml accept=${ACCEPT_XML} content_type=${HEADERS_XML} mapping=${mapping} session=${session} normalize_json=False endline=${\n} iterations=${iterations} iter_start=${iter_start} additional_allowed_status_codes=${additional_allowed_status_codes} explicit_status_codes=${explicit_status_codes} http_timeout=${http_timeout} iter_j_offset=${iter_j_offset} Resolve URI and data from folder, call Post_To_Uri, return response text. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) response=${response_text} folder=${folder} base_name=response mapping=${mapping} iter_j_offset=${iter_j_offset} Resolve expected XML data, should be equal to provided ${response}. Endline set to empty, as this Resource does not support indented XML comparison. ${response_text} ${SUBSCRIBE_YNL_DIR} mapping=${mapping} session=${session} Add arguments sensible for XML data, return Post_Templated response text. Optionally, verification against response.xml (no iteration) is called. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${count} Subscribe listener for the notifications with identifier ${gid}. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) 5000 ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${suffix} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ${total_notification_rate}+1 ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${count} ${count} Converts the given item to an integer number. ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} ${test_duration_in_seconds} ${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Start publishing notifications by invoking publish-notifications rpc. ${index} 1 ${count}+1 ${getter} Get_Notifications_Active_Status ${DNB_TESTED_MEMBER_INDEX} ${count} Turn keyword with given arguments into a scalar closure. ${validator} Check_Notifications_Active_Status data_holder Turn keyword with given arguments into a scalar closure. ${validation_timeout_in_seconds} ${test_duration_in_seconds}+${DNB_CHECK_TOLERANCE_IN_SECONDS} Evaluates the given expression in Python and returns the result. timeout=${validation_timeout_in_seconds}s period=${DNB_CHECK_PERIOD_IN_SECONDS}s getter=${getter} stateless_validator=${validator} Repeatedly run getter and plug its output to validator. If both pass, return validator message. If getter fails, fail. If validator fails, repeat in WUKS fashion (fail when timeout is exceeded). FIXME: Cover this keyword in WaitUtilTest.robot ${sum_local_number} ${0} Returns the given values which can then be assigned to a variables. ${low_limit_pair_rate} 0.9*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${high_limit_pair_rate} 1.1*${DNB_PUBLISHER_SUBSCRIBER_PAIR_RATE} Evaluates the given expression in Python and returns the result. ${all_not} ${id_not} ${err_not} ${local_number} ${DNB_TESTED_MEMBER_INDEX} ${DNB_PUBLISHER_LISTENER_PREFIX}${index} Unsubscribe listener for the ${gid} identifier. Return statistics of the publishing process. ${err_not} ${0} Fails if objects are unequal after converting them to real numbers. ${local_number} ${0} Fails if objects are equal after converting them to real numbers. ${id_not} ${local_number} Fails if objects are unequal after converting them to real numbers. ${rate} ${local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${rate} > ${low_limit_pair_rate} Fails if the given condition is not true. ${rate} < ${high_limit_pair_rate} Fails if the given condition is not true. ${sum_local_number} ${sum_local_number}+${local_number} Evaluates the given expression in Python and returns the result. ${index} 1 ${count}+1 ${final_rate} ${sum_local_number}/${test_duration_in_seconds} Evaluates the given expression in Python and returns the result. ${low_limit_final_rate} 0.9*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${high_limit_final_rate} 1.1*${total_notification_rate} Evaluates the given expression in Python and returns the result. ${final_rate} > ${low_limit_final_rate} Fails if the given condition is not true. ${final_rate} < ${high_limit_final_rate} Fails if the given condition is not true. ${60000} ${TC_DURATION_IN_SECONDS} Test case template. Input parameter ${total_notification_rate} determines, how many publisher/subscriber pais take part in the test case. For every 5000 one pair is created. The test case itself firstly subscribe listeners, then run publishers and at the end unsubscribe listeners and check achieved rates. ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${SetupUtils__Known_Bug_ID} Report that a test failed due to a known Bugzilla bug whose number is provided as an argument. Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. '${SetupUtils__Known_Bug_ID}' != '' Set_Known_Bug_Id ${EMPTY} Runs the specified keyword and returns from the enclosing user keyword. ${test_skipped} = False ${test_skipped} len(re.findall('SKIPPED', """${TEST_MESSAGE}""")) > 0 modules=re Evaluates the given expression in Python and returns the result. ${newline} = ${newline} chr(10) Evaluates the given expression in Python and returns the result. ${reference} = controller_rest_cars_perf_txt_Noloss_Rate_1Node_Notifications_rate_60k ${reference} ${SUITE_NAME}_${TEST_NAME} [ /\.-] _ Replaces ``pattern`` in the given ``string`` with ``replace_with``. ${reference} = controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k ${reference} ${reference} Converts string to lower case. ${msg} = ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k" reference somewhere inside) ${msg} ... click for list of related bugs or create a new one if needed (with the${newline}"${reference}"${newline}reference somewhere inside) Returns the given values which can then be assigned to a variables. ${bugs} = "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k&order=bug_status" ${bugs} "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=${reference}&order=bug_status" Returns the given values which can then be assigned to a variables. Set test message to: ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) ${msg}${newline}${bugs}${newline}${newline}${TEST_MESSAGE} Sets message for the current test case. ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k&order=bug_status" ${msg}${newline}${bugs} Logs the given message with the given level. Report that a test failed and point to linked Bugzilla bug(s). Linked bugs must contain the ${reference} inside comments (workaround becasue of currently missing suitable field for external references and not correctly working the CONTENT MATCHES filter). Not FAILED (incl. SKIPPED) test are not reported. This keyword must be used in the [Teardown] setting of the affected test or as the first line of the test if FastFail module is not being used. It reports the URL of the bug on console and also puts it into the Robot log file. Test case teardown. Show linked bugs in case of failure. critical ... click for list of related bugs or create a new one if needed (with the "controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k" reference somewhere inside) "https://bugs.opendaylight.org/buglist.cgi?f1=cf_external_ref&o1=substring&v1=controller_rest_cars_perf_txt_noloss_rate_1node_notifications_rate_60k&order=bug_status" ConnectionError: HTTPConnectionPool(host='10.30.170.35', port=8181): Max retries exceeded with url: /rests/operations/odl-mdsal-lowlevel-control:subscribe-ynl (Caused by NewConnectionError("HTTPConnection(host='10.30.170.35', port=8181): Failed to establish a new connection: [Errno 111] Connection refused")) Closes all open connections. DOMNotificationBroker testing: No-loss rate Copyright (c) 2017 Cisco Systems, Inc. and others. All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html Provides routing of YANG notifications from publishers to subscribers. The purpose of this test is to determine the broker can forward messages without loss. We do this on a single-node setup by incrementally adding publishers and subscribers. All Tests critical controller-rest-cars-perf.txt controller-rest-cars-perf.txt.010 Crud Mdsal Perf controller-rest-cars-perf.txt.Noloss Rate 1Node