From ab867b963c7af48dca5dfe3815952cbebb6dab04 Mon Sep 17 00:00:00 2001 From: GuillaumeLaine Date: Mon, 30 Oct 2023 15:30:49 +0100 Subject: [PATCH] dds_topics: Adds missing data reader --- src/modules/uxrce_dds_client/dds_topics.h.em | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/modules/uxrce_dds_client/dds_topics.h.em b/src/modules/uxrce_dds_client/dds_topics.h.em index 2f4e82aca4..c664d87a9f 100644 --- a/src/modules/uxrce_dds_client/dds_topics.h.em +++ b/src/modules/uxrce_dds_client/dds_topics.h.em @@ -166,7 +166,7 @@ static void on_topic_update(uxrSession *session, uxrObjectId object_id, uint16_t bool RcvTopicsPubs::init(uxrSession *session, uxrStreamId reliable_out_stream_id, uxrStreamId reliable_in_stream_id, uxrStreamId best_effort_in_stream_id, uxrObjectId participant_id, const char *client_namespace) { -@[ for idx, sub in enumerate(subscriptions)]@ +@[ for idx, sub in enumerate(subscriptions + subscriptions_multi)]@ { uint16_t queue_depth = uORB::DefaultQueueSize<@(sub['simple_base_type'])_s>::value * 2; // use a bit larger queue size than internal create_data_reader(session, reliable_out_stream_id, best_effort_in_stream_id, participant_id, @(idx), client_namespace, "@(sub['topic_simple'])", "@(sub['dds_type'])", queue_depth);