Skip to content

Commit d194c15

Browse files
Carlosespicurmergify[bot]
Carlosespicur
authored and
mergify[bot]
committed
Bump to asio 1.34.2 (#5896)
* Refs #22970: Bump to asio 1.34 Signed-off-by: Carlosespicur <carlosespicur@proton.me> * Refs #22970: Update thirdparty module to 1.34.2 release Signed-off-by: Carlosespicur <carlosespicur@proton.me> * Refs #22970: Update versions.md Signed-off-by: Carlosespicur <carlosespicur@proton.me> * Refs #22970: Uncrustify Signed-off-by: Carlosespicur <carlosespicur@proton.me> * Refs #22970: Update Asio minimum version in CMakeLists Signed-off-by: Carlosespicur <carlosespicur@proton.me> --------- Signed-off-by: Carlosespicur <carlosespicur@proton.me> (cherry picked from commit da0e9ed) # Conflicts: # versions.md
1 parent ac0536e commit d194c15

28 files changed

Lines changed: 200 additions & 202 deletions

‎CMakeLists.txt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ if(NOT BUILD_SHARED_LIBS)
255255
endif()
256256

257257
eprosima_find_package(fastcdr 2 REQUIRED)
258-
eprosima_find_thirdparty(Asio asio VERSION 1.10.8)
258+
eprosima_find_thirdparty(Asio asio VERSION 1.13.0)
259259
eprosima_find_thirdparty(TinyXML2 tinyxml2)
260260

261261
find_package(foonathan_memory REQUIRED)

‎src/cpp/rtps/transport/TCPAcceptor.cpp‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -24,28 +24,28 @@ namespace rtps {
2424
using IPLocator = fastdds::rtps::IPLocator;
2525

2626
TCPAcceptor::TCPAcceptor(
27-
asio::io_service& io_service,
27+
asio::io_context& io_context,
2828
TCPTransportInterface* parent,
2929
const Locator& locator)
30-
: acceptor_(io_service, parent->generate_endpoint(IPLocator::getPhysicalPort(locator)))
30+
: acceptor_(io_context, parent->generate_endpoint(IPLocator::getPhysicalPort(locator)))
3131
, locator_(locator)
32-
, io_service_(&io_service)
32+
, io_context_(&io_context)
3333
{
3434
locator_.port = acceptor_.local_endpoint().port();
3535
endpoint_ = asio::ip::tcp::endpoint(parent->generate_protocol(), IPLocator::getPhysicalPort(locator_));
3636
}
3737

3838
TCPAcceptor::TCPAcceptor(
39-
asio::io_service& io_service,
39+
asio::io_context& io_context,
4040
const std::string& iface,
4141
const Locator& locator)
42-
: acceptor_(io_service, asio::ip::tcp::endpoint(asio::ip::address::from_string(iface),
42+
: acceptor_(io_context, asio::ip::tcp::endpoint(asio::ip::make_address(iface),
4343
IPLocator::getPhysicalPort(locator)))
4444
, locator_(locator)
45-
, io_service_(&io_service)
45+
, io_context_(&io_context)
4646
{
4747
locator_.port = acceptor_.local_endpoint().port();
48-
endpoint_ = asio::ip::tcp::endpoint(asio::ip::address::from_string(iface),
48+
endpoint_ = asio::ip::tcp::endpoint(asio::ip::make_address(iface),
4949
IPLocator::getPhysicalPort(locator_));
5050
}
5151

‎src/cpp/rtps/transport/TCPAcceptor.h‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,17 +35,17 @@ class TCPAcceptor
3535
Locator locator_;
3636
asio::ip::tcp::endpoint endpoint_;
3737
std::vector<Locator> pending_out_locators_;
38-
asio::io_service* io_service_;
38+
asio::io_context* io_context_;
3939

4040
public:
4141

4242
TCPAcceptor(
43-
asio::io_service& io_service,
43+
asio::io_context& io_context,
4444
TCPTransportInterface* parent,
4545
const Locator& locator);
4646

4747
TCPAcceptor(
48-
asio::io_service& io_service,
48+
asio::io_context& io_context,
4949
const std::string& iface,
5050
const Locator& locator);
5151

‎src/cpp/rtps/transport/TCPAcceptorBasic.cpp‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -24,23 +24,23 @@ namespace rtps {
2424
using IPLocator = fastdds::rtps::IPLocator;
2525

2626
TCPAcceptorBasic::TCPAcceptorBasic(
27-
asio::io_service& io_service,
27+
asio::io_context& io_context,
2828
TCPTransportInterface* parent,
2929
const Locator& locator)
30-
: TCPAcceptor(io_service, parent, locator)
31-
, socket_(*io_service_)
30+
: TCPAcceptor(io_context, parent, locator)
31+
, socket_(*io_context_)
3232
{
3333
endpoint_ = asio::ip::tcp::endpoint(parent->generate_protocol(), IPLocator::getPhysicalPort(locator_));
3434
}
3535

3636
TCPAcceptorBasic::TCPAcceptorBasic(
37-
asio::io_service& io_service,
37+
asio::io_context& io_context,
3838
const std::string& iface,
3939
const Locator& locator)
40-
: TCPAcceptor(io_service, iface, locator)
41-
, socket_(*io_service_)
40+
: TCPAcceptor(io_context, iface, locator)
41+
, socket_(*io_context_)
4242
{
43-
endpoint_ = asio::ip::tcp::endpoint(asio::ip::address::from_string(iface),
43+
endpoint_ = asio::ip::tcp::endpoint(asio::ip::make_address(iface),
4444
IPLocator::getPhysicalPort(locator_));
4545
}
4646

‎src/cpp/rtps/transport/TCPAcceptorBasic.h‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,23 +31,23 @@ class TCPAcceptorBasic : public TCPAcceptor
3131

3232
/**
3333
* Constructor
34-
* @param io_service Reference to the ASIO service.
34+
* @param io_context Reference to the ASIO context.
3535
* @param parent Pointer to the transport that is going to manage the acceptor.
3636
* @param locator Locator with the information about where to accept connections.
3737
*/
3838
TCPAcceptorBasic(
39-
asio::io_service& io_service,
39+
asio::io_context& io_context,
4040
TCPTransportInterface* parent,
4141
const Locator& locator);
4242

4343
/**
4444
* Constructor
45-
* @param io_service Reference to the ASIO service.
45+
* @param io_context Reference to the ASIO context.
4646
* @param iface Network interface to bind the socket
4747
* @param locator Locator with the information about where to accept connections.
4848
*/
4949
TCPAcceptorBasic(
50-
asio::io_service& io_service,
50+
asio::io_context& io_context,
5151
const std::string& iface,
5252
const Locator& locator);
5353

‎src/cpp/rtps/transport/TCPAcceptorSecure.cpp‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,18 +27,18 @@ using Log = fastdds::dds::Log;
2727
using namespace asio;
2828

2929
TCPAcceptorSecure::TCPAcceptorSecure(
30-
io_service& io_service,
30+
io_context& io_context,
3131
TCPTransportInterface* parent,
3232
const Locator_t& locator)
33-
: TCPAcceptor(io_service, parent, locator)
33+
: TCPAcceptor(io_context, parent, locator)
3434
{
3535
}
3636

3737
TCPAcceptorSecure::TCPAcceptorSecure(
38-
io_service& io_service,
38+
io_context& io_context,
3939
const std::string& iface,
4040
const Locator_t& locator)
41-
: TCPAcceptor(io_service, iface, locator)
41+
: TCPAcceptor(io_context, iface, locator)
4242
{
4343
}
4444

@@ -83,7 +83,7 @@ void TCPAcceptorSecure::accept(
8383
}
8484
});
8585
#else
86-
auto secure_socket = std::make_shared<asio::ssl::stream<asio::ip::tcp::socket>>(*io_service_, ssl_context);
86+
auto secure_socket = std::make_shared<asio::ssl::stream<asio::ip::tcp::socket>>(*io_context_, ssl_context);
8787

8888
acceptor_.async_accept(secure_socket->lowest_layer(),
8989
[locator, parent, secure_socket](const std::error_code& error)

‎src/cpp/rtps/transport/TCPAcceptorSecure.h‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,23 +37,23 @@ class TCPAcceptorSecure : public TCPAcceptor
3737

3838
/**
3939
* Constructor
40-
* @param io_service Reference to the ASIO service.
40+
* @param io_context Reference to the ASIO context.
4141
* @param parent Pointer to the transport that is going to manage the acceptor.
4242
* @param locator Locator with the information about where to accept connections.
4343
*/
4444
TCPAcceptorSecure(
45-
asio::io_service& io_service,
45+
asio::io_context& io_context,
4646
TCPTransportInterface* parent,
4747
const Locator& locator);
4848

4949
/**
5050
* Constructor
51-
* @param io_service Reference to the ASIO service.
51+
* @param io_context Reference to the ASIO context.
5252
* @param iface Network interface to bind the socket
5353
* @param locator Locator with the information about where to accept connections.
5454
*/
5555
TCPAcceptorSecure(
56-
asio::io_service& io_service,
56+
asio::io_context& io_context,
5757
const std::string& iface,
5858
const Locator& locator);
5959

‎src/cpp/rtps/transport/TCPChannelResourceBasic.cpp‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -31,21 +31,21 @@ using Log = fastdds::dds::Log;
3131

3232
TCPChannelResourceBasic::TCPChannelResourceBasic(
3333
TCPTransportInterface* parent,
34-
asio::io_service& service,
34+
asio::io_context& context,
3535
const Locator& locator,
3636
uint32_t maxMsgSize)
3737
: TCPChannelResource(parent, locator, maxMsgSize)
38-
, service_(service)
38+
, context_(context)
3939
{
4040
}
4141

4242
TCPChannelResourceBasic::TCPChannelResourceBasic(
4343
TCPTransportInterface* parent,
44-
asio::io_service& service,
44+
asio::io_context& context,
4545
std::shared_ptr<asio::ip::tcp::socket> socket,
4646
uint32_t maxMsgSize)
4747
: TCPChannelResource(parent, maxMsgSize)
48-
, service_(service)
48+
, context_(context)
4949
, socket_(socket)
5050
{
5151
}
@@ -64,14 +64,14 @@ void TCPChannelResourceBasic::connect(
6464
{
6565
try
6666
{
67-
ip::tcp::resolver resolver(service_);
67+
ip::tcp::resolver resolver(context_);
6868

69-
auto endpoints = resolver.resolve({
70-
IPLocator::hasWan(locator_) ? IPLocator::toWanstring(locator_) : IPLocator::ip_to_string(
71-
locator_),
72-
std::to_string(IPLocator::getPhysicalPort(locator_))});
69+
auto endpoints = resolver.resolve(
70+
IPLocator::hasWan(locator_) ? IPLocator::toWanstring(locator_) : IPLocator::ip_to_string(
71+
locator_),
72+
std::to_string(IPLocator::getPhysicalPort(locator_)));
7373

74-
socket_ = std::make_shared<asio::ip::tcp::socket>(service_);
74+
socket_ = std::make_shared<asio::ip::tcp::socket>(context_);
7575
std::weak_ptr<TCPChannelResource> channel_weak_ptr = myself;
7676

7777
asio::async_connect(
@@ -109,7 +109,7 @@ void TCPChannelResourceBasic::disconnect()
109109
std::error_code ec;
110110
socket->shutdown(asio::ip::tcp::socket::shutdown_both, ec);
111111

112-
service_.post([&, socket]()
112+
asio::post(context_, [&, socket]()
113113
{
114114
try
115115
{

‎src/cpp/rtps/transport/TCPChannelResourceBasic.h‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ namespace rtps {
2525

2626
class TCPChannelResourceBasic : public TCPChannelResource
2727
{
28-
asio::io_service& service_;
28+
asio::io_context& context_;
2929

3030
std::mutex send_mutex_;
3131
std::shared_ptr<asio::ip::tcp::socket> socket_;
@@ -35,14 +35,14 @@ class TCPChannelResourceBasic : public TCPChannelResource
3535
// Constructor called when trying to connect to a remote server
3636
TCPChannelResourceBasic(
3737
TCPTransportInterface* parent,
38-
asio::io_service& service,
38+
asio::io_context& context,
3939
const Locator& locator,
4040
uint32_t maxMsgSize);
4141

4242
// Constructor called when local server accepted connection
4343
TCPChannelResourceBasic(
4444
TCPTransportInterface* parent,
45-
asio::io_service& service,
45+
asio::io_context& context,
4646
std::shared_ptr<asio::ip::tcp::socket> socket,
4747
uint32_t maxMsgSize);
4848

‎src/cpp/rtps/transport/TCPChannelResourceSecure.cpp‎

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -31,29 +31,29 @@ using namespace asio;
3131

3232
TCPChannelResourceSecure::TCPChannelResourceSecure(
3333
TCPTransportInterface* parent,
34-
asio::io_service& service,
34+
asio::io_context& context,
3535
asio::ssl::context& ssl_context,
3636
const Locator_t& locator,
3737
uint32_t maxMsgSize)
3838
: TCPChannelResource(parent, locator, maxMsgSize)
39-
, service_(service)
39+
, context_(context)
4040
, ssl_context_(ssl_context)
41-
, strand_read_(service)
42-
, strand_write_(service)
41+
, strand_read_(make_strand(context))
42+
, strand_write_(make_strand(context))
4343
{
4444
}
4545

4646
TCPChannelResourceSecure::TCPChannelResourceSecure(
4747
TCPTransportInterface* parent,
48-
asio::io_service& service,
48+
asio::io_context& context,
4949
asio::ssl::context& ssl_context,
5050
std::shared_ptr<asio::ssl::stream<asio::ip::tcp::socket>> socket,
5151
uint32_t maxMsgSize)
5252
: TCPChannelResource(parent, maxMsgSize)
53-
, service_(service)
53+
, context_(context)
5454
, ssl_context_(ssl_context)
55-
, strand_read_(service)
56-
, strand_write_(service)
55+
, strand_read_(make_strand(context))
56+
, strand_write_(make_strand(context))
5757
, secure_socket_(socket)
5858
{
5959
set_tls_verify_mode(parent->configuration());
@@ -76,15 +76,15 @@ void TCPChannelResourceSecure::connect(
7676
{
7777
try
7878
{
79-
ip::tcp::resolver resolver(service_);
79+
ip::tcp::resolver resolver(context_);
8080

81-
auto endpoints = resolver.resolve({
82-
IPLocator::hasWan(locator_) ? IPLocator::toWanstring(locator_) : IPLocator::ip_to_string(
83-
locator_),
84-
std::to_string(IPLocator::getPhysicalPort(locator_))});
81+
auto endpoints = resolver.resolve(
82+
IPLocator::hasWan(locator_) ? IPLocator::toWanstring(locator_) : IPLocator::ip_to_string(
83+
locator_),
84+
std::to_string(IPLocator::getPhysicalPort(locator_)));
8585

8686
TCPTransportInterface* parent = parent_;
87-
secure_socket_ = std::make_shared<asio::ssl::stream<asio::ip::tcp::socket>>(service_, ssl_context_);
87+
secure_socket_ = std::make_shared<asio::ssl::stream<asio::ip::tcp::socket>>(context_, ssl_context_);
8888
set_tls_verify_mode(parent->configuration());
8989
set_tls_sni(parent->configuration());
9090
std::weak_ptr<TCPChannelResource> channel_weak_ptr = myself;
@@ -142,7 +142,7 @@ void TCPChannelResourceSecure::disconnect()
142142
{
143143
auto socket = secure_socket_;
144144

145-
service_.post([&, socket]()
145+
post(context_, [&, socket]()
146146
{
147147
std::error_code ec;
148148
socket->lowest_layer().close(ec);
@@ -166,7 +166,7 @@ uint32_t TCPChannelResourceSecure::read(
166166
auto bytes_future = read_bytes_promise.get_future();
167167
auto socket = secure_socket_;
168168

169-
strand_read_.post([&, socket]()
169+
asio::post(strand_read_, [&, socket]()
170170
{
171171
if (socket->lowest_layer().is_open())
172172
{
@@ -227,7 +227,7 @@ size_t TCPChannelResourceSecure::send(
227227
auto bytes_future = write_bytes_promise.get_future();
228228
auto socket = secure_socket_;
229229

230-
strand_write_.post([&, socket]()
230+
asio::post(strand_write_, [&, socket]()
231231
{
232232
if (socket->lowest_layer().is_open())
233233
{

0 commit comments

Comments
 (0)