|
@@ -209,6 +209,9 @@ static void recv_trailing_metadata_ready(void* user_data, grpc_error* err) {
|
|
if (calld->original_recv_initial_metadata_ready) {
|
|
if (calld->original_recv_initial_metadata_ready) {
|
|
calld->recv_trailing_metadata_error = GRPC_ERROR_REF(err);
|
|
calld->recv_trailing_metadata_error = GRPC_ERROR_REF(err);
|
|
calld->seen_recv_trailing_ready = true;
|
|
calld->seen_recv_trailing_ready = true;
|
|
|
|
+ GRPC_CLOSURE_INIT(&calld->recv_trailing_metadata_ready,
|
|
|
|
+ recv_trailing_metadata_ready, elem,
|
|
|
|
+ grpc_schedule_on_exec_ctx);
|
|
GRPC_CALL_COMBINER_STOP(calld->call_combiner, "wait for initial metadata");
|
|
GRPC_CALL_COMBINER_STOP(calld->call_combiner, "wait for initial metadata");
|
|
}
|
|
}
|
|
err = grpc_error_add_child(GRPC_ERROR_REF(err), GRPC_ERROR_REF(calld->error));
|
|
err = grpc_error_add_child(GRPC_ERROR_REF(err), GRPC_ERROR_REF(calld->error));
|