*** Settings ***
-Documentation Keywords wrapping controller's odl-mdsal-lowlevel yang model rpcs.
+Documentation Keywords wrapping controller's odl-mdsal-lowlevel yang model rpcs.
...
-... This is just an initial skeleton implementation, calls are debugged. Multiple
-... changes will follow as suites will be implemented.
-... This suite should be preferably merged before any suite to avoid conflicting
-... situations while suites will be implementing.
+... Copyright (c) 2017 Cisco Systems, Inc. and others. All rights reserved.
...
-... 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
-Library XML
-Resource ${CURDIR}/ClusterManagement.robot
-Resource ${CURDIR}/TemplatedRequests.robot
+... 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
+
+Library XML
+Resource ${CURDIR}/ClusterManagement.robot
+Resource ${CURDIR}/TemplatedRequests.robot
+
*** Variables ***
-${RPC_DIR} ${CURDIR}/../variables/mdsal/lowlevelrpc
-${ADD_SHARD_REPLICA_DIR} ${RPC_DIR}/add_shard_replica
-${BECOME_MODULE_LEADER_DIR} ${RPC_DIR}/become_module_leader
-${BECOME_PREFIX_LEADER_DIR} ${RPC_DIR}/become_prefix_leader
-${DECONFIGURE_ID_INTS_SHARD_DIR} ${RPC_DIR}/deconfigure_id_ints_shard
-${GET_CONSTANT_DIR} ${RPC_DIR}/get_constant
-${GET_CONTEXTED_CONSTANT_DIR} ${RPC_DIR}/get_contexted_constant
-${GET_SINGLETON_CONSTANT_DIR} ${RPC_DIR}/get_singleton_constant
-${IS_CLIENT_ABORTED_DIR} ${RPC_DIR}/is_client_aborted
-${PRODUCE_TRANSACTIONS_DIR} ${RPC_DIR}/produce_transactions
-${PUBLISH_NOTIFICATIONS_DIR} ${RPC_DIR}/publish_notifications
-${REGISTER_BOUND_CONSTANT_DIR} ${RPC_DIR}/register_bound_constant
-${REGISTER_CONSTANT_DIR} ${RPC_DIR}/register_constant
-${REGISTER_DEFAULT_CONSTANT_DIR} ${RPC_DIR}/register_default_constant
-${REGISTER_FLAPPING_SINGLETON_DIR} ${RPC_DIR}/register_flapping_singleton
-${REGISTER_SINGLETON_CONSTANT_DIR} ${RPC_DIR}/register_singleton_constant
-${REMOVE_SHARD_REPLICA_DIR} ${RPC_DIR}/remove_shard_replica
-${SUBSCRIBE_DDTL_DIR} ${RPC_DIR}/subscribe_ddtl
-${SUBSCRIBE_DTCL_DIR} ${RPC_DIR}/subscribe_dtcl
-${SUBSCRIBE_YNL_DIR} ${RPC_DIR}/subscribe_ynl
-${UNREGISTER_BOUND_CONSTANT_DIR} ${RPC_DIR}/unregister_bound_constant
-${UNREGISTER_CONSTANT_DIR} ${RPC_DIR}/unregister_constant
-${UNREGISTER_DEFAULT_CONSTANT_DIR} ${RPC_DIR}/unregister_default_constant
-${UNREGISTER_FLAPPING_SINGLETON_DIR} ${RPC_DIR}/unregister_flapping_singleton
-${UNREGISTER_SINGLETON_CONSTANT_DIR} ${RPC_DIR}/unregister_singleton_constant
-${UNSUBSCRIBE_DDTL_DIR} ${RPC_DIR}/unsubscribe_ddtl
-${UNSUBSCRIBE_DTCL_DIR} ${RPC_DIR}/unsubscribe_dtcl
-${UNSUBSCRIBE_YNL_DIR} ${RPC_DIR}/unsubscribe_ynl
-${WRITE_TRANSACTIONS_DIR} ${RPC_DIR}/write_transactions
+${LOWLEVEL_RPC_DIR} ${CURDIR}/../variables/mdsal/lowlevelrpc
+${BECOME_PREFIX_LEADER_DIR} ${LOWLEVEL_RPC_DIR}/become_prefix_leader
+${CHECK_PUBLISH_NOTIFICATIONS_DIR} ${LOWLEVEL_RPC_DIR}/check_publish_notifications
+${CREATE_PREFIX_SHARD_DIR} ${LOWLEVEL_RPC_DIR}/create_prefix_shard
+${GET_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/get_constant
+${GET_CONTEXTED_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/get_contexted_constant
+${GET_SINGLETON_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/get_singleton_constant
+${PRODUCE_TRANSACTIONS_DIR} ${LOWLEVEL_RPC_DIR}/produce_transactions
+${REGISTER_BOUND_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/register_bound_constant
+${REGISTER_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/register_constant
+${REGISTER_FLAPPING_SINGLETON_DIR} ${LOWLEVEL_RPC_DIR}/register_flapping_singleton
+${REGISTER_SINGLETON_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/register_singleton_constant
+${REMOVE_PREFIX_SHARD_DIR} ${LOWLEVEL_RPC_DIR}/remove_prefix_shard
+${SHUTDOWN_SHARD_REPLICA_DIR} ${LOWLEVEL_RPC_DIR}/shutdown_shard_replica
+${SHUTDOWN_PREFIX_SHARD_REPLICA_DIR} ${LOWLEVEL_RPC_DIR}/shutdown_prefix_shard_replica
+${START_PUBLISH_NOTIFICATIONS_DIR} ${LOWLEVEL_RPC_DIR}/start_publish_notifications
+${SUBSCRIBE_DDTL_DIR} ${LOWLEVEL_RPC_DIR}/subscribe_ddtl
+${SUBSCRIBE_DTCL_DIR} ${LOWLEVEL_RPC_DIR}/subscribe_dtcl
+${SUBSCRIBE_YNL_DIR} ${LOWLEVEL_RPC_DIR}/subscribe_ynl
+${UNREGISTER_BOUND_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/unregister_bound_constant
+${UNREGISTER_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/unregister_constant
+${UNREGISTER_FLAPPING_SINGLETON_DIR} ${LOWLEVEL_RPC_DIR}/unregister_flapping_singleton
+${UNREGISTER_SINGLETON_CONSTANT_DIR} ${LOWLEVEL_RPC_DIR}/unregister_singleton_constant
+${UNSUBSCRIBE_DDTL_DIR} ${LOWLEVEL_RPC_DIR}/unsubscribe_ddtl
+${UNSUBSCRIBE_DTCL_DIR} ${LOWLEVEL_RPC_DIR}/unsubscribe_dtcl
+${UNSUBSCRIBE_YNL_DIR} ${LOWLEVEL_RPC_DIR}/unsubscribe_ynl
+${WRITE_TRANSACTIONS_DIR} ${LOWLEVEL_RPC_DIR}/write_transactions
+
*** Keywords ***
Get_Constant
+ [Documentation] Invoke get-constant rpc on the requested member and return the registered constant unless explicit status code is expected.
+ ... The ${explicit_status_codes} is a list of http status codes for which the rpc call is considered as passed and is used for calls with
+ ... expected failures on odl's side, such as calling the rpc on isolated node etc.
[Arguments] ${member_index} ${explicit_status_codes}=${NO_STATUS_CODES}
- [Documentation] Invoke get-constant rpc on the requested member and return the registered constant. The ${explicit_status_codes} is a list
- ... of http status codes for which the rpc call is considered as passed and is used for calls with expected failures on odl's side, such as
- ... calling the rpc on isolated node etc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${text} = TemplatedRequests.Post_As_Xml_Templated ${GET_CONSTANT_DIR} session=${session} explicit_status_codes=${explicit_status_codes}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${GET_CONSTANT_DIR}
+ ... session=${session}
+ ... explicit_status_codes=${explicit_status_codes}
+ IF """${explicit_status_codes}""" != """${NO_STATUS_CODES}""" RETURN
${xml} = XML.Parse_Xml ${text}
${constant} = XML.Get_Element_Text ${xml} xpath=constant
- BuiltIn.Return_From_Keyword ${constant}
+ RETURN ${constant}
Get_Contexted_Constant
+ [Documentation] Invoke get-contexted-constant rpc on the requested member and return the registered constant. The argument ${context} is only the string part
+ ... of the whole instance identifier. The ${explicit_status_codes} is a list of http status codes for which the rpc call is considered as passed and is used for
+ ... calls with expected failures on odl's side, such as calling the rpc on isolated node etc.
[Arguments] ${member_index} ${context}
- [Documentation] TODO: more desctiptive comment than: Invoke get-contexted-constant rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary CONTEXT=${context}
- ${test} = TemplatedRequests.Post_As_Xml_Templated ${GET_CONTEXTED_CONSTANT_DIR} mapping=${mapping} session=${session}
- BuiltIn.Fail TODO: to format output data or at least to check the format
- BuiltIn.Return_From_Keyword ${formatted_output}
+ &{mapping} = BuiltIn.Create_Dictionary CONTEXT=${context}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${GET_CONTEXTED_CONSTANT_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
+ ${xml} = XML.Parse_Xml ${text}
+ ${constant} = XML.Get_Element_Text ${xml} xpath=constant
+ RETURN ${constant}
Get_Singleton_Constant
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke get-singleton-constant rpc.
+ [Documentation] Invoke get-singleton-constant rpc on the requested member and return the registered constant unless explicit status code is
+ ... expected. The ${explicit_status_codes} is a list of http status codes for which the rpc call is considered as passed and is used for calls
+ ... with expected failures on odl's side, such as calling the rpc on isolated node etc.
+ [Arguments] ${member_index} ${explicit_status_codes}=${NO_STATUS_CODES}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${GET_SINGLETON_CONSTANT_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
- BuiltIn.Fail TODO: to format output data
- BuiltIn.Return_From_Keyword ${formatted_output}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${GET_SINGLETON_CONSTANT_DIR}
+ ... session=${session}
+ ... explicit_status_codes=${explicit_status_codes}
+ IF """${explicit_status_codes}""" != """${NO_STATUS_CODES}""" RETURN
+ ${xml} = XML.Parse_Xml ${text}
+ ${constant} = XML.Get_Element_Text ${xml} xpath=constant
+ RETURN ${constant}
Register_Constant
- [Arguments] ${member_index} ${constant}
[Documentation] Register the get-constant rpc on the requested node with given constant.
+ [Arguments] ${member_index} ${constant}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary CONSTANT=${constant}
+ &{mapping} = BuiltIn.Create_Dictionary CONSTANT=${constant}
TemplatedRequests.Post_As_Xml_Templated ${REGISTER_CONSTANT_DIR} mapping=${mapping} session=${session}
Unregister_Constant
- [Arguments] ${member_index}
[Documentation] Unregister the get-constant rpc on the given node.
+ [Arguments] ${member_index}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
TemplatedRequests.Post_As_Xml_Templated ${UNREGISTER_CONSTANT_DIR} session=${session}
Register_Singleton_Constant
+ [Documentation] Register singleton application on given node by invoking register-singleton-constant rpc.
[Arguments] ${member_index} ${constant}
- [Documentation] TODO: more desctiptive comment than: Invoke register-singleton-constant rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary CONSTANT=${constant}
- TemplatedRequests.Post_As_Xml_Templated ${REGISTER_SINGLETON_CONSTANT_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary CONSTANT=${constant}
+ TemplatedRequests.Post_As_Xml_Templated
+ ... ${REGISTER_SINGLETON_CONSTANT_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
Unregister_Singleton_Constant
+ [Documentation] Unregister singleton application on given node by invoking unregister-singleton-constant rpc.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unregister-singleton-constant rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${UNREGISTER_SINGLETON_CONSTANT_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ TemplatedRequests.Post_As_Xml_Templated ${UNREGISTER_SINGLETON_CONSTANT_DIR} session=${session}
Register_Flapping_Singleton
+ [Documentation] Activate flapping application on given node by invoking register-flapping-singleton rpc.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke register-flapping-singleton rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${REGISTER_FLAPPING_SINGLETON_DIR} base_name=location extension=uri
- TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ TemplatedRequests.Post_As_Xml_Templated ${REGISTER_FLAPPING_SINGLETON_DIR} session=${session}
Unregister_Flapping_Singleton
+ [Documentation] Deactivate flapping singleton application by invoking unregister-flapping-singleton rpc.
+ ... Return the successful re-registrations count.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unregister-flapping-singleton rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${UNREGISTER_FLAPPING_SINGLETON_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated ${UNREGISTER_FLAPPING_SINGLETON_DIR} session=${session}
+ ${xml} = XML.Parse_Xml ${text}
+ ${count} = XML.Get_Element_Text ${xml} xpath=flap-count
+ RETURN ${count}
Write_Transactions
- [Arguments] ${member_index} ${seconds} ${trans_per_sec} ${chained_trans}=${True}
- [Documentation] TODO: more desctiptive comment than: Invoke write-transactions rpc.
+ [Documentation] Create transactions with given rate for given time for module-based shards.
+ [Arguments] ${member_index} ${identifier} ${seconds} ${trans_per_sec} ${chained_trans}=${True}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SECONDS=${seconds} TPS=${trans_per_sec} CHAINED_TRANSACTIONS=${chained_trans}
+ &{mapping} = BuiltIn.Create_Dictionary
+ ... ID=${identifier}
+ ... DURATION=${seconds}
+ ... RATE=${trans_per_sec}
+ ... CHAINED_FLAG=${chained_trans}
TemplatedRequests.Post_As_Xml_Templated ${WRITE_TRANSACTIONS_DIR} mapping=${mapping} session=${session}
Produce_Transactions
+ [Documentation] Create transactions with given rate for given time for prefix-based shards.
[Arguments] ${member_index} ${seconds} ${trans_per_sec} ${isolated_trans}=${True}
- [Documentation] TODO: more desctiptive comment than: Invoke produce-transactions rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SECONDS=${seconds} TPS=${trans_per_sec} ISOLATED_TRANSACTIONS=${chained_trans}
+ &{mapping} = BuiltIn.Create_Dictionary
+ ... SECONDS=${seconds}
+ ... TPS=${trans_per_sec}
+ ... ISOLATED_TRANSACTIONS=${chained_trans}
TemplatedRequests.Post_As_Xml_Templated ${PRODUCE_TRANSACTIONS_DIR} mapping=${mapping} session=${session}
-Become_Prefix_Leader
- [Arguments] ${member_index} ${shard_name}
- [Documentation] TODO: more desctiptive comment than: Invoke become-prefix-leader rpc.
+Create_Prefix_Shard
+ [Documentation] Create prefix based shard. ${replicas} is a list of cluster node indexes, taken e.g. from ClusterManagement.List_Indices_Or_All.
+ [Arguments] ${member_index} ${prefix} ${replicas}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SHARD_NAME=${shard_name}
- ${text} = TemplatedRequests.Post_As_Xml_Templated ${BECOME_PREFIX_LEADER_DIR} mapping=${mapping} session=${session}
+ ${replicas_str} = BuiltIn.Set_Variable ${EMPTY}
+ FOR ${replica} IN @{replicas}
+ ${replicas_str} = BuiltIn.Set_Variable ${replicas_str}<replicas>member-${replica}</replicas>
+ END
+ &{mapping} = BuiltIn.Create_Dictionary PREFIX=${prefix} REPLICAS=${replicas_str}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${CREATE_PREFIX_SHARD_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Become_Module_Leader
- [Arguments] ${member_index} ${shard_name}
- [Documentation] TODO: more desctiptive comment than: Invoke become-module-leader rpc.
+Remove_Prefix_Shard
+ [Documentation] Remove prefix based shard.
+ [Arguments] ${member_index} ${prefix}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SHARD_NAME=${shard_name}
- ${text} = TemplatedRequests.Post_As_Xml_Templated ${BECOME_MODULE_LEADER_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary PREFIX=${prefix}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${REMOVE_PREFIX_SHARD_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Remove_Shard_Replica
+Become_Prefix_Leader
+ [Documentation] Given node ask to become a shard leader.
[Arguments] ${member_index} ${shard_name}
- [Documentation] TODO: more desctiptive comment than: Invoke remove-shard-replica rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SHARD_NAME=${shard_name}
- TemplatedRequests.Post_As_Xml_Templated ${REMOVE_SHARD_REPLICA_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary SHARD_NAME=${shard_name} ID=prefix-0
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${BECOME_PREFIX_LEADER_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Add_Shard_Replica
- [Arguments] ${member_index} ${shard_name}
- [Documentation] TODO: more desctiptive comment than: Invoke add-shard-replica rpc.
+Subscribe_Dtcl
+ [Documentation] Subscribe a listener for data changes. Invoke subscribe-dtcl rpc.
+ [Arguments] ${member_index}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SHARD_NAME=${shard_name}
- TemplatedRequests.Post_As_Xml_Templated ${ADD_SHARD_REPLICA_DIR} mapping=${mapping} session=${session}
+ TemplatedRequests.Post_As_Xml_Templated ${SUBSCRIBE_DTCL_DIR} session=${session}
-Deconfigure_Id_Ints_Shard
+Unsubscribe_Dtcl
+ [Documentation] Invoke unsubscribe-dtcl rpc, return copy-matches field as boolean.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke deconfigure-id-ints-shard rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${DECONFIGURE_ID_INTS_SHARD_DIR} base_name=location extension=uri
- TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated ${UNSUBSCRIBE_DTCL_DIR} session=${session}
+ BuiltIn.Run_Keyword_And_Return MdsalLowLevel__Parse_Matches ${text}
-Is_Client_Aborted
+Unsubscribe_Dtcl_No_Tx
+ [Documentation] Unsubscribe a listener from the data changes. Expect success no notifications received. Return boolean status.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke is-client-aborted rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${IS_CLIENT_ABORTED_SHARD_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${UNSUBSCRIBE_DTCL_DIR}
+ ... session=${session}
+ ... additional_allowed_status_codes=${INTERNAL_SERVER_ERROR}
+ BuiltIn.Run_Keyword_And_Return MdsalLowLevel__Parse_Maybe_No_Tx ${text}
-Subscribe_Dtcl
+Subscribe_Ddtl
+ [Documentation] Subscribe DOMDataTreeListener to listen for the data changes.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke subscribe-dtcl rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${SUBSCRIBE_DTCL_DIR} base_name=location extension=uri
- TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ TemplatedRequests.Post_As_Xml_Templated ${SUBSCRIBE_DDTL_DIR} session=${session}
-Unsubscribe_Dtcl
+Unsubscribe_Ddtl
+ [Documentation] Invoke unsubscribe-ddtl rpc, return copy-matches field as boolean.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unsubscribe-dtcl rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${UNSUBSCRIBE_DTCL_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated ${UNSUBSCRIBE_DDTL_DIR} session=${session}
+ BuiltIn.Run_Keyword_And_Return MdsalLowLevel__Parse_Matches ${text}
-Subscribe_Ddtl
+Unsubscribe_Ddtl_No_Tx
+ [Documentation] Unsubscribe a listener from the data changes. Expect success no notifications received. Return boolean status.
[Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke subscribe-ddtl rpc.
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${SUBSCRIBE_DDTL_DIR} base_name=location extension=uri
- TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${UNSUBSCRIBE_DDTL_DIR}
+ ... session=${session}
+ ... additional_allowed_status_codes=${INTERNAL_SERVER_ERROR}
+ BuiltIn.Run_Keyword_And_Return MdsalLowLevel__Parse_Maybe_No_Tx ${text}
-Unsubscribe_Ddtl
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unsubscribe-ddtl rpc.
+MdsalLowLevel__Parse_Matches
+ [Documentation] Interpret the \${text} as XML response to an unsubscribe call and return copy-matches as boolean.
+ [Arguments] ${text}
+ ${xml} = XML.Parse_Xml ${text}
+ ${matches} = XML.Get_Element_Text ${xml} xpath=copy-matches
+ ${matches} = BuiltIn.Convert_To_Boolean ${matches}
+ RETURN ${matches}
+
+MdsalLowLevel__Parse_Maybe_No_Tx
+ [Documentation] Attempt to parse the \${text} as successful unsubscribe. If that fails, extract the error message and expect no notifications.
+ [Arguments] ${text}
+ ${status} ${message} = BuiltIn.Run_Keyword_And_Ignore_Error MdsalLowLevel__Parse_Matches ${text}
+ IF "${status}" == "PASS" RETURN ${message}
+ ${xml} = XML.Parse_Xml ${text}
+ ${message} = XML.Get_Element_Text ${xml} xpath=error/error-message
+ ${status} ${message} = BuiltIn.Run_Keyword_And_Ignore_Error
+ ... BuiltIn.Should_Contain
+ ... ${message}
+ ... listener has not received
+ IF "${status}" == "PASS" RETURN ${TRUE}
+ RETURN ${FALSE}
+
+Start_Publish_Notifications
+ [Documentation] Start publishing notifications by invoking publish-notifications rpc.
+ [Arguments] ${member_index} ${gid} ${seconds} ${notif_per_sec}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${UNSUBSCRIBE_DDTL_DIR} base_name=location extension=uri
- ${text} = TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary ID=${gid} DURATION=${seconds} RATE=${notif_per_sec}
+ TemplatedRequests.Post_As_Xml_Templated
+ ... ${START_PUBLISH_NOTIFICATIONS_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Publish_Notifications
- [Arguments] ${member_index} ${seconds} ${notif_per_sec}
- [Documentation] TODO: more desctiptive comment than: Invoke publish-notifications rpc.
+Check_Publish_Notifications
+ [Documentation] Publishing notifications check by invoking check-publish-notifications rpc. Return publising process state details.
+ [Arguments] ${member_index} ${gid}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary SECONDS=${seconds} NPS=${notif_per_sec}
- TemplatedRequests.Post_As_Xml_Templated ${PUBLISH_NOTIFICATIONS_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary ID=${gid}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${CHECK_PUBLISH_NOTIFICATIONS_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
+ ${xml} = XML.Parse_Xml ${text}
+ ${active} = XML.Get_Element_Text ${xml} xpath=active
+ ${active} = BuiltIn.Convert_To_Boolean ${active}
+ ${status} ${publish_count} = BuiltIn.Run_Keyword_And_Ignore_Error
+ ... XML.Get_Element_Text
+ ... ${xml}
+ ... xpath=publish-count
+ IF """${status}""" == """FAIL""" and """${publish_count}""" != """No element matching 'publish-count' found."""
+ BuiltIn.Fail ${publish_count}
+ END
+ ${publish_count} = BuiltIn.Set_Variable_If """${status}""" == """FAIL""" ${EMPTY} ${publish_count}
+ ${status} ${last_error} = BuiltIn.Run_Keyword_And_Ignore_Error
+ ... XML.Get_Element_Text
+ ... ${xml}
+ ... xpath=last-error
+ IF """${status}""" == """FAIL""" and """${last_error}""" != """No element matching 'last-error' found."""
+ BuiltIn.Fail ${last_error}
+ END
+ ${last_error} = BuiltIn.Set_Variable_If """${status}""" == """FAIL""" ${EMPTY} ${last_error}
+ RETURN ${active} ${publish_count} ${last_error}
Subscribe_Ynl
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke subscribe-ynl rpc.
+ [Documentation] Subscribe listener for the notifications with identifier ${gid}.
+ [Arguments] ${member_index} ${gid}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary
+ &{mapping} = BuiltIn.Create_Dictionary ID=${gid}
TemplatedRequests.Post_As_Xml_Templated ${SUBSCRIBE_YNL_DIR} mapping=${mapping} session=${session}
Unsubscribe_Ynl
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unsubscribe-ynl rpc.
+ [Documentation] Unsubscribe listener for the ${gid} identifier. Return statistics of the publishing process.
+ [Arguments] ${member_index} ${gid}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary
- ${text} = TemplatedRequests.Post_As_Xml_Templated ${UNSUBSCRIBE_YNL_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary ID=${gid}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${UNSUBSCRIBE_YNL_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
+ ${xml} = XML.Parse_Xml ${text}
+ ${all_not} = XML.Get_Element_Text ${xml} xpath=all-not
+ ${id_not} = XML.Get_Element_Text ${xml} xpath=id-not
+ ${err_not} = XML.Get_Element_Text ${xml} xpath=err-not
+ ${local_number} = XML.Get_Element_Text ${xml} xpath=local-number
+ RETURN ${all_not} ${id_not} ${err_not} ${local_number}
Register_Bound_Constant
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke register-bound-constant rpc.
+ [Documentation] Invoke register-bound-constant rpc and register get-contexted-constant rpc. The argument ${context} is only the string part
+ ... of the whole instance identifier.
+ [Arguments] ${member_index} ${context} ${constant}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary
- ${text} = TemplatedRequests.Post_As_Xml_Templated ${REGISTER_BOUND_CONSTANT_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary CONTEXT=${context} CONSTANT=${constant}
+ ${text} = TemplatedRequests.Post_As_Xml_Templated
+ ... ${REGISTER_BOUND_CONSTANT_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
Unregister_Bound_Constant
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unregister-bound-constant rpc.
+ [Documentation] Invoke unregister-bound-constant rpc and unregister get-contexted-constant rpc. The argument ${context} is only the string part
+ ... of the whole instance identifier.
+ [Arguments] ${member_index} ${context}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary
- TemplatedRequests.Post_As_Xml_Templated ${UNREGISTER_BOUND_CONSTANT_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary CONTEXT=${context}
+ TemplatedRequests.Post_As_Xml_Templated
+ ... ${UNREGISTER_BOUND_CONSTANT_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Register_Default_Constant
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke register-default-constant rpc.
+Shutdown_Shard_Replica
+ [Documentation] Invoke shutdown-shard-replica rpc.
+ [Arguments] ${member_index} ${shard_name}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- &{mapping} BuiltIn.Create_Dictionary
- TemplatedRequests.Post_As_Xml_Templated ${REGISTER_DEFAULT_CONSTANT_DIR} mapping=${mapping} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary SHARD_NAME=${shard_name}
+ TemplatedRequests.Post_As_Xml_Templated
+ ... ${SHUTDOWN_SHARD_REPLICA_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
-Unregister_Default_Constant
- [Arguments] ${member_index}
- [Documentation] TODO: more desctiptive comment than: Invoke unregister-default-constant rpc.
+Shutdown_Prefix_Shard_Replica
+ [Documentation] Invoke shutdown-prefix-shard-replica rpc.
+ [Arguments] ${member_index} ${shard_prefix}
${session} = ClusterManagement.Resolve_Http_Session_For_Member member_index=${member_index}
- ${uri} = TemplatedRequests.Resolve_Text_From_Template_Folder folder=${UNREGISTER_DEFAULT_CONSTANT_DIR} base_name=location extension=uri
- TemplatedRequests.Post_To_Uri uri=${uri} data=${EMPTY} accept=${ACCEPT_JSON} content_type=${HEADERS_YANG_JSON} session=${session}
+ &{mapping} = BuiltIn.Create_Dictionary PREFIX=${shard_prefix}
+ TemplatedRequests.Post_As_Xml_Templated
+ ... ${SHUTDOWN_PREFIX_SHARD_REPLICA_DIR}
+ ... mapping=${mapping}
+ ... session=${session}
Code Review / integration / test.git / blobdiff