call graph filtering

dmelikyan · dmelikyan · commit b32bf14f5c80 · 2017-07-18T09:27:27.000+02:00
diff --git a/setup.py b/setup.py
@@ -2,7 +2,7 @@
 
 setup(
     name = 'stackimpact',
-    version = '1.0.3',
+    version = '1.0.4',
     description = 'StackImpact Python Agent',
     author = 'StackImpact',
     author_email = 'devops@stackimpact.com',
diff --git a/stackimpact/agent.py b/stackimpact/agent.py
@@ -26,7 +26,7 @@
 
 class Agent:
 
-    AGENT_VERSION = "1.0.3"
+    AGENT_VERSION = "1.0.4"
     SAAS_DASHBOARD_ADDRESS = "https://agent-api.stackimpact.com"
 
     def __init__(self, **kwargs):
diff --git a/stackimpact/reporters/allocation_reporter.py b/stackimpact/reporters/allocation_reporter.py
@@ -130,6 +130,7 @@ def report(self):
             return
 
         self.profile.normalize(self.profile_duration)
+        self.profile.filter(2, 1000, float("inf"))
 
         metric = Metric(self.agent, Metric.TYPE_PROFILE, Metric.CATEGORY_MEMORY_PROFILE, Metric.NAME_UNCOLLECTED_ALLOCATIONS, Metric.UNIT_BYTE)
         measurement = metric.create_measurement(Metric.TRIGGER_TIMER, self.profile.measurement, 1, self.profile)
diff --git a/stackimpact/reporters/block_reporter.py b/stackimpact/reporters/block_reporter.py
@@ -189,6 +189,7 @@ def report(self):
 
         with self.profile_lock:
             self.block_profile.normalize(self.profile_duration)
+            self.block_profile.filter(2, 1, float("inf"))
 
             metric = Metric(self.agent, Metric.TYPE_PROFILE, Metric.CATEGORY_BLOCK_PROFILE, Metric.NAME_BLOCKING_CALL_TIMES, Metric.UNIT_MILLISECOND)
             measurement = metric.create_measurement(Metric.TRIGGER_TIMER, self.block_profile.measurement, 1, self.block_profile)
@@ -197,6 +198,7 @@ def report(self):
             if self.block_profile.num_samples > 0 and self.http_profile.num_samples > 0:
                 self.http_profile.normalize(self.profile_duration)
                 self.http_profile.convert_to_percent(self.block_profile.measurement)
+                self.block_profile.filter(2, 1, 100)
 
                 metric = Metric(self.agent, Metric.TYPE_PROFILE, Metric.CATEGORY_HTTP_TRACE, Metric.NAME_HTTP_TRANSACTION_BREAKDOWN, Metric.UNIT_PERCENT)
                 measurement = metric.create_measurement(Metric.TRIGGER_TIMER, self.http_profile.measurement, None, self.http_profile)
diff --git a/stackimpact/reporters/cpu_reporter.py b/stackimpact/reporters/cpu_reporter.py
@@ -154,6 +154,8 @@ def report(self):
         with self.profile_lock:
             self.profile.evaluate_percent(self.profile_duration / self.SAMPLING_RATE)
 
+            self.profile.filter(2, 1, 100)
+
             metric = Metric(self.agent, Metric.TYPE_PROFILE, Metric.CATEGORY_CPU_PROFILE, Metric.NAME_MAIN_THREAD_CPU_USAGE, Metric.UNIT_PERCENT)
             measurement = metric.create_measurement(Metric.TRIGGER_TIMER, self.profile.measurement, None, self.profile)
             self.agent.message_queue.add('metric', metric.to_dict())
