# connect to the existing socket to see if there is an existing
# msgq running. Only if that fails do we remove the file and
# attempt to create a new socket.
- self._existing = True
+ existing_msgq = True
try:
self._session = isc.cc.Session(self.socket_file)
except isc.cc.session.SessionError:
- self._existing = False
+ existing_msgq = False
self._session.close()
self._session = None
- if self._existing:
+ if existing_msgq:
logger.fatal(MSGQ_ALREADY_RUNNING)
- raise MsgQRunningError("Message Queue daemon already running")
+ raise MsgQRunningError("b10-msgq already running")
os.remove(self.socket_file)
# <topsrcdir>/tools/reorder_message_file.py to make sure the
# messages are in the correct order.
-% MSGQ_ALREADY_RUNNING Another copy of the message queue daemon is already running.
-Only a single instance of the message queue daemon should ever be run at one
-time. This instance will now terminate.
+% MSGQ_ALREADY_RUNNING Another copy of b10-msgq is already running.
+Only a single instance of b10-msgq should ever be run at one time.
+This instance will now terminate.
% MSGQ_CFGMGR_SUBSCRIBED The config manager subscribed to message queue
This is a debug message. The message queue has little bit of special handling
Check to make sure that an attempt to start a second copy of the MsgQ
daemon fails.
"""
+
+ self.assertTrue (os.path.exists(SOCKET_PATH))
self.__retcode = subprocess.call([MSGQ_PATH, '-s', SOCKET_PATH])
self.assertNotEqual(self.__retcode, 0)
+ # Verify that the socket still exists
+ self.assertTrue (os.path.exists(SOCKET_PATH))
+
if __name__ == '__main__':
isc.log.init("msgq-tests")
isc.log.resetUnitTestRootLogger()