com.serotonin.mango.rt.dataSource.persistent

Class PersistentDataSourceRT.ConnectionHandler

java.lang.Object

com.serotonin.mango.rt.dataSource.persistent.PersistentDataSourceRT.ConnectionHandler

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

PersistentDataSourceRT

class PersistentDataSourceRT.ConnectionHandler
extends java.lang.Object
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	PersistentDataSourceRT.ConnectionHandler.PacketInfo
(package private) class	PersistentDataSourceRT.ConnectionHandler.RangeCountHandler

Field Summary

Fields

Modifier and Type	Field and Description
private long	connectionTime
private java.io.InputStream	in
private java.util.List<java.lang.String>	indexedXids
private java.io.OutputStream	out
private long	packetsReceived
(package private) PointValueDao	pointValueDao
private java.net.Socket	socket
(package private) int	version
private com.serotonin.util.queue.ByteQueue	writeBuffer

Constructor Summary

Constructors

Constructor and Description
ConnectionHandler(java.net.Socket socket)

Method Summary

Modifier and Type	Method and Description
private void	ensurePoint(java.lang.String xid, byte[] serializedData)
long	getConnectionTime()
(package private) DataPointRT	getIndexedPoint(int index)
long	getPacketsReceived()
java.lang.String	getSocketAddress()
void	run()
private void	runImpl()
private void	sleepImpl()
private DataPointVO	unserialize(byte[] serializedData)
private void	updatePoint(DataPointVO oldDpvo, DataPointVO newDpvo)
private void	updatePointHierarchy(java.lang.String xid, java.util.List<java.lang.String> path)

Methods inherited from class java.lang.Object

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

Field Detail

socket

private final java.net.Socket socket

in

private java.io.InputStream in

out

private java.io.OutputStream out

version

int version

writeBuffer

private final com.serotonin.util.queue.ByteQueue writeBuffer

indexedXids

private final java.util.List<java.lang.String> indexedXids

pointValueDao

final PointValueDao pointValueDao

connectionTime

private final long connectionTime

packetsReceived

private long packetsReceived

Constructor Detail

ConnectionHandler

public ConnectionHandler(java.net.Socket socket)

Method Detail

getSocketAddress

public java.lang.String getSocketAddress()

getConnectionTime

public long getConnectionTime()

getPacketsReceived

public long getPacketsReceived()

run

public void run()

Specified by:

run in interface java.lang.Runnable

sleepImpl

private void sleepImpl()

runImpl

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

Throws:

java.io.IOException

PersistentProtocolException

PersistentAbortException

DoAbortException

unserialize

private DataPointVO unserialize(byte[] serializedData)
                         throws DoAbortException

Throws:

DoAbortException

ensurePoint

private void ensurePoint(java.lang.String xid,
                         byte[] serializedData)
                  throws DoAbortException

Throws:

DoAbortException

updatePoint

private void updatePoint(DataPointVO oldDpvo,
                         DataPointVO newDpvo)

updatePointHierarchy

private void updatePointHierarchy(java.lang.String xid,
                                  java.util.List<java.lang.String> path)

getIndexedPoint

DataPointRT getIndexedPoint(int index)