github/falco
1
0
Fork 0
mirror of https://github.com/falcosecurity/falco.git synced 2025-07-18 16:51:30 +00:00
Code Issues Projects Releases Wiki Activity

update(userspace/falco): keep the stream open

Browse Source 
Co-Authored-By: Leonardo Di Donato <leodidonato@gmail.com>
Signed-off-by: Lorenzo Fontana <lo@linux.com>
This commit is contained in:
Lorenzo Fontana 2019-09-05 12:04:18 +02:00 committed by Leo Di Donato
parent 356861be5f
commit 572a1e8381
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
userspace/falco/grpc_server.cpp
View File

@ -84,7 +84,7 @@ void request_stream_context<falco_output_request, falco_output_response>::end(fa
// Complete the processing // Complete the processing
falco_output_response res; falco_output_response res;
(srv->*m_process_func)(*m_stream_ctx, m_req, res); (srv->*m_process_func)(*m_stream_ctx, m_req, res); // subscribe()
} }
else else
{ {
@ -117,16 +117,15 @@ void falco_grpc_server_impl::subscribe(const stream_context& ctx, const falco_ou
{ {
// Start (or continue) streaming // Start (or continue) streaming
// ctx.m_status == stream_context::STREAMING // ctx.m_status == stream_context::STREAMING
// todo > do we want batching? // todo > do we want batching?
dequeue:
if(!m_event_queue.try_pop(res)) if(!m_event_queue.try_pop(res))
{ {
// TODO: log that we've not been able to pop? // TODO: backoff mechanism that does has more false
goto dequeue;
} }
ctx.m_has_more = true; ctx.m_has_more = true;
} }
// todo > print/store statistics
} }
void falco_grpc_server::thread_process(int thread_index) void falco_grpc_server::thread_process(int thread_index)