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

removed useless variable

This commit is contained in:
jsteemann 2016-05-30 14:21:26 +02:00
parent e171675371
commit 7c5e210f0c
2 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
arangod/Scheduler/SchedulerThread.cpp
View File

@ -47,7 +47,6 @@ SchedulerThread::SchedulerThread(Scheduler* scheduler, EventLoop loop,
_scheduler(scheduler),
_defaultLoop(defaultLoop),
_loop(loop),
_hasWork(false),
_numberTasks(0),
_taskData(100) {}
@ -101,7 +100,6 @@ bool SchedulerThread::registerTask(Scheduler* scheduler, Task* task) {
MUTEX_LOCKER(mutexLocker, _queueLock);
_queue.push_back(w);
_hasWork = true;
scheduler->wakeupLoop(_loop);
@ -132,7 +130,6 @@ void SchedulerThread::unregisterTask(Task* task) {
MUTEX_LOCKER(mutexLocker, _queueLock);
_queue.push_back(w);
_hasWork = true;
_scheduler->wakeupLoop(_loop);
}
@ -164,7 +161,6 @@ void SchedulerThread::destroyTask(Task* task) {
MUTEX_LOCKER(mutexLocker, _queueLock);
_queue.push_back(w);
_hasWork = true;
_scheduler->wakeupLoop(_loop);
}
@ -229,7 +225,7 @@ void SchedulerThread::run() {
MUTEX_LOCKER(mutexLocker,
_queueLock); // TODO(fc) XXX goto boost lockfree
if (!_hasWork.load() || _queue.empty()) {
if (_queue.empty()) {
break;
}

6
arangod/Scheduler/SchedulerThread.h
View File

@ -139,12 +139,6 @@ class SchedulerThread : public Thread, private TaskManager {
std::deque<Work> _queue;
//////////////////////////////////////////////////////////////////////////////
/// @brief work indicator
//////////////////////////////////////////////////////////////////////////////
std::atomic<bool> _hasWork;
//////////////////////////////////////////////////////////////////////////////
/// @brief statistics
///