X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;ds=inline;f=src%2Flib%2Fserver.cc;h=c1be5735e9bb0be7db25831ebab9f44641ec1f3c;hb=233f8008287c09ed0da6cddba56fb1bd83e21d0f;hp=722b1c81130bde8a81856526c3ad01c357153f3e;hpb=8b183eea3238cc2f25cf62e63d724a2d2d361ee7;p=dcpomatic.git diff --git a/src/lib/server.cc b/src/lib/server.cc index 722b1c811..c1be5735e 100644 --- a/src/lib/server.cc +++ b/src/lib/server.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 2012-2015 Carl Hetherington + Copyright (C) 2012-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,20 +18,27 @@ */ + #include "server.h" #include "dcpomatic_socket.h" + #include "i18n.h" -using boost::shared_ptr; -Server::Server (int port) +using std::make_shared; +using std::shared_ptr; + + +Server::Server (int port, int timeout) : _terminate (false) , _acceptor (_io_service, boost::asio::ip::tcp::endpoint (boost::asio::ip::tcp::v4(), port)) + , _timeout (timeout) { } + Server::~Server () { { @@ -43,6 +50,7 @@ Server::~Server () stop (); } + void Server::run () { @@ -50,6 +58,7 @@ Server::run () _io_service.run (); } + void Server::start_accept () { @@ -60,10 +69,11 @@ Server::start_accept () } } - shared_ptr socket (new Socket); + auto socket = make_shared(_timeout); _acceptor.async_accept (socket->socket (), boost::bind (&Server::handle_accept, this, socket, boost::asio::placeholders::error)); } + void Server::handle_accept (shared_ptr socket, boost::system::error_code const & error) { @@ -75,6 +85,7 @@ Server::handle_accept (shared_ptr socket, boost::system::error_code cons start_accept (); } + void Server::stop () {