You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by yo...@apache.org on 2012/02/23 03:00:10 UTC
svn commit: r1292619 -
/lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java
Author: yonik
Date: Thu Feb 23 02:00:10 2012
New Revision: 1292619
URL: http://svn.apache.org/viewvc?rev=1292619&view=rev
Log:
logging: log versions
Modified:
lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java
Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java?rev=1292619&r1=1292618&r2=1292619&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/update/processor/LogUpdateProcessorFactory.java Thu Feb 23 02:00:10 2012
@@ -106,7 +106,10 @@ class LogUpdateProcessor extends UpdateR
}
if (adds.size() < maxNumToLog) {
- adds.add(cmd.getPrintableId());
+ long version = cmd.getVersion();
+ String msg = cmd.getPrintableId();
+ if (version != 0) msg = msg + " (" + version + ')';
+ adds.add(msg);
}
if (logDebug) { log.debug("add {}", cmd.getPrintableId()); }
@@ -123,11 +126,17 @@ class LogUpdateProcessor extends UpdateR
toLog.add("delete",deletes);
}
if (deletes.size() < maxNumToLog) {
- deletes.add(cmd.getId());
+ long version = cmd.getVersion();
+ String msg = cmd.getId();
+ if (version != 0) msg = msg + " (" + version + ')';
+ deletes.add(msg);
}
if (logDebug) { log.debug("delete {}", cmd.getId()); }
} else {
if (toLog.size() < maxNumToLog) {
+ long version = cmd.getVersion();
+ String msg = cmd.query;
+ if (version != 0) msg = msg + " (" + version + ')';
toLog.add("deleteByQuery", cmd.query);
}
if (logDebug) { log.debug("deleteByQuery {}", cmd.getQuery()); }