io.github.robolib.nettable

Class NTWriteManager

java.lang.Object

io.github.robolib.nettable.NTWriteManager

All Implemented Interfaces:

NTThread.NTRunnable

public class NTWriteManager
extends java.lang.Object
implements NTThread.NTRunnable

A write manager is a IncomingEntryReceiver that buffers transactions and then and then dispatches them to a flushable transaction receiver that is periodically offered all queued transaction and then flushed

Field Summary

Fields

Modifier and Type	Field and Description
private NTEntryStore	m_entryStore
private java.util.Queue<NTTableEntry>	m_incomingAssignmentQueue
private java.util.Queue<NTTableEntry>	m_incomingUpdateQueue
private long	m_keepAliveDelay
private long	m_lastWrite
private java.util.Queue<NTTableEntry>	m_outgoingAssignmentQueue
private java.util.Queue<NTTableEntry>	m_outgoingUpdateQueue
private NTConnectionList	m_receiver
private NTThread	m_thread
private java.lang.Object	m_transactionsLock
private int	QUEUE_SIZE
private int	SLEEP_TIME

Constructor Summary

Constructors

Constructor and Description
NTWriteManager(NTConnectionList receiver, NTEntryStore entryStore, long keepAliveDelay) Create a new Write manager

Method Summary

Modifier and Type	Method and Description
void	offerOutgoingAssignment(NTTableEntry entry)
void	offerOutgoingUpdate(NTTableEntry entry)
void	run() the periodic method that sends all buffered transactions
void	start() start the write thread
void	stop() stop the write thread

Methods inherited from class java.lang.Object

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

Field Detail

SLEEP_TIME

private final int SLEEP_TIME

See Also:

Constant Field Values

QUEUE_SIZE

private final int QUEUE_SIZE

See Also:

Constant Field Values

m_transactionsLock

private java.lang.Object m_transactionsLock

m_thread

private NTThread m_thread

m_entryStore

private final NTEntryStore m_entryStore

m_incomingAssignmentQueue

private volatile java.util.Queue<NTTableEntry> m_incomingAssignmentQueue

m_incomingUpdateQueue

private volatile java.util.Queue<NTTableEntry> m_incomingUpdateQueue

m_outgoingAssignmentQueue

private volatile java.util.Queue<NTTableEntry> m_outgoingAssignmentQueue

m_outgoingUpdateQueue

private volatile java.util.Queue<NTTableEntry> m_outgoingUpdateQueue

m_receiver

private NTConnectionList m_receiver

m_lastWrite

private long m_lastWrite

m_keepAliveDelay

private final long m_keepAliveDelay

Constructor Detail

NTWriteManager

public NTWriteManager(NTConnectionList receiver,
                      NTEntryStore entryStore,
                      long keepAliveDelay)

Create a new Write manager

Parameters:

receiver -

threadManager -

transactionPool -

entryStore -

Method Detail

start

public void start()

start the write thread

stop

public void stop()

stop the write thread

offerOutgoingAssignment

public void offerOutgoingAssignment(NTTableEntry entry)

offerOutgoingUpdate

public void offerOutgoingUpdate(NTTableEntry entry)

run

public void run()
         throws java.lang.InterruptedException

the periodic method that sends all buffered transactions

Specified by:

run in interface NTThread.NTRunnable

Throws:

java.lang.InterruptedException