org.archive.format.gzip.zipnum

Class ZipNumBlockLoader

java.lang.Object

org.archive.format.gzip.zipnum.ZipNumBlockLoader

public class ZipNumBlockLoader
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	bufferFully
protected int	connectTimeoutMS
protected java.lang.String	cookie
protected java.util.Map<java.lang.String,SeekableLineReaderFactory>	fileFactoryMap
protected HTTPSeekableLineReaderFactory	httpFactory
protected java.lang.String	httpLib
protected int	maxHostConnections
protected int	maxTotalConnections
protected boolean	noKeepAlive
protected int	numRetries
protected int	readTimeoutMS
protected int	signDurationSecs
protected HMACSigner	signer
protected boolean	staleChecking
protected boolean	useNio

Constructor Summary

Constructors

Constructor and Description
ZipNumBlockLoader()

Method Summary

Modifier and Type	Method and Description
SeekableLineReader	attemptLoadBlock(java.lang.String location, long startOffset, int totalLength, boolean decompress, boolean isRequired)
void	close()
static void	closeAllReaders()
void	closeFileFactory(java.lang.String filename)
SeekableLineReader	createBlockReader(java.lang.String uri)
int	getConnectTimeoutMS()
java.lang.String	getCookie()
protected SeekableLineReader	getFileReader(java.lang.String filename)
java.lang.String	getHttpLib()
protected HTTPSeekableLineReader	getHttpReader(java.lang.String url)
int	getMaxHostConnections()
int	getMaxTotalConnections()
int	getNumRetries()
int	getReadTimeoutMS()
int	getSignDurationSecs()
HMACSigner	getSigner()
boolean	isBufferFully()
boolean	isNoKeepAlive()
boolean	isStaleChecking()
boolean	isUseNio()
void	setBufferFully(boolean bufferFully)
void	setConnectTimeoutMS(int connectTimeoutMS)
void	setCookie(java.lang.String cookie)
void	setHttpLib(java.lang.String httpLib)
void	setMaxHostConnections(int maxHostConnections)
void	setMaxTotalConnections(int maxTotalConnections)
void	setNoKeepAlive(boolean noKeepAlive)
void	setNumRetries(int numRetries)
void	setReadTimeoutMS(int readTimeoutMS)
void	setSignDurationSecs(int signDurationSecs)
void	setSigner(HMACSigner signer)
void	setStaleChecking(boolean staleChecking)
void	setUseNio(boolean useNio)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

fileFactoryMap

protected java.util.Map<java.lang.String,SeekableLineReaderFactory> fileFactoryMap

httpFactory

protected HTTPSeekableLineReaderFactory httpFactory

signer

protected HMACSigner signer

signDurationSecs

protected int signDurationSecs

useNio

protected boolean useNio

httpLib

protected java.lang.String httpLib

bufferFully

protected boolean bufferFully

noKeepAlive

protected boolean noKeepAlive

cookie

protected java.lang.String cookie

maxHostConnections

protected int maxHostConnections

maxTotalConnections

protected int maxTotalConnections

connectTimeoutMS

protected int connectTimeoutMS

readTimeoutMS

protected int readTimeoutMS

numRetries

protected int numRetries

staleChecking

protected boolean staleChecking

Constructor Detail

ZipNumBlockLoader

public ZipNumBlockLoader()

Method Detail

closeAllReaders

public static void closeAllReaders()

createBlockReader

public SeekableLineReader createBlockReader(java.lang.String uri)
                                     throws java.io.IOException

Throws:

java.io.IOException

getHttpReader

protected HTTPSeekableLineReader getHttpReader(java.lang.String url)
                                        throws java.io.IOException

Throws:

java.io.IOException

getFileReader

protected SeekableLineReader getFileReader(java.lang.String filename)
                                    throws java.io.IOException

Throws:

java.io.IOException

attemptLoadBlock

public SeekableLineReader attemptLoadBlock(java.lang.String location,
                                           long startOffset,
                                           int totalLength,
                                           boolean decompress,
                                           boolean isRequired)

closeFileFactory

public void closeFileFactory(java.lang.String filename)
                      throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

isUseNio

public boolean isUseNio()

setUseNio

public void setUseNio(boolean useNio)

isBufferFully

public boolean isBufferFully()

setBufferFully

public void setBufferFully(boolean bufferFully)

isNoKeepAlive

public boolean isNoKeepAlive()

setNoKeepAlive

public void setNoKeepAlive(boolean noKeepAlive)

getMaxHostConnections

public int getMaxHostConnections()

setMaxHostConnections

public void setMaxHostConnections(int maxHostConnections)

getMaxTotalConnections

public int getMaxTotalConnections()

setMaxTotalConnections

public void setMaxTotalConnections(int maxTotalConnections)

getConnectTimeoutMS

public int getConnectTimeoutMS()

setConnectTimeoutMS

public void setConnectTimeoutMS(int connectTimeoutMS)

getReadTimeoutMS

public int getReadTimeoutMS()

setReadTimeoutMS

public void setReadTimeoutMS(int readTimeoutMS)

getNumRetries

public int getNumRetries()

setNumRetries

public void setNumRetries(int numRetries)

setStaleChecking

public void setStaleChecking(boolean staleChecking)

isStaleChecking

public boolean isStaleChecking()

getHttpLib

public java.lang.String getHttpLib()

setHttpLib

public void setHttpLib(java.lang.String httpLib)

getCookie

public java.lang.String getCookie()

setCookie

public void setCookie(java.lang.String cookie)

getSigner

public HMACSigner getSigner()

setSigner

public void setSigner(HMACSigner signer)

getSignDurationSecs

public int getSignDurationSecs()

setSignDurationSecs

public void setSignDurationSecs(int signDurationSecs)