summaryrefslogtreecommitdiff
path: root/system/gd/grpc/grpc_event_queue.h
diff options
context:
space:
mode:
Diffstat (limited to 'system/gd/grpc/grpc_event_queue.h')
-rw-r--r--system/gd/grpc/grpc_event_queue.h4
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());
}