Skip to content
Snippets Groups Projects
Commit 676db291 authored by Craig Tiller's avatar Craig Tiller
Browse files

Fix barriers

parent e0341792
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
src/core/lib/surface/call.c
+ 2
− 2
View file @ 676db291
...@@ -315,7 +315,7 @@ grpc_error *grpc_call_create(grpc_exec_ctx *exec_ctx, ...@@ -315,7 +315,7 @@ grpc_error *grpc_call_create(grpc_exec_ctx *exec_ctx,
GPR_ASSERT(!args->parent_call->is_client); GPR_ASSERT(!args->parent_call->is_client);
gpr_mu_lock(&args->parent_call->child_list_mu); gpr_mu_lock(&args->parent_call->child_list_mu);
gpr_atm_no_barrier_store(&args->parent_call->has_children, 1); gpr_atm_rel_store(&args->parent_call->has_children, 1);
if (args->propagation_mask & GRPC_PROPAGATE_DEADLINE) { if (args->propagation_mask & GRPC_PROPAGATE_DEADLINE) {
send_deadline = gpr_time_min( send_deadline = gpr_time_min(
...@@ -1095,7 +1095,7 @@ static void post_batch_completion(grpc_exec_ctx *exec_ctx, ...@@ -1095,7 +1095,7 @@ static void post_batch_completion(grpc_exec_ctx *exec_ctx,
call->received_final_op = true; call->received_final_op = true;
/* propagate cancellation to any interested children */ /* propagate cancellation to any interested children */
if (gpr_atm_no_barrier_load(&call->has_children)) { if (gpr_atm_acq_load(&call->has_children)) {
gpr_mu_lock(&call->child_list_mu); gpr_mu_lock(&call->child_list_mu);
child_call = call->first_child; child_call = call->first_child;
if (child_call != NULL) { if (child_call != NULL) {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment