Code Review / integration / test.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Update StreamDict to include argon
[integration/test.git] / csit / libraries / NettyReplication.robot
diff --git a/csit/libraries/NettyReplication.robot b/csit/libraries/NettyReplication.robot
index a907b58832244ecaf1c42a4383724aee84db7f0e..a02dd4990e3dfc7ebc27c4ae0502dc64ddd6f926 100644 (file)
--- a/csit/libraries/NettyReplication.robot
+++ b/csit/libraries/NettyReplication.robot
@@ -1,55 +1,80 @@
 *** Settings ***
-Documentation     Netty replication library. This library can be used to setup and teardown netty replication connections.
-Resource          KarafKeywords.robot
-Resource          ClusterManagement.robot
+Documentation       Netty replication library. This library can be used to setup and teardown netty replication connections.
+
+Resource            KarafKeywords.robot
+Resource            ClusterManagement.robot
+
 
 *** Variables ***
-${DEFAULT_NETTY_SOURCE_NODE_INDEX}    ${1}
-@{DEFAULT_NETTY_SINK_NODE_INDEXES}    ${2}
+${DEFAULT_NETTY_SOURCE_NODE_INDEX}      ${1}
+@{DEFAULT_NETTY_SINK_NODE_INDEXES}      ${2}
+
 
 *** Keywords ***
 Setup_Netty_Replication
-    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}    ${sink_members_indexes}=${DEFAULT_NETTY_SINK_NODE_INDEXES}
     [Documentation]    Set up netty replication connections betwean source and sinks.
+    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}    ${sink_members_indexes}=${DEFAULT_NETTY_SINK_NODE_INDEXES}
     Open_Source_Connection    ${source_member_index}
     FOR    ${sink_member_index}    IN    @{sink_members_indexes}
         Open_Sink_Connection    ${sink_member_index}    source_member_index=${source_member_index}
     END
 
 Teardown_Netty_Replication
-    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}    ${sink_members_indexes}=${DEFAULT_NETTY_SINK_NODE_INDEXES}
     [Documentation]    Tear down netty replication connections betwean source and sinks.
+    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}    ${sink_members_indexes}=${DEFAULT_NETTY_SINK_NODE_INDEXES}
     Close_Source_Connection    ${source_member_index}
     FOR    ${sink_member_index}    IN    @{sink_members_indexes}
         Close_Sink_Connection    ${sink_member_index}
     END
 
 Open_Source_Connection
-    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
     [Documentation]    Open source part of netty replicate connection on specific node.
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:edit org.opendaylight.mdsal.replicate.netty.source    member_index=${source_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:property-set enabled true    member_index=${source_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:update    member_index=${source_member_index}
+    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:edit org.opendaylight.mdsal.replicate.netty.source
+    ...    member_index=${source_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:property-set enabled true
+    ...    member_index=${source_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:update
+    ...    member_index=${source_member_index}
 
 Close_Source_Connection
-    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
     [Documentation]    Close source part of netty replicate connection on specific node.
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:edit org.opendaylight.mdsal.replicate.netty.source    member_index=${source_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:property-set enabled false    member_index=${source_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:update    member_index=${source_member_index}
+    [Arguments]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:edit org.opendaylight.mdsal.replicate.netty.source
+    ...    member_index=${source_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:property-set enabled false
+    ...    member_index=${source_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:update
+    ...    member_index=${source_member_index}
 
 Open_Sink_Connection
-    [Arguments]    ${sink_member_index}=@{DEFAULT_NETTY_SINK_NODE_INDEXES}[0]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
     [Documentation]    Open sink part of netty replicate connection on specific node.
+    [Arguments]    ${sink_member_index}=@{DEFAULT_NETTY_SINK_NODE_INDEXES}[0]    ${source_member_index}=${DEFAULT_NETTY_SOURCE_NODE_INDEX}
     ${replicate_source_ip}=    ClusterManagement.Resolve_Ip_Address_For_Member    ${source_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:edit org.opendaylight.mdsal.replicate.netty.sink    member_index=${sink_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:property-set enabled true    member_index=${sink_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:property-set source-host ${replicate_source_ip}    member_index=${sink_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:edit org.opendaylight.mdsal.replicate.netty.sink
+    ...    member_index=${sink_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:property-set enabled true
+    ...    member_index=${sink_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:property-set source-host ${replicate_source_ip}
+    ...    member_index=${sink_member_index}
     KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:update    member_index=${sink_member_index}
 
 Close_Sink_Connection
-    [Arguments]    ${sink_member_index}=@{DEFAULT_NETTY_SINK_NODE_INDEXES}[0]
     [Documentation]    Close sink part of netty replicate connection on specific node.
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:edit org.opendaylight.mdsal.replicate.netty.sink    member_index=${sink_member_index}
-    KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:property-set enabled false    member_index=${sink_member_index}
+    [Arguments]    ${sink_member_index}=@{DEFAULT_NETTY_SINK_NODE_INDEXES}[0]
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:edit org.opendaylight.mdsal.replicate.netty.sink
+    ...    member_index=${sink_member_index}
+    KarafKeywords.Execute_Controller_Karaf_Command_On_Background
+    ...    config:property-set enabled false
+    ...    member_index=${sink_member_index}
     KarafKeywords.Execute_Controller_Karaf_Command_On_Background    config:update    member_index=${sink_member_index}
Integration test