ServerConnectionAdapter.h

/*
 * ServerConnectionAdapter.h
 *
 *  Created on: Sep 26, 2012
 *      Author: Mitchell Wills
 */

#ifndef SERVERCONNECTIONADAPTER_H_
#define SERVERCONNECTIONADAPTER_H_

class ServerConnectionAdapter;

#include "networktables2/connection/ConnectionMonitorThread.h"
#include "networktables2/NetworkTableEntry.h"
#include "networktables2/connection/ConnectionAdapter.h"
#include "networktables2/stream/IOStream.h"
#include "networktables2/IncomingEntryReceiver.h"
#include "networktables2/FlushableOutgoingEntryReceiver.h"
#include "networktables2/server/ServerNetworkTableEntryStore.h"
#include "networktables2/server/ServerAdapterManager.h"
#include "networktables2/server/ServerConnectionState.h"
#include "networktables2/thread/NTThread.h"
#include "networktables2/thread/NTThreadManager.h"



class ServerConnectionAdapter : public ConnectionAdapter, public IncomingEntryReceiver, public FlushableOutgoingEntryReceiver{
private:
        ServerNetworkTableEntryStore& entryStore;
        IncomingEntryReceiver& transactionReceiver;
        ServerAdapterManager& adapterListener;
public:
        NetworkTableConnection connection;
private:
        NTThread* readThread;
        ConnectionMonitorThread monitorThread;
private:

        ServerConnectionState* connectionState;

        void gotoState(ServerConnectionState* newState);
        bool m_IsAdapterListenerClosed;
public:
        ServerConnectionAdapter(IOStream* stream, ServerNetworkTableEntryStore& entryStore, IncomingEntryReceiver& transactionReceiver, ServerAdapterManager& adapterListener, NetworkTableEntryTypeManager& typeManager, NTThreadManager& threadManager);
        virtual ~ServerConnectionAdapter();

        void shutdown(bool closeStream);

        void offerOutgoingAssignment(NetworkTableEntry* entry);

        void offerOutgoingUpdate(NetworkTableEntry* entry);


        void flush();

        ServerConnectionState* getConnectionState();

        void ensureAlive();

        //return true once the close has been issued
        bool IsAdapterListenerClosed() const {return m_IsAdapterListenerClosed;}
        ConnectionAdapter &AsConnectionAdapter() {return *this;}
protected:  //from ConnectionAdapter

        bool keepAlive();
        void badMessage(BadMessageException& e);
        void ioException(IOException& e);
        void clientHello(ProtocolVersion protocolRevision);
        void protocolVersionUnsupported(ProtocolVersion protocolRevision);
        void serverHelloComplete();
        void offerIncomingAssignment(NetworkTableEntry* entry);
        void offerIncomingUpdate(NetworkTableEntry* entry, SequenceNumber sequenceNumber, EntryValue value);
        NetworkTableEntry* GetEntry(EntryId id);
};


#endif /* SERVERCONNECTIONADAPTER_H_ */