1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Copyright (C) 2017-2019 Red Hat, Inc. <http://www.redhat.com>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License along
# with this program; if not, write to the Free Software Foundation, Inc.,
# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
from random import choice
from time import sleep
from glusto.core import Glusto as g
from glustolibs.gluster.exceptions import ExecutionError
from glustolibs.gluster.gluster_base_class import GlusterBaseClass, runs_on
from glustolibs.gluster.volume_ops import set_volume_options
from glustolibs.gluster.gluster_init import start_glusterd, stop_glusterd
from glustolibs.gluster.profile_ops import profile_start, profile_stop
@runs_on([['distributed', 'replicated', 'dispersed',
'distributed-replicated', 'distributed-dispersed'], ['glusterfs']])
class TestProfileStartWithQuorumNotMet(GlusterBaseClass):
def setUp(self):
# calling GlusterBaseClass setUp
GlusterBaseClass.setUp.im_func(self)
# Creating Volume
g.log.info("Started creating volume")
ret = self.setup_volume()
if not ret:
raise ExecutionError("Volume creation failed: %s" % self.volname)
g.log.info("Volme created successfully : %s", self.volname)
def tearDown(self):
# Setting Quorum ratio to 51%
self.quorum_perecent = {'cluster.server-quorum-ratio': '51%'}
ret = set_volume_options(self.mnode, 'all', self.quorum_perecent)
if not ret:
raise ExecutionError("gluster volume set all cluster."
"server-quorum-ratio percentage "
"Failed :%s" % self.servers)
g.log.info("gluster volume set all cluster.server-quorum-ratio 51 "
"percentage enabled successfully on :%s", self.servers)
# stopping the volume and Cleaning up the volume
ret = self.cleanup_volume()
if not ret:
raise ExecutionError("Failed Cleanup the Volume %s" % self.volname)
g.log.info("Volume deleted successfully : %s", self.volname)
# Calling GlusterBaseClass tearDown
GlusterBaseClass.tearDown.im_func(self)
def test_profile_start_with_quorum_not_met(self):
# pylint: disable=too-many-statements
"""
1. Create a volume
2. Set the quorum type to server and ratio to 90
3. Stop glusterd randomly on one of the node
4. Start profile on the volume
5. Start glusterd on the node where it is stopped
6. Start profile on the volume
7. Stop profile on the volume where it is started
"""
# Enabling server quorum
self.quorum_options = {'cluster.server-quorum-type': 'server'}
ret = set_volume_options(self.mnode, self.volname, self.quorum_options)
self.assertTrue(ret, "gluster volume set %s cluster.server-quorum-type"
" server Failed" % self.volname)
g.log.info("gluster volume set %s cluster.server-quorum-type server "
"enabled successfully", self.volname)
# Setting Quorum ratio to 90%
self.quorum_perecent = {'cluster.server-quorum-ratio': '90%'}
ret = set_volume_options(self.mnode, 'all', self.quorum_perecent)
self.assertTrue(ret, "gluster volume set all cluster.server-quorum-rat"
"io percentage Failed :%s" % self.servers)
g.log.info("gluster volume set all cluster.server-quorum-ratio 90 "
"percentage enabled successfully on :%s", self.servers)
# Stop glusterd on one of the node randomly
self.node_on_glusterd_to_stop = choice(self.servers)
ret = stop_glusterd(self.node_on_glusterd_to_stop)
self.assertTrue(ret, "glusterd stop on the node failed")
g.log.info("glusterd stop on the node: % "
"succeeded", self.node_on_glusterd_to_stop)
# checking whether peers are connected or not
count = 0
while count < 5:
ret = self.validate_peers_are_connected()
if not ret:
break
sleep(2)
count += 1
self.assertFalse(ret, "Peers are in connected state even after "
"stopping glusterd on one node")
# Starting volume profile when quorum is not met
self.new_servers = self.servers[:]
self.new_servers.remove(self.node_on_glusterd_to_stop)
ret, _, _ = profile_start(choice(self.new_servers),
self.volname)
self.assertNotEqual(ret, 0, "Expected: Should not be able to start "
"volume profile. Acutal: Able to start "
"the volume profile start")
g.log.info("gluster vol profile start is failed as expected")
# Start glusterd on the node where it is stopped
ret = start_glusterd(self.node_on_glusterd_to_stop)
self.assertTrue(ret, "glusterd start on the node failed")
g.log.info("glusterd start succeeded")
# checking whether peers are connected or not
count = 0
while count < 5:
ret = self.validate_peers_are_connected()
if ret:
break
sleep(5)
count += 1
self.assertTrue(ret, "Peer are not in connected state ")
# Starting profile when volume quorum is met
ret, _, _ = profile_start(self.mnode, self.volname)
self.assertEqual(ret, 0, "Expected: Should be able to start the"
"volume profile start. Acutal: Not able"
" to start the volume profile start")
g.log.info("gluster vol profile start is successful")
# Stop the profile
ret, _, _ = profile_stop(self.mnode, self.volname)
self.assertEqual(ret, 0, "Expected: Should be able to stop the "
"profile stop. Acutal: Not able to stop"
" the profile stop")
g.log.info("gluster volume profile stop is successful")
|
