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

cluster/ThreadedBackend: Remove Process()

Browse source 
This must have been left-over from before OnLoopProcess existed. It
wasn't called or used anymore.
This commit is contained in:
Arne Welzel 2025-04-24 08:59:54 +02:00
parent 63d31d7d9f
commit 85a2694cb2
2 changed files with 0 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/cluster/Backend.cc
View file

@ -213,11 +213,6 @@ void ThreadedBackend::QueueForProcessing(QueueMessage&& qmessages) {
onloop->QueueForProcessing(std::move(qmessages)); onloop->QueueForProcessing(std::move(qmessages));
} }
void ThreadedBackend::Process() {
if ( onloop )
onloop->Process();
}
void ThreadedBackend::Process(QueueMessage&& msg) { void ThreadedBackend::Process(QueueMessage&& msg) {
// sonarlint wants to use std::visit. not sure... // sonarlint wants to use std::visit. not sure...
if ( auto* emsg = std::get_if<EventMessage>(&msg) ) { if ( auto* emsg = std::get_if<EventMessage>(&msg) ) {

6
src/cluster/Backend.h
View file

@ -570,12 +570,6 @@ protected:
*/ */
void QueueForProcessing(QueueMessage&& messages); void QueueForProcessing(QueueMessage&& messages);
/**
* Delegate to onloop->Process() to trigger processing
* of outstanding queued messages explicitly, if any.
*/
void Process();
/** /**
* The default DoInit() implementation of ThreadedBackend * The default DoInit() implementation of ThreadedBackend
* registers itself as a counting IO source to keep the IO * registers itself as a counting IO source to keep the IO