~lucadestudios/lucadestudios/trunk

#include <boost/bind.hpp>

#include <boost/foreach.hpp>

 

#include "node.h"

#include "connection.h"

 

namespace lucade {

namespace network {

 

node::node(node_process_ptr process) {

 

}

 

bool node::start() {

    on_pre_start(); //Perform any tasks before starting the node

    //Start the process thread using the node_process

    _process_thread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&node_process::run, _process.get())));

    on_post_start();

}

 

void node::stop() {

    on_pre_stop();

 

    //Disconnect each connection

    BOOST_FOREACH(connection_ptr cp, _connections) {

        cp->disconnect(); //Disconnect the connections

    }

 

    _process->stop(); //Tell the process to stop

    _process_thread->join(); //Wait for the thread to end

 

    on_post_stop(); //Trigger any post conditions

}

 

connection_ptr node::spawn_connection(ip_addressv4 to_where) {

    connection_ptr new_connection(new connection(this, to_where)); //Create the new connection

    connect_connection(new_connection); //Does the backend specific connecting

    generate_connection_uid(new_connection); //Generate a unique ID for the connection

    _connections.push_back(new_connection); //Add the connection to the list

    return new_connection;

}

 

int node::get_connection_count() const {

    return static_cast<int>(_connections.size());

}

 

connection_ptr node::get_connection(int id) const {

 

}

 

}

}