diff options
Diffstat (limited to 'system/gd/grpc/grpc_event_queue.h')
-rw-r--r-- | system/gd/grpc/grpc_event_queue.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/system/gd/grpc/grpc_event_queue.h b/system/gd/grpc/grpc_event_queue.h index ffacb14700..dc1c588708 100644 --- a/system/gd/grpc/grpc_event_queue.h +++ b/system/gd/grpc/grpc_event_queue.h @@ -51,8 +51,8 @@ class GrpcEventQueue { using namespace std::chrono_literals; LOG_INFO("%s: Entering Loop", log_name_.c_str()); while (!context->IsCancelled()) { - // Wait for 500 ms so that cancellation can be caught in amortized 250 ms latency - if (pending_events_.wait_to_take(500ms)) { + // Wait for 100 ms so that cancellation can be caught in amortized 50 ms latency + if (pending_events_.wait_to_take(100ms)) { LOG_INFO("%s: Got event from queue", log_name_.c_str()); writer->Write(pending_events_.take()); } |