com.serotonin.mango.rt.publish.persistent

Class PersistentSendThread

java.lang.Object

java.lang.Thread

com.serotonin.mango.rt.publish.SendThread

com.serotonin.mango.rt.publish.persistent.PersistentSendThread

All Implemented Interfaces:

com.serotonin.util.ILifecycle, java.lang.Runnable

class PersistentSendThread
extends SendThread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	PersistentSendThread.PointHierarchySync
(package private) class	PersistentSendThread.SyncTimer

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	connecting
(package private) java.io.InputStream	in
private long	lastTestPacket
(package private) static org.apache.commons.logging.Log	LOG
(package private) java.io.OutputStream	out
(package private) java.util.List<Packet>	packetsToSend
(package private) PersistentSendThread.PointHierarchySync	pointHierarchySync
(package private) PersistentSenderRT	publisher
(package private) java.net.Socket	socket
(package private) SyncHandler	syncHandler
(package private) PersistentSendThread.SyncTimer	syncTimer
(package private) int	version
(package private) com.serotonin.util.queue.ByteQueue	writeBuffer

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
PersistentSendThread(PersistentSenderRT publisher)

Method Summary

Modifier and Type	Method and Description
private void	closeConnection(int sleep)
(package private) void	endSyncHandler()
int	getConnectingIndex()
private void	getPointResponse()
void	initialize()
boolean	isConnected()
private void	openConnection()
protected void	runImpl()
private void	send(PublishQueueEntry<PersistentPointVO> entry)
(package private) void	sendPacket(Packet packet)
(package private) boolean	startSync()
void	terminate()
(package private) void	writePointHierarchy()
(package private) void	writePointHierarchy(PointHierarchy hierarchy)

Methods inherited from class com.serotonin.mango.rt.publish.SendThread

isRunning, joinTermination, run, waitImpl

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

static final org.apache.commons.logging.Log LOG

publisher

final PersistentSenderRT publisher

socket

java.net.Socket socket

connecting

int connecting

in

java.io.InputStream in

out

java.io.OutputStream out

writeBuffer

com.serotonin.util.queue.ByteQueue writeBuffer

version

int version

syncTimer

PersistentSendThread.SyncTimer syncTimer

syncHandler

SyncHandler syncHandler

pointHierarchySync

PersistentSendThread.PointHierarchySync pointHierarchySync

packetsToSend

final java.util.List<Packet> packetsToSend

lastTestPacket

private long lastTestPacket

Constructor Detail

PersistentSendThread

public PersistentSendThread(PersistentSenderRT publisher)

Method Detail

isConnected

public boolean isConnected()

getConnectingIndex

public int getConnectingIndex()

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class SendThread

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class SendThread

runImpl

protected void runImpl()

Specified by:

runImpl in class SendThread

sendPacket

void sendPacket(Packet packet)

send

private void send(PublishQueueEntry<PersistentPointVO> entry)
           throws java.io.IOException

Throws:

java.io.IOException

openConnection

private void openConnection()
                     throws java.io.IOException,
                            PersistentProtocolException,
                            PersistentAbortException

Throws:

java.io.IOException

PersistentProtocolException

PersistentAbortException

getPointResponse

private void getPointResponse()
                       throws java.io.IOException,
                              PersistentAbortException,
                              PersistentProtocolException

Throws:

java.io.IOException

PersistentAbortException

PersistentProtocolException

closeConnection

private void closeConnection(int sleep)

startSync

boolean startSync()

endSyncHandler

void endSyncHandler()

writePointHierarchy

void writePointHierarchy()

writePointHierarchy

void writePointHierarchy(PointHierarchy hierarchy)