Searched refs:batch_error (Results 1 – 3 of 3) sorted by relevance
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 …]
109 gpr_atm batch_error = reinterpret_cast<gpr_atm>(GRPC_ERROR_NONE); member1056 grpc_error* batch_error) { in recv_trailing_filter() argument1058 if (batch_error != GRPC_ERROR_NONE) { in recv_trailing_filter()1059 set_final_status(call, batch_error); in recv_trailing_filter()1175 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()1176 gpr_atm_rel_store(&bctl->batch_error, in reset_batch_errors()1184 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in post_batch_completion()1353 if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == in receiving_stream_ready()1355 gpr_atm_rel_store(&bctl->batch_error, in receiving_stream_ready()1486 if (reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error)) == in receiving_initial_metadata_ready()[all …]
1247 with self.assertRaises(BatchError) as batch_error:1249 str(batch_error.exception)