Searched refs:batch_error (Results 1 – 3 of 3) sorted by relevance
109 gpr_atm batch_error = reinterpret_cast<gpr_atm>(GRPC_ERROR_NONE); member1055 grpc_error_handle batch_error) { in recv_trailing_filter() argument1057 if (batch_error != GRPC_ERROR_NONE) { in recv_trailing_filter()1058 set_final_status(call, batch_error); in recv_trailing_filter()1174 gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()1175 gpr_atm_rel_store(&bctl->batch_error, in reset_batch_errors()1183 gpr_atm_acq_load(&bctl->batch_error))); in post_batch_completion()1353 gpr_atm_acq_load(&bctl->batch_error)) == GRPC_ERROR_NONE) { in receiving_stream_ready()1354 gpr_atm_rel_store(&bctl->batch_error, in receiving_stream_ready()1487 gpr_atm_acq_load(&bctl->batch_error)) == GRPC_ERROR_NONE) { in receiving_initial_metadata_ready()[all …]
99 gpr_atm batch_error; member1007 grpc_error* batch_error) { in recv_trailing_filter() argument1009 if (batch_error != GRPC_ERROR_NONE) { in recv_trailing_filter()1010 set_final_status(call, batch_error); in recv_trailing_filter()1124 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()1125 gpr_atm_rel_store(&bctl->batch_error, in reset_batch_errors()1133 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in post_batch_completion()1297 if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == in receiving_stream_ready()1299 gpr_atm_rel_store(&bctl->batch_error, in receiving_stream_ready()1406 if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == in receiving_initial_metadata_ready()[all …]
1308 with self.assertRaises(BatchError) as batch_error:1310 str(batch_error.exception)