TcpServer.h

Go to the documentation of this file.

/*
 * File:   TcpServer.h
 * Author: jtedesco
 *
 * Created on May 26, 2011, 12:33 PM
 */

#ifndef TCPSERVER_H
#define TCPSERVER_H

#include<set>

#include "Tcp.h"
#include "Server.h"
#include "Logger.h"

using boost::asio::ip::tcp;
using std::set;

class TcpServer: public Tcp, public Server
{

    public:

        TcpServer(int port, boost::asio::io_service & io_service);

        TcpServer(int port, boost::asio::io_service & io_service, map<string, string> options);

        virtual ~TcpServer();

        virtual void start_listening();

        virtual void shutdown();

        virtual int get_port();

        FB_JSAPI_EVENT(disconnect, 1, (const string &));

        FB_JSAPI_EVENT(connect, 0, ());

    protected:


        void receive_handler(const boost::system::error_code & error_code, std::size_t bytesTransferred,
                boost::shared_ptr<tcp::socket> connection, string host, int port);

        virtual void fire_error_event(const string & message);

        virtual void fire_disconnect_event(const string & message);

        virtual void fire_data_event(const string data, boost::shared_ptr<tcp::socket> connection);

        virtual void close();

    private:

        void init();

        void init_socket(boost::shared_ptr<tcp::socket> connection);

        TcpServer(const TcpServer &other);

        void accept_handler(const boost::system::error_code & error_code, boost::shared_ptr<tcp::socket> connection, string host, int port);

        boost::shared_ptr<tcp::acceptor> acceptor;
        
        set<boost::shared_ptr<tcp::socket> > connections;
};

#endif  /* TCPSERVER_H */