Index: jackrabbit-core/src/main/java/org/apache/jackrabbit/core/cluster/ClusterNode.java =================================================================== --- jackrabbit-core/src/main/java/org/apache/jackrabbit/core/cluster/ClusterNode.java (revision 1305275) +++ jackrabbit-core/src/main/java/org/apache/jackrabbit/core/cluster/ClusterNode.java (working copy) @@ -134,6 +134,11 @@ private AtomicInteger syncCount = new AtomicInteger(); /** + * Update counter, used in displaying the number of updates in audit log. + */ + private AtomicInteger updateCount = new AtomicInteger(); + + /** * Status flag, one of {@link #NONE}, {@link #STARTED} or {@link #STOPPED}. */ private int status; @@ -660,9 +665,13 @@ return; } try { - record.update(); + int updateSize = record.update(); setRevision(record.getRevision()); - log.debug("revision {} {}", record.getRevision(), path); + + updateCount.compareAndSet(Integer.MAX_VALUE, 0); + + log.debug("[{}] {} {} ({})", new Object[]{updateCount.incrementAndGet(), + record.getRevision(), path, updateSize}); } catch (JournalException e) { String msg = "Unable to commit log entry."; log.error(msg, e); Index: jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/AppendRecord.java =================================================================== --- jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/AppendRecord.java (revision 1305275) +++ jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/AppendRecord.java (working copy) @@ -253,11 +253,12 @@ /** * {@inheritDoc} */ - public void update() throws JournalException { + public int update() throws JournalException { boolean succeeded = false; + int length = 0; try { - int length = dataOut.size(); + length = dataOut.size(); closeOutput(); InputStream in = openInput(); @@ -278,6 +279,7 @@ journal.unlock(succeeded); } + return succeeded? length : 0; } /** Index: jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/ReadRecord.java =================================================================== --- jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/ReadRecord.java (revision 1305275) +++ jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/ReadRecord.java (working copy) @@ -271,7 +271,7 @@ throw unsupported(); } - public void update() throws JournalException { + public int update() throws JournalException { throw unsupported(); } Index: jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/Record.java =================================================================== --- jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/Record.java (revision 1305275) +++ jackrabbit-core/src/main/java/org/apache/jackrabbit/core/journal/Record.java (working copy) @@ -277,10 +277,11 @@ * Update the changes made to an appended record. This will also update * this record's revision. * + * @return The size of the update in bytes. * @throws JournalException if this record has not been appended, * or if another error occurs */ - void update() throws JournalException; + int update() throws JournalException; /** * Cancel the changes made to an appended record.