Merge pull request #21 from instana/multiprocessing_support

Add handle_fork function for eventual pid change detection

Author: pglombardo

instana/meter.py

@@ -134,7 +134,7 @@ def process(self):
             ss = None
             cm = self.collect_metrics()
 
-            if self.snapshot_countdown == 0:
+            if self.snapshot_countdown < 1:
                 self.snapshot_countdown = self.SNAPSHOT_PERIOD
                 ss = self.collect_snapshot()
                 md = copy.deepcopy(cm).delta_data(None)

instana/sensor.py

@@ -31,3 +31,7 @@ def configure_service_name(self):
 
         if len(self.service_name) == 0:
             self.service_name = os.path.basename(__file__)
+
+    def handle_fork(self):
+        self.agent = a.Agent(self)
+        self.meter = m.Meter(self)

instana/tracer.py

@@ -85,6 +85,10 @@ def extract(self, format, carrier):
         else:
             raise ot.UnsupportedFormatException()
 
+    def handle_fork(self):
+        self.sensor.handle_fork()
+        self.recorder = r.InstanaRecorder(self.sensor)
+
 
 def init(options):
     ot.tracer = InstanaTracer(options)