53 lines
1.5 KiB
C++
53 lines
1.5 KiB
C++
|
// Copyright (c) 2017 Computer Vision Center (CVC) at the Universitat Autonoma
|
||
|
|
// de Barcelona (UAB).
|
||
|
|
//
|
||
|
|
// This work is licensed under the terms of the MIT license.
|
||
|
|
// For a copy, see <https://opensource.org/licenses/MIT>.
|
||
|
|
|
||
|
|
#include "carla/streaming/detail/tcp/Server.h"
|
||
|
|
|
||
|
|
#include <boost/asio/post.hpp>
|
||
|
|
|
||
|
|
#include "carla/Logging.h"
|
||
|
|
|
||
|
|
#include <memory>
|
||
|
|
|
||
|
|
namespace carla {
|
||
|
|
namespace streaming {
|
||
|
|
namespace detail {
|
||
|
|
namespace tcp {
|
||
|
|
|
||
|
|
Server::Server(boost::asio::io_context &io_context, endpoint ep)
|
||
|
|
: _io_context(io_context),
|
||
|
|
_acceptor(_io_context, std::move(ep)),
|
||
|
|
_timeout(time_duration::seconds(10u)),
|
||
|
|
_synchronous(false) {}
|
||
|
|
|
||
|
|
void Server::OpenSession(
|
||
|
|
time_duration timeout,
|
||
|
|
ServerSession::callback_function_type on_opened,
|
||
|
|
ServerSession::callback_function_type on_closed) {
|
||
|
|
using boost::system::error_code;
|
||
|
|
|
||
|
|
auto session = std::make_shared<ServerSession>(_io_context, timeout, *this);
|
||
|
|
|
||
|
|
auto handle_query = [on_opened, on_closed, session](const error_code &ec) {
|
||
|
|
if (!ec) {
|
||
|
|
session->Open(std::move(on_opened), std::move(on_closed));
|
||
|
|
} else {
|
||
|
|
log_error("tcp accept stream error:", ec.message());
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
_acceptor.async_accept(session->_socket, [=](error_code ec) {
|
||
|
|
// Handle query and open a new session immediately.
|
||
|
|
boost::asio::post(_io_context, [=]() { handle_query(ec); });
|
||
|
|
OpenSession(timeout, on_opened, on_closed);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
} // namespace tcp
|
||
|
|
} // namespace detail
|
||
|
|
} // namespace streaming
|
||
|
|
} // namespace carla
|