commit 35cb8d6537614dbd56396c47c35cbabd46a411ad
author Yao Chen <yaochen@google.com> Thu Jan 03 16:49:14 2019 -0800
committer Yao Chen <yaochen@google.com> Thu Jan 03 17:00:39 2019 -0800
tree b03999db3778236e07efd1ca58cc635349b27c38
parent 20a1afd998de4454ec930cf1ccf76ac9f2e661d7

Add a timeout option in shell subscriber.

Test: cts added
Change-Id: I0fe854fcfd5535ed03e502a4cad3f57079b45381

cmds/statsd/src/StatsService.cpp

diff --git a/cmds/statsd/src/StatsService.cpp b/cmds/statsd/src/StatsService.cpp
index f2a4663..3107b4d 100644
--- a/cmds/statsd/src/StatsService.cpp
+++ b/cmds/statsd/src/StatsService.cpp
@@ -360,7 +360,11 @@
             if (mShellSubscriber == nullptr) {
                 mShellSubscriber = new ShellSubscriber(mUidMap, mPullerManager);
             }
-            mShellSubscriber->startNewSubscription(in, out, resultReceiver);
+            int timeoutSec = -1;
+            if (argCount >= 2) {
+                timeoutSec = atoi(args[1].c_str());
+            }
+            mShellSubscriber->startNewSubscription(in, out, resultReceiver, timeoutSec);
             return NO_ERROR;
         }
     }