Skip to content

Commit ca226cd

Browse files
Transports/UDP: support custom message filters.
1 parent 2466797 commit ca226cd

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

src/Transports/UDP/Task.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,8 @@ namespace Transports
6969
std::vector<std::string> rate_lims;
7070
// Filtered entities.
7171
std::vector<std::string> entities_flt;
72+
// Custom filters to apply.
73+
std::vector<std::string> custom_filters;
7274
// List of messages to publish.
7375
std::vector<std::string> messages;
7476
// Announce this transport to services or not
@@ -156,6 +158,9 @@ namespace Transports
156158
param("Filtered Entities", m_args.entities_flt)
157159
.description("List of <Message>:<Entity>+<Entity> that define the source entities allowed to pass message of a specific message type.");
158160

161+
param("Custom Filters", m_args.custom_filters)
162+
.description("List of custom filters to apply");
163+
159164
param("Announce Service", m_args.announce_service)
160165
.defaultValue("true")
161166
.description("Announce this transport to services or not");
@@ -279,6 +284,9 @@ namespace Transports
279284
if (paramChanged(m_args.ign_filter))
280285
m_listener->setIgnoreFilter(m_args.ign_filter);
281286
}
287+
288+
if (paramChanged(m_args.custom_filters))
289+
m_filter.setupCustomFilters(m_args.custom_filters, this);
282290
}
283291

284292
void

0 commit comments

Comments
 (0)