Fix bugs in early triggering

9 years ago · f3596c5074
parent d2fd769aae
commit f3596c5074
1 changed files with 2 additions and 0 deletions
--- a/src/core/lib/iomgr/timer.c
+++ b/src/core/lib/iomgr/timer.c
@ -184,11 +184,13 @@ void grpc_timer_init(grpc_exec_ctx *exec_ctx, grpc_timer *timer,
  timer->triggered = 0;

  if (!g_initialized) {
+    timer->triggered = 1;
    grpc_exec_ctx_enqueue(exec_ctx, &timer->closure, false, NULL);
    return;
  }

  if (gpr_time_cmp(deadline, now) <= 0) {
+    timer->triggered = 1;
    grpc_exec_ctx_enqueue(exec_ctx, &timer->closure, true, NULL);
    return;
  }