WriteManager.h

/*
 * WriteManager.h
 *
 *  Created on: Sep 25, 2012
 *      Author: Mitchell Wills
 */

#ifndef WRITEMANAGER_H_
#define WRITEMANAGER_H_

class AbstractNetworkTableEntryStore;
class WriteManager;


#include "networktables2/thread/PeriodicRunnable.h"
#include "networktables2/OutgoingEntryReceiver.h"
#include "networktables2/thread/NTThread.h"
#include "networktables2/thread/NTThreadManager.h"
#include "networktables2/FlushableOutgoingEntryReceiver.h"
#include "networktables2/NetworkTableEntry.h"
#include <queue>
#include "OSAL/Synchronized.h"



class WriteManager : public OutgoingEntryReceiver, public PeriodicRunnable{
private:
        const static size_t queueSize = 500;
        
        NTReentrantSemaphore transactionsLock;
        
        NTThread* thread;
        
        FlushableOutgoingEntryReceiver& receiver;
        NTThreadManager& threadManager;
        AbstractNetworkTableEntryStore& entryStore;

        unsigned long keepAliveDelay;
        
        volatile std::queue<NetworkTableEntry*>* incomingAssignmentQueue;
        volatile std::queue<NetworkTableEntry*>* incomingUpdateQueue;
        volatile std::queue<NetworkTableEntry*>* outgoingAssignmentQueue;
        volatile std::queue<NetworkTableEntry*>* outgoingUpdateQueue;
        
        unsigned long lastWrite;


public:
        WriteManager(FlushableOutgoingEntryReceiver& receiver, NTThreadManager& threadManager, AbstractNetworkTableEntryStore& entryStore, unsigned long keepAliveDelay);
        virtual ~WriteManager();
        void start();
        void stop();


        void offerOutgoingAssignment(NetworkTableEntry* entry);


        void offerOutgoingUpdate(NetworkTableEntry* entry);

        
        void run();

};

#endif /* WRITEMANAGER_H_ */