commit 089f10fdc1b30f5e4551e3d83a69b93846071497
author Runhang Li <rli@twitter.com> Fri Jul 07 11:03:35 2017 -0700
committer Runhang Li <rli@twitter.com> Fri Jul 07 11:03:35 2017 -0700
tree 9f7dff8a18f8359d278fd7cce27b0567180e3bf2
parent f4cecfba380cb2b9e1fe2e21cc3092d885df600b

Compile.

heron/stmgr/src/cpp/manager/stmgr-server.cpp

diff --git a/heron/stmgr/src/cpp/manager/stmgr-server.cpp b/heron/stmgr/src/cpp/manager/stmgr-server.cpp
index 4bd6788..9251358 100644
--- a/heron/stmgr/src/cpp/manager/stmgr-server.cpp
+++ b/heron/stmgr/src/cpp/manager/stmgr-server.cpp
@@ -15,6 +15,8 @@
  */
 
 #include "manager/stmgr-server.h"
+#include <gperftools/malloc_extension.h>
+#include <gperftools/heap-checker.h>
 #include <iostream>
 #include <unordered_set>
 #include <vector>
@@ -497,7 +499,7 @@
   LOG(INFO) << "We observe back pressure on sending data to instance " << instance_name;
   StartBackPressureOnSpouts();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -532,7 +534,7 @@
   LOG(INFO) << "We don't observe back pressure now on sending data to instance " << instance_name;
   AttemptStopBackPressureFromSpouts();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -555,7 +557,7 @@
             << _other_stmgr_id;
   StartBackPressureOnSpouts();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -582,7 +584,7 @@
             << _other_stmgr_id;
   AttemptStopBackPressureFromSpouts();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -616,7 +618,7 @@
 
   __global_protobuf_pool_release__(_message);
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -653,7 +655,7 @@
 
   __global_protobuf_pool_release__(_message);
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -671,7 +673,7 @@
   LOG(INFO) << "End stat and check!";
   stmgr_->SendStartBackPressureToOtherStMgrs();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -689,7 +691,7 @@
             << "stream managers";
   stmgr_->SendStopBackPressureToOtherStMgrs();
   LOG(INFO) << "Starts stat and check!";
-  char buffer[4096];
+  memset(buffer, '\0', 4096);
   MallocExtension::instance()->GetStats(buffer, 4096);
   LOG(INFO) << buffer;
   HeapLeakChecker::NoGlobalLeaks();
@@ -714,7 +716,7 @@
     }
     back_pressure_metric_aggr_->Start();
     LOG(INFO) << "Starts stat and check!";
-    char buffer[4096];
+    memset(buffer, '\0', 4096);
     MallocExtension::instance()->GetStats(buffer, 4096);
     LOG(INFO) << buffer;
     HeapLeakChecker::NoGlobalLeaks();
@@ -742,7 +744,7 @@
     }
     back_pressure_metric_aggr_->Stop();
     LOG(INFO) << "Starts stat and check!";
-    char buffer[4096];
+    memset(buffer, '\0', 4096);
     MallocExtension::instance()->GetStats(buffer, 4096);
     LOG(INFO) << buffer;
     HeapLeakChecker::NoGlobalLeaks();