Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include "server.h"
- #include <iostream>
- using namespace std;
- server::server(boost::asio::io_service& io_service, short port)
- : io_service_(io_service)
- , acceptor_(io_service, tcp::endpoint(tcp::v4(), port))
- {
- session* new_session = new session(io_service_);
- acceptor_.async_accept(new_session->socket(),
- boost::bind(&server::handle_accept, this, new_session,
- boost::asio::placeholders::error));
- }
- void server::handle_accept(session* new_session,
- const boost::system::error_code& error)
- {
- if (!error)
- {
- cout << "connection from "
- << new_session->socket().remote_endpoint()
- << endl;
- new_session->start();
- new_session = new session(io_service_);
- acceptor_.async_accept(new_session->socket(),
- boost::bind(&server::handle_accept, this, new_session,
- boost::asio::placeholders::error));
- }
- else
- {
- delete new_session;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement