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 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

Author:

Mitchell

Field Summary

Fields inherited from interface edu.wpi.first.wpilibj.networktables2.OutgoingEntryReceiver

NULL

Constructor Summary

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

Method Summary

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

equals, 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 InterruptedException

the periodic method that sends all buffered transactions

Specified by:

run in interface PeriodicRunnable

Throws:

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