|
|
@ -652,8 +652,8 @@ retry: |
|
|
|
fail_locked(exec_ctx, calld, GRPC_ERROR_REF(op->cancel_error)); |
|
|
|
fail_locked(exec_ctx, calld, GRPC_ERROR_REF(op->cancel_error)); |
|
|
|
break; |
|
|
|
break; |
|
|
|
case GRPC_SUBCHANNEL_CALL_HOLDER_PICKING_SUBCHANNEL: |
|
|
|
case GRPC_SUBCHANNEL_CALL_HOLDER_PICKING_SUBCHANNEL: |
|
|
|
pick_subchannel(exec_ctx, elem, NULL, 0, |
|
|
|
pick_subchannel(exec_ctx, elem, NULL, 0, &calld->connected_subchannel, |
|
|
|
&calld->connected_subchannel, NULL); |
|
|
|
NULL); |
|
|
|
break; |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
gpr_mu_unlock(&calld->mu); |
|
|
|
gpr_mu_unlock(&calld->mu); |
|
|
@ -670,10 +670,9 @@ retry: |
|
|
|
calld->creation_phase = GRPC_SUBCHANNEL_CALL_HOLDER_PICKING_SUBCHANNEL; |
|
|
|
calld->creation_phase = GRPC_SUBCHANNEL_CALL_HOLDER_PICKING_SUBCHANNEL; |
|
|
|
grpc_closure_init(&calld->next_step, subchannel_ready, calld); |
|
|
|
grpc_closure_init(&calld->next_step, subchannel_ready, calld); |
|
|
|
GRPC_CALL_STACK_REF(calld->owning_call, "pick_subchannel"); |
|
|
|
GRPC_CALL_STACK_REF(calld->owning_call, "pick_subchannel"); |
|
|
|
if (pick_subchannel( |
|
|
|
if (pick_subchannel(exec_ctx, elem, op->send_initial_metadata, |
|
|
|
exec_ctx, elem, op->send_initial_metadata, |
|
|
|
op->send_initial_metadata_flags, |
|
|
|
op->send_initial_metadata_flags, &calld->connected_subchannel, |
|
|
|
&calld->connected_subchannel, &calld->next_step)) { |
|
|
|
&calld->next_step)) { |
|
|
|
|
|
|
|
calld->creation_phase = GRPC_SUBCHANNEL_CALL_HOLDER_NOT_CREATING; |
|
|
|
calld->creation_phase = GRPC_SUBCHANNEL_CALL_HOLDER_NOT_CREATING; |
|
|
|
GRPC_CALL_STACK_UNREF(exec_ctx, calld->owning_call, "pick_subchannel"); |
|
|
|
GRPC_CALL_STACK_UNREF(exec_ctx, calld->owning_call, "pick_subchannel"); |
|
|
|
} |
|
|
|
} |
|
|
|