[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [ooni-probe/master] Add some debugging logs to the refresh deck list
commit a3700b5eabd923886f0e6951784196bdc451caaa
Author: Arturo Filastò <arturo@xxxxxxxxxxx>
Date: Tue Sep 13 17:20:34 2016 +0200
Add some debugging logs to the refresh deck list
---
ooni/agent/scheduler.py | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/ooni/agent/scheduler.py b/ooni/agent/scheduler.py
index d6fbc31..2797fba 100644
--- a/ooni/agent/scheduler.py
+++ b/ooni/agent/scheduler.py
@@ -278,6 +278,7 @@ class RefreshDeckList(ScheduledTask):
def task(self):
self.scheduler.refresh_deck_list()
+
class SendHeartBeat(ScheduledTask):
"""
This task is used to send a heartbeat that the probe is still alive and
@@ -345,6 +346,7 @@ class SchedulerService(service.MultiService):
# If we are not initialized we should not enable anything
if not config.is_initialized():
+ log.msg("We are not initialized skipping setup of decks")
to_enable = []
for scheduled_task in self._scheduled_tasks[:]:
@@ -355,13 +357,16 @@ class SchedulerService(service.MultiService):
if info in to_enable:
# If the task is already scheduled there is no need to
# enable it.
+ log.msg("The deck {0} is already scheduled".format(deck_id))
to_enable.remove(info)
else:
# If one of the tasks that is scheduled is no longer in the
# scheduled tasks. We should disable it.
+ log.msg("The deck task {0} should be disabled".format(deck_id))
self.unschedule(scheduled_task)
for deck_id, schedule in to_enable:
+ log.msg("Scheduling to run {0}".format(deck_id))
self.schedule(RunDeck(self.director, deck_id, schedule))
def _task_did_not_run(self, failure, task):
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits