Commit 9e6a4d3c authored by Vincent Pelletier's avatar Vincent Pelletier

Refuse all neoctl requests when not connected to a primary master.

parent 9077cfcd
...@@ -23,11 +23,17 @@ from neo.lib.protocol import Packets, Errors ...@@ -23,11 +23,17 @@ from neo.lib.protocol import Packets, Errors
from neo.lib.exception import PrimaryFailure from neo.lib.exception import PrimaryFailure
from neo.lib.util import dump from neo.lib.util import dump
def check_primary_master(func):
def wrapper(self, *args, **kw):
if self.app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary master.')
return func(self, *args, **kw)
return wrapper
def forward_ask(klass): def forward_ask(klass):
@check_primary_master
def wrapper(self, conn, *args, **kw): def wrapper(self, conn, *args, **kw):
app = self.app app = self.app
if app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary master.')
msg_id = app.master_conn.ask(klass(*args, **kw)) msg_id = app.master_conn.ask(klass(*args, **kw))
app.dispatcher.register(msg_id, conn, {'msg_id': conn.getPeerId()}) app.dispatcher.register(msg_id, conn, {'msg_id': conn.getPeerId()})
return wrapper return wrapper
...@@ -41,15 +47,13 @@ def forward_answer(klass): ...@@ -41,15 +47,13 @@ def forward_answer(klass):
class AdminEventHandler(EventHandler): class AdminEventHandler(EventHandler):
"""This class deals with events for administrating cluster.""" """This class deals with events for administrating cluster."""
@check_primary_master
def askPartitionList(self, conn, min_offset, max_offset, uuid): def askPartitionList(self, conn, min_offset, max_offset, uuid):
neo.lib.logging.info("ask partition list from %s to %s for %s" % neo.lib.logging.info("ask partition list from %s to %s for %s" %
(min_offset, max_offset, dump(uuid))) (min_offset, max_offset, dump(uuid)))
app = self.app app = self.app
# check we have one pt otherwise ask it to PMN # check we have one pt otherwise ask it to PMN
if app.pt is None: if app.pt is None:
if self.app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary ' \
'master.')
msg_id = self.app.master_conn.ask(Packets.AskPartitionTable()) msg_id = self.app.master_conn.ask(Packets.AskPartitionTable())
app.dispatcher.register(msg_id, conn, app.dispatcher.register(msg_id, conn,
{'min_offset' : min_offset, {'min_offset' : min_offset,
...@@ -60,6 +64,7 @@ class AdminEventHandler(EventHandler): ...@@ -60,6 +64,7 @@ class AdminEventHandler(EventHandler):
app.sendPartitionTable(conn, min_offset, max_offset, uuid) app.sendPartitionTable(conn, min_offset, max_offset, uuid)
@check_primary_master
def askNodeList(self, conn, node_type): def askNodeList(self, conn, node_type):
if node_type is None: if node_type is None:
node_type = 'all' node_type = 'all'
...@@ -72,6 +77,7 @@ class AdminEventHandler(EventHandler): ...@@ -72,6 +77,7 @@ class AdminEventHandler(EventHandler):
p = Packets.AnswerNodeList(node_information_list) p = Packets.AnswerNodeList(node_information_list)
conn.answer(p) conn.answer(p)
@check_primary_master
def setNodeState(self, conn, uuid, state, modify_partition_table): def setNodeState(self, conn, uuid, state, modify_partition_table):
neo.lib.logging.info("set node state for %s-%s" %(dump(uuid), state)) neo.lib.logging.info("set node state for %s-%s" %(dump(uuid), state))
node = self.app.nm.getByUUID(uuid) node = self.app.nm.getByUUID(uuid)
...@@ -83,17 +89,13 @@ class AdminEventHandler(EventHandler): ...@@ -83,17 +89,13 @@ class AdminEventHandler(EventHandler):
conn.answer(p) conn.answer(p)
return return
# forward to primary master node # forward to primary master node
if self.app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary master.')
p = Packets.SetNodeState(uuid, state, modify_partition_table) p = Packets.SetNodeState(uuid, state, modify_partition_table)
msg_id = self.app.master_conn.ask(p) msg_id = self.app.master_conn.ask(p)
self.app.dispatcher.register(msg_id, conn, {'msg_id' : conn.getPeerId()}) self.app.dispatcher.register(msg_id, conn, {'msg_id' : conn.getPeerId()})
@check_primary_master
def askClusterState(self, conn): def askClusterState(self, conn):
if self.app.cluster_state is None: if self.app.cluster_state is None:
if self.app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary ' \
'master.')
# required it from PMN first # required it from PMN first
msg_id = self.app.master_conn.ask(Packets.AskClusterState()) msg_id = self.app.master_conn.ask(Packets.AskClusterState())
self.app.dispatcher.register(msg_id, conn, self.app.dispatcher.register(msg_id, conn,
...@@ -101,9 +103,8 @@ class AdminEventHandler(EventHandler): ...@@ -101,9 +103,8 @@ class AdminEventHandler(EventHandler):
else: else:
conn.answer(Packets.AnswerClusterState(self.app.cluster_state)) conn.answer(Packets.AnswerClusterState(self.app.cluster_state))
@check_primary_master
def askPrimary(self, conn): def askPrimary(self, conn):
if self.app.master_conn is None:
raise protocol.NotReadyError('Not connected to a primary master.')
master_node = self.app.master_node master_node = self.app.master_node
conn.answer(Packets.AnswerPrimary(master_node.getUUID(), [])) conn.answer(Packets.AnswerPrimary(master_node.getUUID(), []))
......
...@@ -505,7 +505,10 @@ class NEOCluster(object): ...@@ -505,7 +505,10 @@ class NEOCluster(object):
def expectAllMasters(self, node_count, state=None, *args, **kw): def expectAllMasters(self, node_count, state=None, *args, **kw):
def callback(last_try): def callback(last_try):
current_try = len(self.getMasterList(state=state)) try:
current_try = len(self.getMasterList(state=state))
except NotReadyException:
current_try = 0
if last_try is not None and current_try < last_try: if last_try is not None and current_try < last_try:
raise AssertionError, 'Regression: %s became %s' % \ raise AssertionError, 'Regression: %s became %s' % \
(last_try, current_try) (last_try, current_try)
...@@ -516,7 +519,10 @@ class NEOCluster(object): ...@@ -516,7 +519,10 @@ class NEOCluster(object):
if not isinstance(state, (tuple, list)): if not isinstance(state, (tuple, list)):
state = (state, ) state = (state, )
def callback(last_try): def callback(last_try):
current_try = self.__getNodeState(node_type, uuid) try:
current_try = self.__getNodeState(node_type, uuid)
except NotReadyException:
current_try = None
return current_try in state, current_try return current_try in state, current_try
self.expectCondition(callback, *args, **kw) self.expectCondition(callback, *args, **kw)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment