[Archive-crawler-cvs] ArchiveOpenCrawler/src/org/archive/util HttpRecorder.java,1.1,1.2

[<go...@us...>]

Update of /cvsroot/archive-crawler/ArchiveOpenCrawler/src/org/archive/util
In directory sc8-pr-cvs1:/tmp/cvs-serv4243/src/org/archive/util

Modified Files:
	HttpRecorder.java 
Log Message:
http byte-level recording (in progress)

Index: HttpRecorder.java
===================================================================
RCS file: /cvsroot/archive-crawler/ArchiveOpenCrawler/src/org/archive/util/HttpRecorder.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** HttpRecorder.java	24 Sep 2003 01:46:37 -0000	1.1
--- HttpRecorder.java	25 Sep 2003 00:14:03 -0000	1.2
***************
*** 7,13 ****
--- 7,17 ----
  package org.archive.util;
  
+ import java.io.IOException;
  import java.io.InputStream;
  import java.io.OutputStream;
  
+ import org.archive.crawler.io.RecordingInputStream;
+ import org.archive.crawler.io.RecordingOutputStream;
+ 
  /**
   * Initially only supports HTTP/1.0 (one request, one response per stream)
***************
*** 17,20 ****
--- 21,36 ----
   */
  public class HttpRecorder {
+ 	String backingFilenamePrefix;
+ 	RecordingInputStream ris;
+ 	RecordingOutputStream ros;
+ 	
+ 	/**
+ 	 * 
+ 	 */
+ 	public HttpRecorder(String backingFilenamePrefix) {
+ 		super();
+ 		ris = new RecordingInputStream(32768,backingFilenamePrefix+".ris",2^20);
+ 		ros = new RecordingOutputStream(2048,backingFilenamePrefix+".ros",2^12);
+ 	}
  
  	/**
***************
*** 22,27 ****
  	 * @return
  	 */
! 	public InputStream inputWrap(InputStream is) {
! 		return is;
  	}
  
--- 38,44 ----
  	 * @return
  	 */
! 	public InputStream inputWrap(InputStream is) throws IOException {
! 		ris.open(is);
! 		return ris;
  	}
  
***************
*** 30,35 ****
  	 * @return
  	 */
! 	public OutputStream outputWrap(OutputStream outputStream) {
! 		return outputStream;
  	}
  	
--- 47,53 ----
  	 * @return
  	 */
! 	public OutputStream outputWrap(OutputStream os) throws IOException {
! 		ros.open(os);
! 		return ros;
  	}