diff --git a/agkyra/syncer/localfs_client.py b/agkyra/syncer/localfs_client.py index 4e70eedfa3f1d9e7e15eda821103fa4e7a04ef8d..37711ae6b6ec2f79ac06ebfe7b42a1669df0e063 100644 --- a/agkyra/syncer/localfs_client.py +++ b/agkyra/syncer/localfs_client.py @@ -553,7 +553,9 @@ class LocalfsFileClient(FileClient): def check_enabled(self): if not self.settings.localfs_is_enabled(): msg = messaging.LocalfsSyncDisabled(logger=logger) - self.settings.messager.put(msg) + else: + msg = messaging.LocalfsSyncEnabled(logger=logger) + self.settings.messager.put(msg) def remove_candidates(self, objnames, ident): with self.probe_candidates.lock() as d: diff --git a/agkyra/syncer/messaging.py b/agkyra/syncer/messaging.py index 6e4220d06934899b77a95246379a5bc3c562d5cb..516d6a8901c61559fdf36cb5d25d0c76104605ad 100644 --- a/agkyra/syncer/messaging.py +++ b/agkyra/syncer/messaging.py @@ -179,3 +179,15 @@ class PithosSyncDisabled(Message): def __init__(self, *args, **kwargs): Message.__init__(self, *args, **kwargs) self.logger.warning("Pithos sync is disabled") + + +class LocalfsSyncEnabled(Message): + def __init__(self, *args, **kwargs): + Message.__init__(self, *args, **kwargs) + self.logger.info("Localfs sync is enabled") + + +class PithosSyncEnabled(Message): + def __init__(self, *args, **kwargs): + Message.__init__(self, *args, **kwargs) + self.logger.info("Pithos sync is enabled") diff --git a/agkyra/syncer/pithos_client.py b/agkyra/syncer/pithos_client.py index 5b06d0622b7bca3e6c941e081cf71bea1bd03307..0f18296f31fe8fafc85e17035454ffac8163331f 100644 --- a/agkyra/syncer/pithos_client.py +++ b/agkyra/syncer/pithos_client.py @@ -288,7 +288,9 @@ class PithosFileClient(FileClient): def check_enabled(self): if not self.settings.pithos_is_enabled(): msg = messaging.PithosSyncDisabled(logger=logger) - self.settings.messager.put(msg) + else: + msg = messaging.PithosSyncEnabled(logger=logger) + self.settings.messager.put(msg) def remove_candidates(self, objnames, ident): with self.probe_candidates.lock() as d: diff --git a/test.py b/test.py index 2d8be6d4755a0f13d25afde572b069ed10064027..7a088951be502904f4e531463c4687707894690e 100644 --- a/test.py +++ b/test.py @@ -104,6 +104,10 @@ class AgkyraTest(unittest.TestCase): cls.pithos = cls.master.endpoint cls.pithos.create_container(cls.ID) cls.db = cls.s.get_db() + m = cls.s.get_next_message(block=True) + assert isinstance(m, messaging.PithosSyncEnabled) + m = cls.s.get_next_message(block=True) + assert isinstance(m, messaging.LocalfsSyncEnabled) def assert_message(self, mtype): m = self.s.get_next_message(block=True)