ClientConnectionAdapter.h

/*
 * ClientConnectionAdapter.h
 *
 *  Created on: Nov 2, 2012
 *      Author: Mitchell Wills
 */

#ifndef CLIENTCONNECTIONADAPTER_H_
#define CLIENTCONNECTIONADAPTER_H_

class ClientConnectionAdapter;

#include "networktables2/connection/ConnectionAdapter.h"
#include "networktables2/IncomingEntryReceiver.h"
#include "networktables2/FlushableOutgoingEntryReceiver.h"
#include "networktables2/client/ClientNetworkTableEntryStore.h"
#include "networktables2/stream/IOStreamFactory.h"
#include "networktables2/thread/NTThreadManager.h"
#include "networktables2/thread/NTThread.h"
#include "networktables2/client/ClientConnectionState.h"
#include "networktables2/client/ClientConnectionListenerManager.h"
#include "networktables2/connection/ConnectionMonitorThread.h"


class ClientConnectionAdapter : public ConnectionAdapter, public IncomingEntryReceiver, public FlushableOutgoingEntryReceiver{
private:
        ClientNetworkTableEntryStore& entryStore;
        IOStreamFactory& streamFactory;
        NTThreadManager& threadManager;
        
        ClientConnectionState* connectionState;
        ClientConnectionListenerManager& connectionListenerManager;
        NTReentrantSemaphore LOCK;
        NetworkTableEntryTypeManager& typeManager;
        NTThread* readThread;
        ConnectionMonitorThread* monitor;
        NetworkTableConnection* connection;

        void gotoState(ClientConnectionState* newState);
        bool m_IsConnectionClosed;  //Keep track of when this is closed to issue reconnect
public:
        ClientConnectionState* getConnectionState();
        bool isConnected();

        ClientConnectionAdapter(ClientNetworkTableEntryStore& entryStore, NTThreadManager& threadManager, IOStreamFactory& streamFactory, ClientConnectionListenerManager& connectionListenerManager, NetworkTableEntryTypeManager& typeManager);
        virtual ~ClientConnectionAdapter();
        
        
        /*
         * Connection management
         */
        void reconnect();
        
        void close();
        void close(ClientConnectionState* newState);
        
        

        void badMessage(BadMessageException& e);

        void ioException(IOException& e);
        
        NetworkTableEntry* GetEntry(EntryId id);
        
        
        bool keepAlive();

        void clientHello(ProtocolVersion protocolRevision);

        void protocolVersionUnsupported(ProtocolVersion protocolRevision);

        void serverHelloComplete();


        void offerIncomingAssignment(NetworkTableEntry* entry);
        void offerIncomingUpdate(NetworkTableEntry* entry, SequenceNumber sequenceNumber, EntryValue value);

        void offerOutgoingAssignment(NetworkTableEntry* entry);

        void offerOutgoingUpdate(NetworkTableEntry* entry);
        void flush();
        void ensureAlive();

};


#endif /* CLIENTCONNECTIONADAPTER_H_ */