github/falco
1
0
Fork 0
mirror of https://github.com/falcosecurity/falco.git synced 2025-08-28 19:00:48 +00:00
Code Issues Projects Releases Wiki Activity

update(userspace/falco): create struct for sync parallel event sources parallelization

Browse Source 
Signed-off-by: Jason Dellaluce <jasondellaluce@gmail.com>
This commit is contained in:
Jason Dellaluce 2022-10-14 10:20:01 +00:00 committed by poiana
parent 0fd765f7c3
commit 3d7677ce5b
1 changed files with 62 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
userspace/falco/application.h
View File

@ -16,6 +16,7 @@ limitations under the License.
#pragma once #pragma once
#include "semaphore.h"
#include "configuration.h" #include "configuration.h"
#include "stats_writer.h" #include "stats_writer.h"
#ifndef MINIMAL_BUILD #ifndef MINIMAL_BUILD
@ -198,6 +199,67 @@ private:
bool proceed; bool proceed;
}; };
// used to synchronize different event source running in parallel
class source_sync_context
{
public:
source_sync_context(falco::semaphore& s)
: m_finished(false), m_joined(false), m_semaphore(s) { }
source_sync_context(source_sync_context&&) = default;
source_sync_context& operator = (source_sync_context&&) = default;
source_sync_context(const source_sync_context&) = delete;
source_sync_context& operator = (const source_sync_context&) = delete;
inline void finish()
{
bool v = false;
while (!m_finished.compare_exchange_weak(
v, true,
std::memory_order_seq_cst,
std::memory_order_seq_cst))
{
if (v)
{
throw falco_exception("source_sync_context has been finished twice");
}
}
m_semaphore.release();
}
inline void join()
{
bool v = false;
while (!m_joined.compare_exchange_weak(
v, true,
std::memory_order_seq_cst,
std::memory_order_seq_cst))
{
if (v)
{
throw falco_exception("source_sync_context has been joined twice");
}
}
}
inline bool joined()
{
return m_joined.load(std::memory_order_seq_cst);
}
inline bool finished()
{
return m_finished.load(std::memory_order_seq_cst);
}
private:
// set to true when the event processing loop finishes
std::atomic<bool> m_finished;
// set to true when the result has been collected after finishing
std::atomic<bool> m_joined;
// used to notify the waiting thread when finished gets set to true
falco::semaphore& m_semaphore;
};
// Convenience method. Read a sequence of filenames and fill // Convenience method. Read a sequence of filenames and fill
// in a vector of rules contents. // in a vector of rules contents.
// Also fill in the provided rules_contents_t with a mapping from // Also fill in the provided rules_contents_t with a mapping from