[grpc-io] Re: For AsyncService returning stream, Next in busy loop returns ok as false, if RPC in other thread and completion queue gets called

2021-06-28 Thread 'Vijay Pai' via grpc.io
It's not really possible to say anything about this without knowing what's in "Proceed" . On Monday, June 21, 2021 at 9:03:15 PM UTC-7 aja...@nvidia.com wrote: > We are facing an issue where Next of a completion queue returns ok as > false, if any other RPC is called. > We need to implement a s

[grpc-io] Re: For AsyncService returning stream, Next in busy loop returns ok as false, if RPC in other thread and completion queue gets called

2021-06-28 Thread Avinash Jagtap IN
here is the complete code: #include #pragma region gRPC #include #include #include #pragma endregion gRPC #include #include #include #include #include #include #pragma region Generated Files #include "napa_plugins_config.hpp" #include "napa_plugins_core_ssl.hpp" #pragma endregion Gener

[grpc-io] Re: For AsyncService returning stream, Next in busy loop returns ok as false, if RPC in other thread and completion queue gets called

2021-06-28 Thread Avinash Jagtap IN
FYI - not sure if it'd matter, though, we are testing this implementation using Kreya tool & there is envoy proxy between client and GRPC On Tuesday, June 29, 2021 at 9:00:30 AM UTC+5:30 Avinash Jagtap IN wrote: > here is the complete code: > #include > > #pragma region gRP

[grpc-io] gRPC executor threads and timer thread

2021-06-28 Thread 'Alex Zuo' via grpc.io
For executor threads, we can use Executor::SetThreadingAll(false) to shut down. If there is no thread, it still works according to the following code. void Executor::Enqueue(grpc_closure* closure, grpc_error_handle error, bool is_short) ... do { retry_push = false; size_t cur_thread_count = stat