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

remove logging

This commit is contained in:
Simon Grätzer 2019-11-05 14:06:02 +01:00
parent 867233b293
commit 39f7a34c4a
No known key found for this signature in database
GPG Key ID: E4736AA091116E5C
2 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
arangod/Aql/SharedQueryState.cpp
View File

@ -64,18 +64,18 @@ void SharedQueryState::resetWakeupHandler() {
bool SharedQueryState::executeWakeupCallback() { bool SharedQueryState::executeWakeupCallback() {
TRI_ASSERT(_valid); TRI_ASSERT(_valid);
TRI_ASSERT(_wakeupCb); TRI_ASSERT(_wakeupCb);
if (_queuedWakeup) {
return false;
}
_queuedWakeup = true;
auto scheduler = SchedulerFeature::SCHEDULER; auto scheduler = SchedulerFeature::SCHEDULER;
if (ADB_UNLIKELY(scheduler == nullptr)) { if (ADB_UNLIKELY(scheduler == nullptr)) {
// We are shutting down // We are shutting down
return false; return false;
} }
TRI_ASSERT(_numWakeups > 0); TRI_ASSERT(_numWakeups > 0);
if (_queuedWakeup) {
return false;
}
_queuedWakeup = true;
return scheduler->queue(RequestLane::CLIENT_AQL, return scheduler->queue(RequestLane::CLIENT_AQL,
[self = shared_from_this(), [self = shared_from_this(),
cb = _wakeupCb] () mutable { cb = _wakeupCb] () mutable {

7
arangod/Aql/UnsortedGatherExecutor.cpp
View File

@ -81,7 +81,6 @@ std::pair<ExecutionState, NoStats> UnsortedGatherExecutor::produceRows(OutputAql
i = (_currentDependency + x) % _numberDependencies; i = (_currentDependency + x) % _numberDependencies;
if (_upstream[i] == ExecutionState::DONE) { if (_upstream[i] == ExecutionState::DONE) {
LOG_DEVEL << "dependency " << i << " done";
continue; continue;
} }
@ -98,12 +97,6 @@ std::pair<ExecutionState, NoStats> UnsortedGatherExecutor::produceRows(OutputAql
} }
} }
if (tmp > 0) {
LOG_DEVEL << "dependency " << i << " state " << state << " returned " << tmp;
} else {
LOG_DEVEL << "dependency " << i << " state " << state;
}
_upstream[i] = state; _upstream[i] = state;
if (state == ExecutionState::HASMORE) { if (state == ExecutionState::HASMORE) {
more = true; more = true;