~lucadestudios/lucadestudios/trunk

#ifndef NODE_H_INCLUDED

#define NODE_H_INCLUDED

 

#include <vector>

#include <boost/thread.hpp>

 

#include "ip_addressv4.h"

#include "node_process.h"

 

namespace lucade {

namespace network {

 

class connection;

typedef boost::shared_ptr<connection> connection_ptr;

 

class packet;

 

class node {

public:

    node(node_process_ptr process);

 

    bool start();

    void stop();

 

    connection_ptr spawn_connection(ip_addressv4 toWhere=ip_addressv4());

    int get_connection_count() const;

    connection_ptr get_connection(int id) const;

private:

    void queue_packet(boost::shared_ptr<packet> packetToSend); ///!< Queues a packet to send via the node_process

    node_process_ptr _process;

    boost::shared_ptr<boost::thread> _process_thread;

 

    std::vector<connection_ptr> _connections;

 

    virtual void on_pre_start() = 0;

    virtual void on_post_start() = 0;

    virtual void on_pre_stop() = 0;

    virtual void on_post_stop() = 0;

 

friend class connection;

};

 

typedef boost::shared_ptr<node> node_ptr;

}

}

 

#endif // NODE_H_INCLUDED