diff options
author | 2018-07-18 14:43:59 -0700 | |
---|---|---|
committer | 2018-07-18 14:47:56 -0700 | |
commit | 6b2b91cc938b1ce4400ad19106255afbdefd00d7 (patch) | |
tree | 019e0133da1df7afcd565a9f5c9dca2d040f56b0 /src/core/lib/iomgr | |
parent | 31c7ab1aafcd00c7407c84c3838ef0bb356ffeb1 (diff) |
Fix a TSAN bug in lockfree_event
Diffstat (limited to 'src/core/lib/iomgr')
-rw-r--r-- | src/core/lib/iomgr/lockfree_event.cc | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/core/lib/iomgr/lockfree_event.cc b/src/core/lib/iomgr/lockfree_event.cc index 5b6b79fa91..8f2c24f464 100644 --- a/src/core/lib/iomgr/lockfree_event.cc +++ b/src/core/lib/iomgr/lockfree_event.cc @@ -89,7 +89,11 @@ void LockfreeEvent::DestroyEvent() { void LockfreeEvent::NotifyOn(grpc_closure* closure) { while (true) { - gpr_atm curr = gpr_atm_no_barrier_load(&state_); + /* This load needs to be an acquire load because this can be a shutdown + * error that we might need to reference. Adding acquire semantics makes + * sure that the shutdown error has been inited properly before us + * referencing it. */ + gpr_atm curr = gpr_atm_acq_load(&state_); if (grpc_polling_trace.enabled()) { gpr_log(GPR_ERROR, "LockfreeEvent::NotifyOn: %p curr=%p closure=%p", this, (void*)curr, closure); |