1
0
Fork 0

removing debug warnings

This commit is contained in:
Kaveh Vahedipour 2016-08-05 14:41:24 +02:00
parent 770d8777a2
commit fcf96f42a7
2 changed files with 1 additions and 14 deletions

View File

@ -201,14 +201,10 @@ size_t State::removeConflicts (query_t const& transactions) {
idx = slice.get("index").getUInt();
pos = idx-_cur;
LOG(WARN) << __LINE__;
if (pos < _log.size()) {
if (idx == _log.at(pos).index && trm != _log.at(pos).term) {
LOG(WARN) << __LINE__;
LOG_TOPIC(DEBUG, Logger::AGENCY)
<< "Removing " << _log.size()-pos
<< " entries from log starting with " << idx << "=="
@ -219,38 +215,29 @@ size_t State::removeConflicts (query_t const& transactions) {
aql << "FOR l IN log FILTER l._key >= '" << stringify(idx)
<< "' REMOVE l IN log";
LOG(WARN) << __LINE__;
arangodb::aql::Query
query(false, _vocbase, aql.str().c_str(), aql.str().size(),
bindVars, nullptr, arangodb::aql::PART_MAIN);
LOG(WARN) << __LINE__;
auto queryResult = query.execute(_queryRegistry);
LOG(WARN) << __LINE__;
if (queryResult.code != TRI_ERROR_NO_ERROR) {
THROW_ARANGO_EXCEPTION_MESSAGE(
queryResult.code, queryResult.details);
}
LOG(WARN) << __LINE__;
queryResult.result->slice();
LOG(WARN) << __LINE__;
// volatile logs
{
MUTEX_LOCKER(mutexLocker, _logLock);
_log.erase(_log.begin()+pos, _log.end());
}
LOG(WARN) << __LINE__;
break;
} else {
LOG(WARN) << _log.at(pos);
LOG(WARN) << slice.toJson();
++ndups;
}
}

View File

@ -25,7 +25,7 @@ SFRE=2.5
COMP=1000
BASE=5001
#rm -rf agency
rm -rf agency
mkdir -p agency
echo -n "Starting agency ... "
if [ $NRAGENTS -gt 1 ]; then