Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Count callbacks in _strand in HeartbeatThread and log.

This commit is contained in:
Max Neunhoeffer 2017-01-28 22:13:21 +01:00
parent 4e2a9be028
commit 429ffcd43c
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
arangod/Cluster/HeartbeatThread.cpp
View File

@ -73,7 +73,9 @@ HeartbeatThread::HeartbeatThread(AgencyCallbackRegistry* agencyCallbackRegistry,
_currentVersions(0, 0), _currentVersions(0, 0),
_desiredVersions(std::make_shared<AgencyVersions>(0, 0)), _desiredVersions(std::make_shared<AgencyVersions>(0, 0)),
_wasNotified(false), _wasNotified(false),
_strand(new boost::asio::io_service::strand(*ioService)) { _strand(new boost::asio::io_service::strand(*ioService)),
_callbacksPosted(0),
_callbacksExecuted(0) {
} }
@ -735,14 +737,19 @@ bool HeartbeatThread::syncDBServerStatusQuo() {
// only warn if the application server is still there and dispatching // only warn if the application server is still there and dispatching
// should succeed // should succeed
LOG_TOPIC(INFO, Logger::HEARTBEAT) << "dispatching sync"; LOG_TOPIC(INFO, Logger::HEARTBEAT) << "dispatching sync "
<< ++_callbacksPosted;
// schedule a job for the change // schedule a job for the change
auto self = shared_from_this(); auto self = shared_from_this();
_strand->post([self, this]() { _strand->post([self, this]() {
LOG_TOPIC(INFO, Logger::HEARTBEAT) << "sync callback started "
<< ++_callbacksExecuted;
DBServerAgencySync job(this); DBServerAgencySync job(this);
job.work(); job.work();
LOG_TOPIC(INFO, Logger::HEARTBEAT) << "sync callback ended "
<< _callbacksExecuted.load();
}); });
MUTEX_LOCKER(mutexLocker, *_statusLock); MUTEX_LOCKER(mutexLocker, *_statusLock);

2
arangod/Cluster/HeartbeatThread.h
View File

@ -226,6 +226,8 @@ class HeartbeatThread : public Thread,
bool _wasNotified; bool _wasNotified;
std::unique_ptr<boost::asio::io_service::strand> _strand; std::unique_ptr<boost::asio::io_service::strand> _strand;
std::atomic<uint64_t> _callbacksPosted;
std::atomic<uint64_t> _callbacksExecuted;
}; };
} }