Merge lp:~facundo/magicicada-gui/fix-mq-polling into lp:magicicada-gui

Proposed by Facundo Batista
Status: Merged
Approved by: Natalia Bidart
Approved revision: 29
Merged at revision: 32
Proposed branch: lp:~facundo/magicicada-gui/fix-mq-polling
Merge into: lp:magicicada-gui
Diff against target: 63 lines (+21/-7)
2 files modified
magicicada/syncdaemon.py (+1/-2)
magicicada/tests/test_syncdaemon.py (+20/-5)
To merge this branch: bzr merge lp:~facundo/magicicada-gui/fix-mq-polling
Reviewer Review Type Date Requested Status
Natalia Bidart Approve
Review via email: mp+26255@code.launchpad.net

Description of the change

Poll MQ even if not in QUEUE_MANAGER.

To post a comment you must log in.
Revision history for this message
Natalia Bidart (nataliabidart) wrote :

Yummy.

review: Approve

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
1=== modified file 'magicicada/syncdaemon.py'
2--- magicicada/syncdaemon.py 2010-05-27 12:45:13 +0000
3+++ magicicada/syncdaemon.py 2010-05-27 23:30:45 +0000
4@@ -198,8 +198,7 @@
5 def _check_mq(self):
6 """Check MQ if we should."""
7 state = self.current_state
8- if state.name != 'QUEUE_MANAGER' or \
9- state.queues not in ('WORKING_ON_METADATA', 'WORKING_ON_BOTH'):
10+ if state.queues not in ('WORKING_ON_METADATA', 'WORKING_ON_BOTH'):
11 logger.info("Check MQ called but States not in MQ")
12 else:
13 logger.info("Asking for MQ information")
14
15=== modified file 'magicicada/tests/test_syncdaemon.py'
16--- magicicada/tests/test_syncdaemon.py 2010-05-27 12:45:13 +0000
17+++ magicicada/tests/test_syncdaemon.py 2010-05-27 23:30:45 +0000
18@@ -269,8 +269,7 @@
19 def setUp(self):
20 """Set up."""
21 BaseTest.setUp(self)
22- self.sd.current_state._set(name='QUEUE_MANAGER',
23- queues='WORKING_ON_METADATA')
24+ self.sd.current_state._set(queues='WORKING_ON_METADATA')
25
26 @defer.inlineCallbacks
27 def test_initial_value(self):
28@@ -328,8 +327,24 @@
29 False, 'queues', 'connection')
30 self.assertTrue(called)
31
32- def test_mq_polling_workinginmetadata(self):
33- """Check that it polls mq while working in metadata."""
34+ def test_mq_polling_workinginmetadata_notinqueuemanager(self):
35+ """Check that it polls mq while working in metadata not being in QM."""
36+ # set the callback
37+ deferred = defer.Deferred()
38+ def fake():
39+ """Fake."""
40+ deferred.callback(True)
41+ return defer.succeed("foo")
42+ self.sd.dbus.get_meta_queue = fake
43+
44+ # send status changed to working in metadata
45+ self.sd.on_sd_status_changed('AUTHENTICATE', 'description', False,
46+ True, False, 'WORKING_ON_METADATA',
47+ 'connection')
48+ return deferred
49+
50+ def test_mq_polling_workinginmetadata_queuemanager(self):
51+ """Check that it polls mq while working in metadata being in QM."""
52 # set the callback
53 deferred = defer.Deferred()
54 def fake():
55@@ -450,7 +465,7 @@
56
57 def setUp(self):
58 """Set up the test."""
59- self.sd = SyncDaemon()
60+ self.sd = SyncDaemon(FakeDBusInterface)
61
62 self._replaced = None
63 self.called = False

Subscribers

People subscribed via source and target branches