adding missing vars to resolver

Author: timvaillancourt

mongodb_consistent_backup/Oplog/Resolver/Resolver.py

@@ -35,8 +35,11 @@ def __init__(self, manager, config, timer, base_dir, backup_dir, tailed_oplogs,
         self.resolver_summary      = {}
         self.resolver_state        = {}
 
-        self._pool   = None
-        self._pooled = []
+        self.running   = False
+        self.stopped   = False
+        self.completed = False
+        self._pool     = None
+        self._pooled   = []
         try:
             self._pool = Pool(processes=self.threads(None, 2))
         except Exception, e:
@@ -80,6 +83,7 @@ def wait(self):
     def run(self):
         logging.info("Resolving oplogs (options: threads=%s, compression=%s)" % (self.threads(), self.compression()))
         self.timer.start(self.timer_name)
+        self.running = True
 
         for shard in self.backup_oplogs:
             backup_oplog = self.backup_oplogs[shard]
@@ -111,6 +115,8 @@ def run(self):
             else:
                 logging.info("No tailed oplog for host %s" % uri)
         self.wait()
+        self.running   = False
+        self.stopped   = True
         self.completed = True
 
         self.timer.stop(self.timer_name)