Searched refs:myToken (Results 1 – 2 of 2) sorted by relevance
| /frameworks/base/cmds/statsd/src/shell/ |
| D | ShellSubscriber.cpp | 35 int myToken = claimToken(); in startNewSubscription() local
36 VLOG("ShellSubscriber: new subscription %d has come in", myToken); in startNewSubscription()
45 spawnHelperThread(myToken); in startNewSubscription()
46 waitForSubscriptionToEndLocked(mySubscriptionInfo, myToken, lock, timeoutSec); in startNewSubscription()
55 void ShellSubscriber::spawnHelperThread(int myToken) { in spawnHelperThread() argument
56 std::thread t([this, myToken] { pullAndSendHeartbeats(myToken); }); in spawnHelperThread()
61 int myToken, in waitForSubscriptionToEndLocked() argument
65 mSubscriptionShouldEnd.wait_for(lock, timeoutSec * 1s, [this, myToken, &myInfo] { in waitForSubscriptionToEndLocked()
66 return mToken != myToken || !myInfo->mClientAlive; in waitForSubscriptionToEndLocked()
69 mSubscriptionShouldEnd.wait(lock, [this, myToken, &myInfo] { in waitForSubscriptionToEndLocked()
[all …]
|
| D | ShellSubscriber.h | 102 void spawnHelperThread(int myToken);
105 int myToken,
113 void pullAndSendHeartbeats(int myToken);
|