diff --git a/arangod/Agency/Agent.cpp b/arangod/Agency/Agent.cpp index ea59449342..770f1f7b92 100644 --- a/arangod/Agency/Agent.cpp +++ b/arangod/Agency/Agent.cpp @@ -138,7 +138,6 @@ bool Agent::waitFor (index_t index, double timeout) { // Wait until woken up through AgentCallback while (true) { - std::cout << _last_commit_index << std::endl; /// success? if (_last_commit_index >= index) { return true; @@ -337,11 +336,11 @@ write_ret_t Agent::write (query_t const& query) { MUTEX_LOCKER(mutexLocker, _ioLock); applied = _spearhead.apply(query); // Apply to spearhead indices = _state.log (query, applied, term(), id()); // Log w/ indicies - if (!indices.empty()) { - maxind = *std::max_element(indices.begin(), indices.end()); - } - _cv.signal(); // Wake up run } + if (!indices.empty()) { + maxind = *std::max_element(indices.begin(), indices.end()); + } + _cv.signal(); // Wake up run reportIn(id(),maxind); diff --git a/arangod/Agency/Agent.h b/arangod/Agency/Agent.h index 0e14afdd3f..3731f9f9c4 100644 --- a/arangod/Agency/Agent.h +++ b/arangod/Agency/Agent.h @@ -159,8 +159,6 @@ public: std::atomic _last_commit_index; /**< @brief Last commit index */ - arangodb::Mutex _uncommitedLock; /**< @brief */ - Store _spearhead; /**< @brief Spearhead key value store */ Store _read_db; /**< @brief Read key value store */