Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-04 15:48:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

cluster/Backend: Rename EnqueueLocalEvent() to ProcessLocalEvent()

Browse source
This commit is contained in:
Arne Welzel 2025-04-10 16:12:57 +02:00
parent f8ef5addaa
commit fcc0f45c57
3 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/cluster/Backend.cc
View file

@ -24,7 +24,7 @@ bool detail::LocalEventHandlingStrategy::DoProcessEvent(std::string_view topic,
return true; return true;
} }
void detail::LocalEventHandlingStrategy::DoEnqueueLocalEvent(EventHandlerPtr h, zeek::Args args) { void detail::LocalEventHandlingStrategy::DoProcessLocalEvent(EventHandlerPtr h, zeek::Args args) {
zeek::event_mgr.Enqueue(h, std::move(args)); zeek::event_mgr.Enqueue(h, std::move(args));
} }
@ -120,7 +120,7 @@ bool Backend::DoPublishLogWrites(const zeek::logging::detail::LogWriteHeader& he
} }
void Backend::EnqueueEvent(EventHandlerPtr h, zeek::Args args) { void Backend::EnqueueEvent(EventHandlerPtr h, zeek::Args args) {
event_handling_strategy->EnqueueLocalEvent(h, std::move(args)); event_handling_strategy->ProcessLocalEvent(h, std::move(args));
} }
bool Backend::ProcessEvent(std::string_view topic, detail::Event e) { bool Backend::ProcessEvent(std::string_view topic, detail::Event e) {

8
src/cluster/Backend.h
View file

@ -116,7 +116,7 @@ public:
* @param h The event handler to use. * @param h The event handler to use.
* @param args The event arguments. * @param args The event arguments.
*/ */
void EnqueueLocalEvent(EventHandlerPtr h, zeek::Args args) { DoEnqueueLocalEvent(h, std::move(args)); } void ProcessLocalEvent(EventHandlerPtr h, zeek::Args args) { DoProcessLocalEvent(h, std::move(args)); }
private: private:
/** /**
@ -130,12 +130,12 @@ private:
virtual bool DoProcessEvent(std::string_view topic, Event e) = 0; virtual bool DoProcessEvent(std::string_view topic, Event e) = 0;
/** /**
* Hook method for implementing EnqueueLocalEvent(). * Hook method for implementing ProcessLocalEvent().
* *
* @param h The event handler to use. * @param h The event handler to use.
* @param args The event arguments. * @param args The event arguments.
*/ */
virtual void DoEnqueueLocalEvent(EventHandlerPtr h, zeek::Args args) = 0; virtual void DoProcessLocalEvent(EventHandlerPtr h, zeek::Args args) = 0;
}; };
/** /**
@ -144,7 +144,7 @@ private:
class LocalEventHandlingStrategy : public EventHandlingStrategy { class LocalEventHandlingStrategy : public EventHandlingStrategy {
private: private:
bool DoProcessEvent(std::string_view topic, Event e) override; bool DoProcessEvent(std::string_view topic, Event e) override;
void DoEnqueueLocalEvent(EventHandlerPtr h, zeek::Args args) override; void DoProcessLocalEvent(EventHandlerPtr h, zeek::Args args) override;
}; };
/** /**

2
src/cluster/websocket/WebSocket.cc
View file

@ -85,7 +85,7 @@ private:
* Events from backends aren't enqueued into the event loop when * Events from backends aren't enqueued into the event loop when
* running for WebSocket clients. * running for WebSocket clients.
*/ */
void DoEnqueueLocalEvent(zeek::EventHandlerPtr h, zeek::Args args) override {} void DoProcessLocalEvent(zeek::EventHandlerPtr h, zeek::Args args) override {}
std::string buffer; std::string buffer;
std::shared_ptr<WebSocketClient> wsc; std::shared_ptr<WebSocketClient> wsc;