|
@@ -199,19 +199,19 @@ class MsgQTest(unittest.TestCase):
|
|
|
class Sock:
|
|
|
def __init__(self, fileno):
|
|
|
self.fileno = lambda: fileno
|
|
|
- self.__msgq.lnames["first"] = Sock(1)
|
|
|
- self.__msgq.lnames["second"] = Sock(2)
|
|
|
- self.__msgq.fd_to_lname[1] = "first"
|
|
|
- self.__msgq.fd_to_lname[2] = "second"
|
|
|
+ self.__msgq.lnames['first'] = Sock(1)
|
|
|
+ self.__msgq.lnames['second'] = Sock(2)
|
|
|
+ self.__msgq.fd_to_lname[1] = 'first'
|
|
|
+ self.__msgq.fd_to_lname[2] = 'second'
|
|
|
|
|
|
- self.__msgq.process_command_subscribe(self.__msgq.lnames["first"],
|
|
|
- {'group': "G1", 'instance': "*"},
|
|
|
+ self.__msgq.process_command_subscribe(self.__msgq.lnames['first'],
|
|
|
+ {'group': 'G1', 'instance': '*'},
|
|
|
None)
|
|
|
- self.__msgq.process_command_subscribe(self.__msgq.lnames["second"],
|
|
|
- {'group': "G1", 'instance': "*"},
|
|
|
+ self.__msgq.process_command_subscribe(self.__msgq.lnames['second'],
|
|
|
+ {'group': 'G1', 'instance': '*'},
|
|
|
None)
|
|
|
- self.__msgq.process_command_subscribe(self.__msgq.lnames["second"],
|
|
|
- {'group': "G2", 'instance': "*"},
|
|
|
+ self.__msgq.process_command_subscribe(self.__msgq.lnames['second'],
|
|
|
+ {'group': 'G2', 'instance': '*'},
|
|
|
None)
|
|
|
|
|
|
self.__msgq.running = True
|
|
@@ -228,16 +228,16 @@ class MsgQTest(unittest.TestCase):
|
|
|
|
|
|
json.dumps(result)
|
|
|
|
|
|
- self.assertEqual({'result': [0, ["second"]]},
|
|
|
+ self.assertEqual({'result': [0, ['second']]},
|
|
|
self.__msgq.command_handler('members',
|
|
|
- {'group': "G2"}))
|
|
|
+ {'group': 'G2'}))
|
|
|
check_both(self.__msgq.command_handler('members', {'group': 'G1'}))
|
|
|
|
|
|
-
|
|
|
+
|
|
|
|
|
|
self.assertEqual({'result': [0, []]},
|
|
|
self.__msgq.command_handler('members',
|
|
|
- {'group': "Empty"}))
|
|
|
+ {'group': 'Empty'}))
|
|
|
|
|
|
check_both(self.__msgq.command_handler('members', {}))
|
|
|
|