From 88416a150a3566272b4312e484bb50220472bccc Mon Sep 17 00:00:00 2001
From: gojomo <gojomo@daa5b2f2-a927-0410-8b2d-f5f262fa301a>
Date: Tue, 14 Jun 2011 03:27:21 +0000
Subject: [PATCH] Tangent revealed by [HER-1898] eritrix 3.1 misses many pages
 that Heritrix 3.0 catches * Recorder     use intended basis for
 GenericReplayCharSequence in-memory-prefix * RecordingInputStream     reveal
 internal ROS buffer size

---
 .../main/java/org/archive/io/RecordingInputStream.java   | 9 +++++++++
 commons/src/main/java/org/archive/util/Recorder.java     | 2 +-
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/commons/src/main/java/org/archive/io/RecordingInputStream.java b/commons/src/main/java/org/archive/io/RecordingInputStream.java
index f28f3d27..8fea7f52 100644
--- a/commons/src/main/java/org/archive/io/RecordingInputStream.java
+++ b/commons/src/main/java/org/archive/io/RecordingInputStream.java
@@ -339,4 +339,13 @@ public class RecordingInputStream
     public void setLimits(long hardMax, long timeoutMs, long maxRateKBps) {
         recordingOutputStream.setLimits(hardMax, timeoutMs, maxRateKBps);
     }
+
+    /**
+     * Expose the amount of in-memory buffering used by the internal 
+     * recording stream. 
+     * @return int buffer size
+     */
+    public int getRecordedBufferLength() {
+        return recordingOutputStream.getBufferLength();
+    }
 }
diff --git a/commons/src/main/java/org/archive/util/Recorder.java b/commons/src/main/java/org/archive/util/Recorder.java
index 4f8a30de..96f197f9 100644
--- a/commons/src/main/java/org/archive/util/Recorder.java
+++ b/commons/src/main/java/org/archive/util/Recorder.java
@@ -382,7 +382,7 @@ public class Recorder {
         InputStream ris = getContentReplayInputStream();
         ReplayCharSequence rcs =  new GenericReplayCharSequence(
                 ris,
-                this.ros.getBufferLength()/2, 
+                this.getRecordedInput().getRecordedBufferLength()/2, 
                 this.backingFileBasename + RECORDING_OUTPUT_STREAM_SUFFIX,
                 requestedCharset);
         ris.close();