public class LogFileFeeder extends StoppableThread
Modifier and Type | Field and Description |
---|---|
(package private) java.security.MessageDigest |
messageDigest |
(package private) static int |
TRANSFER_BYTES |
envImpl
Constructor and Description |
---|
LogFileFeeder(FeederManager feederManager,
java.nio.channels.SocketChannel channel) |
Modifier and Type | Method and Description |
---|---|
protected java.util.logging.Logger |
getLogger() |
(package private) static java.security.MessageDigest |
getSHA1Digest(java.io.File file,
long length)
Returns the SHA1 has associated with the file.
|
protected int |
initiateSoftShutdown()
Threads that use shutdownThread() must define this method.
|
void |
run()
The main driver loop that enforces the protocol message sequence and
implements it.
|
void |
shutdown() |
cleanup, getSavedShutdownException, getTotalCpuTime, getTotalUserTime, isShutdown, saveShutdownException, setExceptionListener, shutdownDone, shutdownThread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
static final int TRANSFER_BYTES
final java.security.MessageDigest messageDigest
public LogFileFeeder(FeederManager feederManager, java.nio.channels.SocketChannel channel) throws DatabaseException
DatabaseException
public void shutdown()
protected int initiateSoftShutdown()
StoppableThread
initiateSoftShutdown
in class StoppableThread
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
static java.security.MessageDigest getSHA1Digest(java.io.File file, long length) throws java.io.IOException, DatabaseException
file
- length
- java.io.IOException
DatabaseException
protected java.util.logging.Logger getLogger()
getLogger
in class StoppableThread
StoppableThread.getLogger()
Copyright (c) 2004-2012 Oracle. All rights reserved.