From 32c09015a16ef8dee535d2c81825a2590f7f15e7 Mon Sep 17 00:00:00 2001
From: Mykola Golub <mgolub@mirantis.com>
Date: Sun, 24 Apr 2016 19:39:40 +0300
Subject: [PATCH] qa/workunits/rbd: test mirror status in pool directory

Signed-off-by: Mykola Golub <mgolub@mirantis.com>
(cherry picked from commit f15cd51a1ddbd4079a8218bc2446a4bf68f95107)
---
 qa/workunits/rbd/rbd_mirror.sh | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/qa/workunits/rbd/rbd_mirror.sh b/qa/workunits/rbd/rbd_mirror.sh
index 4d3c806a7c867..ba144075ddd79 100755
--- a/qa/workunits/rbd/rbd_mirror.sh
+++ b/qa/workunits/rbd/rbd_mirror.sh
@@ -199,8 +199,15 @@ status()
 	rbd --cluster ${cluster} -p ${POOL} ls
 	echo
 
+	echo "${cluster} ${POOL} mirror pool status"
+	rbd --cluster ${cluster} -p ${POOL} mirror pool status --verbose
+	echo
+
 	for image in `rbd --cluster ${cluster} -p ${POOL} ls 2>/dev/null`
 	do
+	    echo "image ${image} info"
+	    rbd --cluster ${cluster} -p ${POOL} info ${image}
+	    echo
 	    echo "image ${image} journal status"
 	    rbd --cluster ${cluster} -p ${POOL} journal status --image ${image}
 	    echo
@@ -373,6 +380,20 @@ wait_for_replay_complete()
     return 1
 }
 
+test_status_in_pool_dir()
+{
+    local cluster=$1
+    local image=$2
+    local state_pattern=$3
+    local description_pattern=$4
+
+    local status_log=${TEMPDIR}/${cluster}-${image}.mirror_status
+    rbd --cluster ${cluster} -p ${POOL} mirror image status ${image} |
+	tee ${status_log}
+    grep "state: .*${state_pattern}" ${status_log}
+    grep "description: .*${description_pattern}" ${status_log}
+}
+
 create_image()
 {
     local cluster=$1
@@ -451,6 +472,8 @@ create_image ${CLUSTER2} ${image}
 wait_for_image_replay_started ${CLUSTER1_DAEMON} ${image}
 write_image ${CLUSTER2} ${image} 100
 wait_for_replay_complete ${CLUSTER1_DAEMON} ${CLUSTER2} ${image}
+test_status_in_pool_dir ${CLUSTER1} ${image} 'up+replaying' 'master_position'
+test_status_in_pool_dir ${CLUSTER2} ${image} 'down+unknown'
 compare_images ${image}
 
 echo "TEST: stop mirror, add image, start mirror and test replay"
@@ -461,11 +484,14 @@ write_image ${CLUSTER2} ${image1} 100
 start_mirror ${CLUSTER1_DAEMON} ${CLUSTER1}
 wait_for_image_replay_started ${CLUSTER1_DAEMON} ${image1}
 wait_for_replay_complete ${CLUSTER1_DAEMON} ${CLUSTER2} ${image1}
+test_status_in_pool_dir ${CLUSTER1} ${image1} 'up+replaying' 'master_position'
+test_status_in_pool_dir ${CLUSTER2} ${image1} 'down+unknown'
 compare_images ${image1}
 
 echo "TEST: test the first image is replaying after restart"
 write_image ${CLUSTER2} ${image} 100
 wait_for_replay_complete ${CLUSTER1_DAEMON} ${CLUSTER2} ${image}
+test_status_in_pool_dir ${CLUSTER1} ${image} 'up+replaying' 'master_position'
 compare_images ${image}
 
 echo "TEST: failover and failback"
@@ -474,19 +500,26 @@ start_mirror ${CLUSTER2_DAEMON} ${CLUSTER2}
 # failover
 demote_image ${CLUSTER2} ${image}
 wait_for_image_replay_stopped ${CLUSTER1_DAEMON} ${image}
+test_status_in_pool_dir ${CLUSTER1} ${image} 'up+stopped'
+test_status_in_pool_dir ${CLUSTER2} ${image} 'up+stopped'
 promote_image ${CLUSTER1} ${image}
 wait_for_image_replay_started ${CLUSTER2_DAEMON} ${image}
 write_image ${CLUSTER1} ${image} 100
 wait_for_replay_complete ${CLUSTER2_DAEMON} ${CLUSTER1} ${image}
+test_status_in_pool_dir ${CLUSTER1} ${image} 'up+stopped'
+test_status_in_pool_dir ${CLUSTER2} ${image} 'up+replaying' 'master_position'
 compare_images ${image}
 
 # failback
 demote_image ${CLUSTER1} ${image}
 wait_for_image_replay_stopped ${CLUSTER2_DAEMON} ${image}
+test_status_in_pool_dir ${CLUSTER2} ${image} 'up+stopped'
 promote_image ${CLUSTER2} ${image}
 wait_for_image_replay_started ${CLUSTER1_DAEMON} ${image}
 write_image ${CLUSTER2} ${image} 100
 wait_for_replay_complete ${CLUSTER1_DAEMON} ${CLUSTER2} ${image}
+test_status_in_pool_dir ${CLUSTER1} ${image} 'up+replaying' 'master_position'
+test_status_in_pool_dir ${CLUSTER2} ${image} 'up+stopped'
 compare_images ${image}
 
 echo OK