server.cpp

#include <iostream>
#include <functional>

#include "server.hpp"
#include "config.hpp"

server::server(asio::io_service &ios)
    : acceptor_(ios, tcp::endpoint(asio::ip::address::from_string(bind_ip), bind_port)) {
    cout << "Listening for connections at " << bind_ip << ":" << bind_port << endl;

    acceptor_.set_option(asio::ip::tcp::socket::reuse_address(false));

    do_accept();
}

void server::do_accept() {
    //client::pointer con = client::create(acceptor_.get_executor().context());
    client::pointer con = client::create(acceptor_.get_io_service());

    acceptor_.async_accept(con->socket(),
        std::bind(&server::on_accepted, this, con,
        std::placeholders::_1));
}

void server::on_accepted(client::pointer con, const asio::error_code& err) {
    if (!err)
        con->start();
    else
        cout << err.message() << endl;

    do_accept();
}