com.serotonin.mango.rt.publish.persistent

Class SyncHandler.PointSync

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SyncHandler

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

Field Summary

Fields

Modifier and Type	Field and Description
private int	id
private int	nextRequestId
(package private) boolean	pointUpdated
private long	responseCount
private int	responseId

Constructor Summary

Constructors

Constructor and Description
PointSync(int id)

Method Summary

Modifier and Type	Method and Description
(package private) void	checkPoint(PersistentPointVO point, long to)
(package private) void	checkRangeImpl(PersistentPointVO point, long from, long to) The recursive method that synchronizes range counts on both sides of the connection.
(package private) void	responseReceived(int responseId, long responseCount)
void	run()
private void	updatePointStartTime(PersistentPointVO point, long time)

Methods inherited from class java.lang.Object

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

Field Detail

id

private final int id

nextRequestId

private int nextRequestId

responseId

private volatile int responseId

responseCount

private volatile long responseCount

pointUpdated

boolean pointUpdated

Constructor Detail

PointSync

public PointSync(int id)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

checkPoint

void checkPoint(PersistentPointVO point,
                long to)

checkRangeImpl

void checkRangeImpl(PersistentPointVO point,
                    long from,
                    long to)

The recursive method that synchronizes range counts on both sides of the connection.

updatePointStartTime

private void updatePointStartTime(PersistentPointVO point,
                                  long time)

responseReceived

void responseReceived(int responseId,
                      long responseCount)