1
0
Fork 0

fixed typo

This commit is contained in:
Jan Steemann 2015-09-03 13:55:07 +02:00
parent 030fbc17d8
commit ec61d921f6
2 changed files with 9 additions and 5 deletions

View File

@ -427,9 +427,12 @@ namespace triagens {
docs.reserve(batchSize);
}
TRI_ASSERT(batchSize > 0);
auto primaryIndex = document->primaryIndex();
while (count < batchSize) {
TRI_doc_mptr_t const* mptr = document->primaryIndex()->lookupSequential(internalSkip, total);
TRI_doc_mptr_t const* mptr = primaryIndex->lookupSequential(internalSkip, total);
if (mptr == nullptr) {
break;
}
@ -438,6 +441,7 @@ namespace triagens {
}
else {
docs.emplace_back(*mptr);
if (++count >= limit) {
break;
}

View File

@ -265,7 +265,7 @@ namespace triagens {
/// the second bucket at Position 2 (7 - Bucket1.size())
////////////////////////////////////////////////////////////////////////////////
Element* findElementSequentialBucktes (uint64_t position) const {
Element* findElementSequentialBuckets (uint64_t position) const {
for (auto& b : _buckets) {
if (position >= b._nrAlloc) {
position -= b._nrAlloc;
@ -754,7 +754,7 @@ namespace triagens {
Element* res = nullptr;
do {
res = findElementSequentialBucktes(position);
res = findElementSequentialBuckets(position);
position++;
}
while (position < total && res == nullptr);
@ -785,7 +785,7 @@ namespace triagens {
Element* res = nullptr;
do {
res = findElementSequentialBucktes(position);
res = findElementSequentialBuckets(position);
position--;
}
while (position > 0 && res == nullptr);
@ -835,7 +835,7 @@ namespace triagens {
// Find documents
Element* res = nullptr;
do {
res = findElementSequentialBucktes(position);
res = findElementSequentialBuckets(position);
position += step;
position = position % total;
}