|
From: <go...@us...> - 2003-09-27 01:10:02
|
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 {
}
|