1
0
Fork 0

micro improvements (#6674)

This commit is contained in:
Jan 2018-10-05 10:25:13 +02:00 committed by GitHub
parent 647949e556
commit 46efcff7d7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 10 additions and 19 deletions

View File

@ -113,10 +113,10 @@ AqlItemBlock::AqlItemBlock(ResourceMonitor* resourceMonitor, VPackSlice const sl
};
int64_t runLength = 0;
size_t tablePos = 0;
RunType runType = NoRun;
try {
size_t tablePos = 0;
// skip the first two records
rawIterator.next();
rawIterator.next();

View File

@ -777,7 +777,6 @@ class LimitNode : public ExecutionNode {
friend class ExecutionBlock;
friend class LimitBlock;
/// @brief constructors for various arguments, always with offset and limit
public:
LimitNode(ExecutionPlan* plan, size_t id, size_t offset, size_t limit)
: ExecutionNode(plan, id),
@ -785,9 +784,6 @@ class LimitNode : public ExecutionNode {
_limit(limit),
_fullCount(false) {}
LimitNode(ExecutionPlan* plan, size_t id, size_t limit)
: LimitNode(plan, id, 0, limit) {}
LimitNode(ExecutionPlan*, arangodb::velocypack::Slice const& base);
/// @brief return the type of the node
@ -824,15 +820,9 @@ class LimitNode : public ExecutionNode {
/// @brief return the offset value
size_t offset() const { return _offset; }
/// @brief set the offset value
void setOffset(size_t offset) { _offset = offset; }
/// @brief return the limit value
size_t limit() const { return _limit; }
/// @brief set the limit value
void setLimit(size_t limit) { _limit = limit; }
private:
/// @brief the offset
size_t _offset;

View File

@ -79,13 +79,12 @@ namespace arangodb {
class HeartbeatBackgroundJobThread : public Thread {
public:
HeartbeatBackgroundJobThread(HeartbeatThread *heartbeatThread) :
Thread("Maintenance"),
_heartbeatThread(heartbeatThread),
_stop(false),
_sleeping(false),
_backgroundJobsLaunched(0)
{}
explicit HeartbeatBackgroundJobThread(HeartbeatThread* heartbeatThread)
: Thread("Maintenance"),
_heartbeatThread(heartbeatThread),
_stop(false),
_sleeping(false),
_backgroundJobsLaunched(0) {}
~HeartbeatBackgroundJobThread() { shutdown(); }

View File

@ -2127,7 +2127,6 @@ void RestReplicationHandler::handleCommandAddFollower() {
TRI_ASSERT(checksumSlice.isString() && readLockIdSlice.isString());
const std::string readLockId = readLockIdSlice.copyString();
const std::string checksum = checksumSlice.copyString();
std::string referenceChecksum;
{

View File

@ -877,6 +877,9 @@ function processQuery (query, explain) {
return bracketize(node, node.subNodes.map(function (sub) { return buildExpression(sub); }).join(' && '));
}
return '';
case 'parameter':
case 'datasource parameter':
return value('@' + node.name);
default:
return 'unhandled node type (' + node.type + ')';
}