1
0
Fork 0

fix count()

This commit is contained in:
jsteemann 2017-04-05 12:31:53 +02:00
parent ff38a5023f
commit 79fc5224cb
1 changed files with 3 additions and 2 deletions

View File

@ -37,6 +37,7 @@
#include "RocksDBEngine/RocksDBKey.h"
#include "RocksDBEngine/RocksDBPrimaryIndex.h"
#include "RocksDBEngine/RocksDBToken.h"
#include "RocksDBEngine/RocksDBTransactionCollection.h"
#include "RocksDBEngine/RocksDBTransactionState.h"
#include "RocksDBEngine/RocksDBValue.h"
#include "StorageEngine/EngineSelectorFeature.h"
@ -170,10 +171,10 @@ uint64_t RocksDBCollection::numberDocuments(transaction::Methods* trx) const {
RocksDBTransactionState* state =
static_cast<RocksDBTransactionState*>(trx->state());
auto trxCollection = state->findCollection(_logicalCollection->cid());
auto trxCollection = static_cast<RocksDBTransactionCollection*>(state->findCollection(_logicalCollection->cid()));
TRI_ASSERT(trxCollection != nullptr);
return _numberDocuments + state->numInserts() - state->numRemoves();
return _numberDocuments + trxCollection->numInserts() - trxCollection->numRemoves();
}
/// @brief report extra memory used by indexes etc.