com.serotonin.mango.rt.publish.persistent

Class SyncHandler

java.lang.Object

com.serotonin.mango.rt.publish.persistent.SyncHandler

All Implemented Interfaces:

java.lang.Runnable

class SyncHandler
extends java.lang.Object
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	SyncHandler.PointSync

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	cancelled
(package private) long	cutoff
(package private) static org.apache.commons.logging.Log	LOG
(package private) int	pointsCompleted
(package private) java.util.List<PublishedPointRT<PersistentPointVO>>	pointsToCheck
(package private) SyncHandler.PointSync[]	pointSyncs
(package private) PointValueDao	pointValueDao
(package private) int	recordsSynced
(package private) int	requestsSent
(package private) int	responseErrors
(package private) PersistentSendThread	sendThread
private static java.lang.String	START_TIMES_KEY
(package private) java.util.Map<java.lang.Integer,java.lang.Long>	startTimes
(package private) java.util.Set<java.lang.Integer>	targetOvercountPoints

Constructor Summary

Constructors

Constructor and Description
SyncHandler(PersistentSendThread sendThread)

Method Summary

Modifier and Type	Method and Description
(package private) void	cancel()
int	getPointsCompleted()
int	getRequestsSent()
(package private) void	responseReceived(Packet packet)
void	run()
(package private) void	sendRequest(int id, int requestId, int pointIndex, long from, long to)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

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

START_TIMES_KEY

private static final java.lang.String START_TIMES_KEY

See Also:

Constant Field Values

sendThread

final PersistentSendThread sendThread

pointValueDao

final PointValueDao pointValueDao

cutoff

long cutoff

recordsSynced

int recordsSynced

targetOvercountPoints

final java.util.Set<java.lang.Integer> targetOvercountPoints

responseErrors

int responseErrors

startTimes

java.util.Map<java.lang.Integer,java.lang.Long> startTimes

requestsSent

int requestsSent

pointsCompleted

int pointsCompleted

cancelled

volatile boolean cancelled

pointsToCheck

java.util.List<PublishedPointRT<PersistentPointVO>> pointsToCheck

pointSyncs

SyncHandler.PointSync[] pointSyncs

Constructor Detail

SyncHandler

SyncHandler(PersistentSendThread sendThread)

Method Detail

getPointsCompleted

public int getPointsCompleted()

getRequestsSent

public int getRequestsSent()

cancel

void cancel()

run

public void run()

Specified by:

run in interface java.lang.Runnable

responseReceived

void responseReceived(Packet packet)

sendRequest

void sendRequest(int id,
                 int requestId,
                 int pointIndex,
                 long from,
                 long to)