diff options
| author | Carl Hetherington <cth@carlh.net> | 2025-05-16 00:55:28 +0200 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2025-05-28 00:33:55 +0200 |
| commit | 0718d408fb279a10ac990334962e4b9412224184 (patch) | |
| tree | 3bd716292f032f510d93df5d7fd8d3721654e8d9 | |
| parent | 6346c3d9905b9a5537e4be8b2ed96c6c2a8b13af (diff) | |
Cleanup: camelCase.
| -rw-r--r-- | src/lib/grok/messenger.h | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/lib/grok/messenger.h b/src/lib/grok/messenger.h index 034c0bd7a..8251307f5 100644 --- a/src/lib/grok/messenger.h +++ b/src/lib/grok/messenger.h @@ -431,7 +431,7 @@ struct BufferSrc struct Messenger; static void outboundThread(Messenger* messenger, const std::string &sendBuf, Synch* synch); static void inboundThread(Messenger* messenger, const std::string &receiveBuf, Synch* synch); -static void processorThread(Messenger* messenger, std::function<void(std::string)> processor); +static void processor_thread(Messenger* messenger, std::function<void (std::string)> processor); struct Messenger { @@ -475,7 +475,7 @@ struct Messenger inbound = std::thread(inboundThread, this, init_.inboundMessageBuf, inboundSynch_); for(size_t i = 0; i < init_.numProcessingThreads_; ++i) - processors_.push_back(std::thread(processorThread, this, init_.processor_)); + processors_.push_back(std::thread(processor_thread, this, init_.processor_)); } bool initBuffers(void) { @@ -756,7 +756,12 @@ struct Msg size_t ct_; }; -static void processorThread(Messenger* messenger, std::function<void(std::string)> processor) + +/* One of these is created for each core, to receive messages (e.g. "frame is encoded") + * from the grok process and handle them. + */ +static void +processor_thread(Messenger* messenger, std::function<void (std::string)> processor) { while (messenger->running) { std::string message; @@ -789,6 +794,7 @@ static void processorThread(Messenger* messenger, std::function<void(std::string } } + template<typename F> struct ScheduledFrames { |