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()); }