Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 06:38:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Update Broker submodule

Browse source
This commit is contained in:
Dominik Charousset 2021-07-02 11:36:39 +02:00
parent 727fca26e3
commit fbd95973b4
2 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
auxil/broker

@ -1 +1 @@
Subproject commit 3c00df399e05d70b2aefdeb8fef6b47f08d0b289
Subproject commit a7d92926dbfcd4577ddf2d8fee2ef9d7dfe60837

12
src/broker/Manager.cc
View file

@ -139,8 +139,8 @@ class BrokerState {
public:
BrokerState(BrokerConfig config, size_t congestion_queue_size)
: endpoint(std::move(config)),
subscriber(endpoint.make_subscriber({broker::topics::statuses,
broker::topics::errors},
subscriber(endpoint.make_subscriber({broker::topic::statuses(),
broker::topic::errors()},
congestion_queue_size))
{
}
@ -382,7 +382,7 @@ void Manager::InitPostScript()
if ( ! iosource_mgr->RegisterFd(bstate->subscriber.fd(), this) )
reporter->FatalError("Failed to register broker subscriber with iosource_mgr");
bstate->subscriber.add_topic(broker::topics::store_events, true);
bstate->subscriber.add_topic(broker::topic::store_events(), true);
InitializeBrokerStoreForwarding();
}
@ -1094,7 +1094,7 @@ void Manager::Process()
{
auto& topic = broker::get_topic(message);
if ( broker::topics::statuses.prefix_of(topic) )
if ( broker::is_prefix(topic, broker::topic::statuses_str) )
{
if ( auto stat = broker::make_status_view(get_data(message)) )
{
@ -1109,7 +1109,7 @@ void Manager::Process()
continue;
}
if ( broker::topics::errors.prefix_of(topic) )
if ( broker::is_prefix(topic, broker::topic::errors_str) )
{
if ( auto err = broker::make_error_view(get_data(message)) )
{
@ -1124,7 +1124,7 @@ void Manager::Process()
continue;
}
if ( broker::topics::store_events.prefix_of(topic) )
if ( broker::is_prefix(topic, broker::topic::store_events_str) )
{
ProcessStoreEvent(broker::move_data(message));
continue;