tza/openauto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Experimental: Allow higher ping/pong diff

Browse Source
This commit is contained in:
hawkeyexp 2019-01-29 19:38:11 +01:00
parent 5b9ebd7bd4
commit 1020069646
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/autoapp/Service/Pinger.cpp
View File

@ -17,6 +17,7 @@
*/ */
#include <f1x/openauto/autoapp/Service/Pinger.hpp> #include <f1x/openauto/autoapp/Service/Pinger.hpp>
#include <f1x/openauto/Common/Log.hpp>
namespace f1x namespace f1x
{ {
@ -50,6 +51,7 @@ void Pinger::ping(Promise::Pointer promise)
else else
{ {
++pingsCount_; ++pingsCount_;
OPENAUTO_LOG(info) << "[Pinger] Ping counter: " << pingsCount_;
promise_ = std::move(promise); promise_ = std::move(promise);
timer_.expires_from_now(boost::posix_time::milliseconds(duration_)); timer_.expires_from_now(boost::posix_time::milliseconds(duration_));
@ -62,6 +64,7 @@ void Pinger::pong()
{ {
strand_.dispatch([this, self = this->shared_from_this()]() { strand_.dispatch([this, self = this->shared_from_this()]() {
++pongsCount_; ++pongsCount_;
OPENAUTO_LOG(info) << "[Pinger] Pong counter: " << pongsCount_;
}); });
} }
@ -75,7 +78,7 @@ void Pinger::onTimerExceeded(const boost::system::error_code& error)
{ {
promise_->reject(aasdk::error::Error(aasdk::error::ErrorCode::OPERATION_ABORTED)); promise_->reject(aasdk::error::Error(aasdk::error::ErrorCode::OPERATION_ABORTED));
} }
else if(pingsCount_ - pongsCount_ > 1) else if(pingsCount_ - pongsCount_ > 4)
{ {
promise_->reject(aasdk::error::Error()); promise_->reject(aasdk::error::Error());
} }