|
|
|
@ -1108,7 +1108,8 @@ static void finish_batch_completion(void* user_data, |
|
|
|
|
static void reset_batch_errors(batch_control* bctl) { |
|
|
|
|
GRPC_ERROR_UNREF( |
|
|
|
|
reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, GRPC_ERROR_NONE); |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, |
|
|
|
|
reinterpret_cast<gpr_atm>(GRPC_ERROR_NONE)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void post_batch_completion(batch_control* bctl) { |
|
|
|
@ -1281,7 +1282,8 @@ static void receiving_stream_ready(void* bctlp, grpc_error* error) { |
|
|
|
|
call->receiving_stream.reset(); |
|
|
|
|
if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == |
|
|
|
|
GRPC_ERROR_NONE) { |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, GRPC_ERROR_REF(error)); |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, |
|
|
|
|
reinterpret_cast<gpr_atm>(GRPC_ERROR_REF(error))); |
|
|
|
|
} |
|
|
|
|
cancel_with_error(call, GRPC_ERROR_REF(error)); |
|
|
|
|
} |
|
|
|
@ -1387,9 +1389,10 @@ static void receiving_initial_metadata_ready(void* bctlp, grpc_error* error) { |
|
|
|
|
call->send_deadline = md->deadline; |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
if (reinterpret_cast<grpc_error*> gpr_atm_acq_load(&bctl->batch_error) == |
|
|
|
|
if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == |
|
|
|
|
GRPC_ERROR_NONE) { |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, GRPC_ERROR_REF(error)); |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, |
|
|
|
|
reinterpret_cast<gpr_atm>(GRPC_ERROR_REF(error))); |
|
|
|
|
} |
|
|
|
|
cancel_with_error(call, GRPC_ERROR_REF(error)); |
|
|
|
|
} |
|
|
|
@ -1439,9 +1442,10 @@ static void finish_batch(void* bctlp, grpc_error* error) { |
|
|
|
|
batch_control* bctl = static_cast<batch_control*>(bctlp); |
|
|
|
|
grpc_call* call = bctl->call; |
|
|
|
|
GRPC_CALL_COMBINER_STOP(&call->call_combiner, "on_complete"); |
|
|
|
|
if (reinterpret_cast<grpc_error*> gpr_atm_acq_load(&bctl->batch_error) == |
|
|
|
|
if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == |
|
|
|
|
GRPC_ERROR_NONE) { |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, GRPC_ERROR_REF(error)); |
|
|
|
|
gpr_atm_rel_store(&bctl->batch_error, |
|
|
|
|
reinterpret_cast<gpr_atm>(GRPC_ERROR_REF(error))); |
|
|
|
|
} |
|
|
|
|
if (error != GRPC_ERROR_NONE) { |
|
|
|
|
cancel_with_error(call, GRPC_ERROR_REF(error)); |
|
|
|
|