Loading cmds/statsd/src/shell/ShellSubscriber.cpp +1 −1 Original line number Original line Diff line number Diff line Loading @@ -41,7 +41,7 @@ void ShellSubscriber::startNewSubscription(int in, int out, int timeoutSec) { // critical-section // critical-section std::unique_lock<std::mutex> lock(mMutex); std::unique_lock<std::mutex> lock(mMutex); if (myToken < mToken) { if (myToken != mToken) { // Some other subscription has already come in. Stop. // Some other subscription has already come in. Stop. return; return; } } Loading cmds/statsd/src/shell/ShellSubscriber.h +1 −1 Original line number Original line Diff line number Diff line Loading @@ -108,7 +108,7 @@ private: std::shared_ptr<SubscriptionInfo> mSubscriptionInfo = nullptr; std::shared_ptr<SubscriptionInfo> mSubscriptionInfo = nullptr; int mToken; int mToken = 0; }; }; } // namespace statsd } // namespace statsd Loading Loading
cmds/statsd/src/shell/ShellSubscriber.cpp +1 −1 Original line number Original line Diff line number Diff line Loading @@ -41,7 +41,7 @@ void ShellSubscriber::startNewSubscription(int in, int out, int timeoutSec) { // critical-section // critical-section std::unique_lock<std::mutex> lock(mMutex); std::unique_lock<std::mutex> lock(mMutex); if (myToken < mToken) { if (myToken != mToken) { // Some other subscription has already come in. Stop. // Some other subscription has already come in. Stop. return; return; } } Loading
cmds/statsd/src/shell/ShellSubscriber.h +1 −1 Original line number Original line Diff line number Diff line Loading @@ -108,7 +108,7 @@ private: std::shared_ptr<SubscriptionInfo> mSubscriptionInfo = nullptr; std::shared_ptr<SubscriptionInfo> mSubscriptionInfo = nullptr; int mToken; int mToken = 0; }; }; } // namespace statsd } // namespace statsd Loading
