boostorg/mqtt5
1
0
Fork 1
mirror of https://github.com/boostorg/mqtt5.git synced 2025-07-30 12:37:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

Do not use temporaries in co_await expressions (g++ compiler bug)

Browse Source 
Summary: related to T13767

Reviewers: iljazovic

Reviewed By: iljazovic

Subscribers: miljen

Differential Revision: https://repo.mireo.local/D29449
This commit is contained in:
Korina Šimičević
2024-05-15 08:04:55 +02:00
parent 68840dda95
commit dc2b2d9bbb
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
test/integration/mqtt_features.cpp
View File

@ -87,8 +87,9 @@ asio::awaitable<void> test_subscription_identifiers() {
client.brokers(broker) client.brokers(broker)
.async_run(asio::detached); .async_run(asio::detached);
publish_props pprops;
auto&& [ec_1, rc_1, _] = co_await client.async_publish<qos_e::at_least_once>( auto&& [ec_1, rc_1, _] = co_await client.async_publish<qos_e::at_least_once>(
topic, payload, retain_e::yes, publish_props {}, use_nothrow_awaitable topic, payload, retain_e::yes, pprops, use_nothrow_awaitable
); );
BOOST_TEST_WARN(!ec_1); BOOST_TEST_WARN(!ec_1);
BOOST_TEST_WARN(!rc_1); BOOST_TEST_WARN(!rc_1);
@ -98,9 +99,9 @@ asio::awaitable<void> test_subscription_identifiers() {
sprops[prop::subscription_identifier] = sub_id; sprops[prop::subscription_identifier] = sub_id;
subscribe_options sub_opts = { .no_local = no_local_e::no }; subscribe_options sub_opts = { .no_local = no_local_e::no };
subscribe_topic sub_topic = { share_topic, sub_opts };
auto&& [ec_2, rcs, __] = co_await client.async_subscribe( auto&& [ec_2, rcs, __] = co_await client.async_subscribe(
{ topic, sub_opts }, sprops, use_nothrow_awaitable sub_topic, sprops, use_nothrow_awaitable
); );
BOOST_TEST_WARN(!ec_2); BOOST_TEST_WARN(!ec_2);
BOOST_TEST_WARN(!rcs[0]); BOOST_TEST_WARN(!rcs[0]);
@ -128,16 +129,18 @@ asio::awaitable<void> test_shared_subscription() {
.async_run(asio::detached); .async_run(asio::detached);
subscribe_options sub_opts = { .no_local = no_local_e::no }; subscribe_options sub_opts = { .no_local = no_local_e::no };
subscribe_topic sub_topic = { share_topic, sub_opts };
subscribe_props sprops;
auto&& [ec_1, rcs, __] = co_await client.async_subscribe( auto&& [ec_1, rcs, __] = co_await client.async_subscribe(
{ share_topic, sub_opts}, subscribe_props {}, use_nothrow_awaitable sub_topic, sprops, use_nothrow_awaitable
); );
BOOST_TEST_WARN(!ec_1); BOOST_TEST_WARN(!ec_1);
BOOST_TEST_WARN(!rcs[0]); BOOST_TEST_WARN(!rcs[0]);
publish_props pprops;
// shared subscriptions do not send Retained Messages on first subscribe // shared subscriptions do not send Retained Messages on first subscribe
auto&& [ec_2, rc_2, _] = co_await client.async_publish<qos_e::at_least_once>( auto&& [ec_2, rc_2, _] = co_await client.async_publish<qos_e::at_least_once>(
topic, payload, retain_e::no, publish_props{}, use_nothrow_awaitable topic, payload, retain_e::no, pprops, use_nothrow_awaitable
); );
BOOST_TEST_WARN(!ec_2); BOOST_TEST_WARN(!ec_2);
BOOST_TEST_WARN(!rc_2); BOOST_TEST_WARN(!rc_2);