diff --git a/userspace/falco/grpc_server.cpp b/userspace/falco/grpc_server.cpp index bdaec631..bf54b376 100644 --- a/userspace/falco/grpc_server.cpp +++ b/userspace/falco/grpc_server.cpp @@ -194,7 +194,7 @@ void falco_grpc_server::run() while(is_running()) { - sleep(1); + sleep(1); // todo > do we want to sleep here? } 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(); return true; } diff --git a/userspace/falco/grpc_server.h b/userspace/falco/grpc_server.h index 2c89c0e9..7aec3e73 100644 --- a/userspace/falco/grpc_server.h +++ b/userspace/falco/grpc_server.h @@ -28,8 +28,7 @@ limitations under the License. class falco_grpc_server : public falco_grpc_server_impl { public: - falco_grpc_server(std::string server_addr, int threadiness, falco_output_response_cq& m_event_queue): - falco_grpc_server_impl(m_event_queue), + falco_grpc_server(std::string server_addr, int threadiness): m_server_addr(server_addr), m_threadiness(threadiness) { @@ -50,7 +49,7 @@ private: std::vector 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 {