grpc_compression_options compression_options,
RefCountedPtr<Arena> arena,
RefCountedPtr<UnstartedCallDestination> destination)
- : Call(false, deadline, std::move(arena)),
+ : Call(/*is_client=*/true, deadline, std::move(arena)),
DualRefCounted("ClientCall"),
cq_(cq),
call_destination_(std::move(destination)),
const grpc_op& send_initial_metadata_op) {
GRPC_LATENT_SEE_SCOPE("ClientCall::StartCall");
auto cur_state = call_state_.load(std::memory_order_acquire);
+ // TODO(akshitpatel): [PH2][P3]: Might need to invoke
+ // PrepareApplicationMetadata here.
CToMetadata(send_initial_metadata_op.data.send_initial_metadata.metadata,
send_initial_metadata_op.data.send_initial_metadata.count,
send_initial_metadata_.get());
PrepareOutgoingInitialMetadata(send_initial_metadata_op,
*send_initial_metadata_);
+ send_initial_metadata_->Set(
+ WaitForReady(),
+ WaitForReady::ValueType{
+ (send_initial_metadata_op.flags &
+ GRPC_INITIAL_METADATA_WAIT_FOR_READY) != 0,
+ (send_initial_metadata_op.flags &
+ GRPC_INITIAL_METADATA_WAIT_FOR_READY_EXPLICITLY_SET) != 0});
auto call = MakeCallPair(std::move(send_initial_metadata_), arena()->Ref());
started_call_initiator_ = std::move(call.initiator);
Party::WakeupHold wakeup_hold{started_call_initiator_.party()};