[Archive-crawler-cvs] ArchiveOpenCrawler/src/org/archive/util FencedInputStream.java,NONE,1.1 ARCReader.java,NONE,1.1 ARCResource.java,NONE,1.1

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

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

Added Files:
	FencedInputStream.java ARCReader.java ARCResource.java 
Log Message:
skeletal first ARCReading work

--- NEW FILE: FencedInputStream.java ---
/*
 * FencedInputStream.java
 * Created on Sep 26, 2003
 *
 * $Header: /cvsroot/archive-crawler/ArchiveOpenCrawler/src/org/archive/util/FencedInputStream.java,v 1.1 2003/09/27 00:48:12 gojomo Exp $
 */
package org.archive.util;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

/**
 * @author gojomo
 *
 */
public class FencedInputStream extends FilterInputStream {
	long maxToRead;
	long position = 0;
	
	/**
	 * @param in
	 */
	protected FencedInputStream(InputStream in, long maxToRead) {
		super(in);
		this.maxToRead = maxToRead;
	}

	/* (non-Javadoc)
	 * @see java.io.InputStream#read()
	 */
	public int read() throws IOException {
		if (position < maxToRead) {
			int b = super.read();
			if (b>=0) {
				position++;
			}
			return b;
		} else {
			return -1; // virtual EOF
		}
	}

	/* (non-Javadoc)
	 * @see java.io.InputStream#read(byte[], int, int)
	 */
	public int read(byte[] b, int off, int len) throws IOException {
		// TODO Auto-generated method stub
		return super.read(b, off, len);
	}

	/* (non-Javadoc)
	 * @see java.io.InputStream#read(byte[])
	 */
	public int read(byte[] b) throws IOException {
		// TODO Auto-generated method stub
		return super.read(b);
	}

}

--- NEW FILE: ARCReader.java ---
/*
 * ARCReader.java
 * Created on Sep 26, 2003
 *
 * $Header: /cvsroot/archive-crawler/ArchiveOpenCrawler/src/org/archive/util/ARCReader.java,v 1.1 2003/09/27 00:48:12 gojomo Exp $
 */
package org.archive.util;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.zip.GZIPInputStream;

/**
 * Utility class for reading ARC files, including .arc.gz
 * files. 
 * 
 * @author gojomo
 *
 */
public class ARCReader {
	protected InputStream inStream;
	protected FileInputStream arcStream;
	protected ARCResource lastResource;
	
	/**
	 * 
	 */
	public ARCReader() {
		super();
	}

	public void open(String filename) throws IOException {
		String flattenedFilename = filename.toLowerCase();
		assert flattenedFilename.endsWith(".arc") || flattenedFilename.endsWith(".arc.gz") : "non-arc filename extension";
		arcStream = new FileInputStream(filename);
		inStream = new BufferedInputStream(arcStream,4096);
	    if (flattenedFilename.endsWith(".gz")) {
	    	inStream = new GZIPInputStream(inStream);
	    }
	}
	
	public ARCResource getNextResource() {
		return null;
	}
}

--- NEW FILE: ARCResource.java ---
/*
 * ARCResource.java
 * Created on Sep 26, 2003
 *
 * $Header: /cvsroot/archive-crawler/ArchiveOpenCrawler/src/org/archive/util/ARCResource.java,v 1.1 2003/09/27 00:48:12 gojomo Exp $
 */
package org.archive.util;

/**
 * @author gojomo
 *
 */
public class ARCResource {

}