ServerIncomingStreamMonitor.h

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

#ifndef SERVERINCOMINGSTREAMMONITOR_H_
#define SERVERINCOMINGSTREAMMONITOR_H_


class ServerIncomingStreamMonitor;


#include "networktables2/thread/PeriodicRunnable.h"
#include "networktables2/thread/NTThreadManager.h"
#include "networktables2/thread/NTThread.h"
#include "networktables2/stream/IOStreamProvider.h"
#include "networktables2/server/ServerIncomingConnectionListener.h"
#include "networktables2/server/ServerNetworkTableEntryStore.h"
#include "networktables2/server/ServerAdapterManager.h"
#include "networktables2/server/ServerConnectionAdapter.h"



class ServerIncomingStreamMonitor : PeriodicRunnable{
private:
        IOStreamProvider& streamProvider;
        ServerNetworkTableEntryStore& entryStore;
        ServerIncomingConnectionListener& incomingListener;

        ServerAdapterManager& adapterListener;
        NetworkTableEntryTypeManager& typeManager;
        NTThreadManager& threadManager;
        NTThread* monitorThread;
        
        NTReentrantSemaphore BlockDeletionList;
        std::vector<ServerConnectionAdapter *> m_DeletionList;
public:
        ServerIncomingStreamMonitor(IOStreamProvider& streamProvider, ServerNetworkTableEntryStore& entryStore,
                        ServerIncomingConnectionListener& incomingListener,
                        ServerAdapterManager& adapterListener,
                        NetworkTableEntryTypeManager& typeManager, NTThreadManager& threadManager);
        
        ~ServerIncomingStreamMonitor();
        void start();
        void stop();
        
        void run();
        
        void close(ServerConnectionAdapter *Adapter);
        
};




#endif /* SERVERINCOMINGSTREAMMONITOR_H_ */