edu.wpi.first.wpilibj.networktables2

Class WriteManager

java.lang.Object

edu.wpi.first.wpilibj.networktables2.WriteManager

All Implemented Interfaces:

OutgoingEntryReceiver, PeriodicRunnable

public class WriteManager
extends java.lang.Object
implements OutgoingEntryReceiver, PeriodicRunnable

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 inherited from interface edu.wpi.first.wpilibj.networktables2.OutgoingEntryReceiver

NULL

Constructor Summary

Constructors

Constructor and Description
WriteManager(FlushableOutgoingEntryReceiver receiver, NTThreadManager threadManager, AbstractNetworkTableEntryStore entryStore, long keepAliveDelay) Create a new Write manager

Method Summary

Modifier and Type	Method and Description
void	offerOutgoingAssignment(NetworkTableEntry entry)
void	offerOutgoingUpdate(NetworkTableEntry 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

Constructor Detail

WriteManager

public WriteManager(FlushableOutgoingEntryReceiver receiver,
                    NTThreadManager threadManager,
                    AbstractNetworkTableEntryStore 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(NetworkTableEntry entry)

Specified by:

offerOutgoingAssignment in interface OutgoingEntryReceiver

offerOutgoingUpdate

public void offerOutgoingUpdate(NetworkTableEntry entry)

Specified by:

offerOutgoingUpdate in interface OutgoingEntryReceiver

run

public void run()
         throws java.lang.InterruptedException

the periodic method that sends all buffered transactions

Specified by:

run in interface PeriodicRunnable

Throws:

java.lang.InterruptedException - thrown when the thread is supposed to be interrupted and stop (implementers should always let this exception fall through)