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

fix: add missing mutex

This commit is contained in:
Jan Christoph Uhde 2016-07-06 17:01:43 +02:00
parent 7996b2c152
commit d5a64253ec
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
arangod/V8Server/V8PeriodicTask.cpp
View File

@ -41,6 +41,7 @@ Mutex V8PeriodicTask::RUNNING_LOCK;
void V8PeriodicTask::jobDone(Task* task) { void V8PeriodicTask::jobDone(Task* task) {
try { try {
MUTEX_LOCKER(guard, V8PeriodicTask::RUNNING_LOCK);
RUNNING.erase(task); RUNNING.erase(task);
} catch (...) { } catch (...) {
// ignore any memory error // ignore any memory error
@ -48,7 +49,7 @@ void V8PeriodicTask::jobDone(Task* task) {
} }
V8PeriodicTask::V8PeriodicTask(std::string const& id, std::string const& name, V8PeriodicTask::V8PeriodicTask(std::string const& id, std::string const& name,
TRI_vocbase_t* vocbase, TRI_vocbase_t* vocbase,
double offset, double period, double offset, double period,
std::string const& command, std::string const& command,
std::shared_ptr<VPackBuilder> parameters, std::shared_ptr<VPackBuilder> parameters,
@ -87,7 +88,7 @@ bool V8PeriodicTask::handlePeriod() {
LOG(WARN) << "could not add task " << _command << ", no dispatcher known"; LOG(WARN) << "could not add task " << _command << ", no dispatcher known";
return false; return false;
} }
{ {
MUTEX_LOCKER(guard, V8PeriodicTask::RUNNING_LOCK); MUTEX_LOCKER(guard, V8PeriodicTask::RUNNING_LOCK);
@ -102,7 +103,7 @@ bool V8PeriodicTask::handlePeriod() {
std::unique_ptr<Job> job(new V8Job( std::unique_ptr<Job> job(new V8Job(
_vocbase, "(function (params) { " + _command + " } )(params);", _vocbase, "(function (params) { " + _command + " } )(params);",
_parameters, _allowUseDatabase, this)); _parameters, _allowUseDatabase, this));
DispatcherFeature::DISPATCHER->addJob(job, false); DispatcherFeature::DISPATCHER->addJob(job, false);
return true; return true;