github/falco
1
0
Fork 0
mirror of https://github.com/falcosecurity/falco.git synced 2025-09-20 01:17:46 +00:00
Code Issues Projects Releases Wiki Activity

update(userspace/falco): use concurrent output queue in grpc server

Browse Source 
Signed-off-by: Leonardo Di Donato <leodidonato@gmail.com>
Co-authored-by: Lorenzo Fontana <lo@linux.com>
This commit is contained in:
Leonardo Di Donato
2019-09-06 14:06:53 +00:00
committed by Leo Di Donato
parent 4f23b0bdfb
commit 45df07bc1b
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
userspace/falco/grpc_server.cpp
View File

@@ -194,7 +194,7 @@ void falco_grpc_server::run()
while(is_running()) while(is_running())
{ {
sleep(1); sleep(1); // todo > do we want to sleep here?
} }
stop(); stop();
@@ -223,9 +223,9 @@ void falco_grpc_server::stop()
} }
} }
bool start_grpc_server(std::string server_address, int threadiness, falco_output_response_cq& output_event_queue) bool start_grpc_server(std::string server_address, int threadiness)
{ {
falco_grpc_server srv(server_address, threadiness, output_event_queue); falco_grpc_server srv(server_address, threadiness);
srv.run(); srv.run();
return true; return true;
} }

5
userspace/falco/grpc_server.h
View File

@@ -28,8 +28,7 @@ limitations under the License.
class falco_grpc_server : public falco_grpc_server_impl class falco_grpc_server : public falco_grpc_server_impl
{ {
public: public:
falco_grpc_server(std::string server_addr, int threadiness, falco_output_response_cq& m_event_queue): falco_grpc_server(std::string server_addr, int threadiness):
falco_grpc_server_impl(m_event_queue),
m_server_addr(server_addr), m_server_addr(server_addr),
m_threadiness(threadiness) m_threadiness(threadiness)
{ {
@@ -50,7 +49,7 @@ private:
std::vector<std::thread> m_threads; std::vector<std::thread> m_threads;
}; };
bool start_grpc_server(std::string server_address, int threadiness, falco_output_response_cq& output_event_queue); bool start_grpc_server(std::string server_address, int threadiness);
class request_context_base class request_context_base
{ {