|
|
@ -2378,11 +2378,12 @@ void ServerCallData::WakeInsideCombiner(Flusher* flusher) { |
|
|
|
GRPC_TRACE_LOG(channel, INFO) |
|
|
|
GRPC_TRACE_LOG(channel, INFO) |
|
|
|
<< LogTag() << ": WakeInsideCombiner: metadata_push done"; |
|
|
|
<< LogTag() << ": WakeInsideCombiner: metadata_push done"; |
|
|
|
send_initial_metadata_->metadata_push_.reset(); |
|
|
|
send_initial_metadata_->metadata_push_.reset(); |
|
|
|
} else |
|
|
|
} else { |
|
|
|
GRPC_TRACE_LOG(channel, INFO) |
|
|
|
GRPC_TRACE_LOG(channel, INFO) |
|
|
|
<< LogTag() << ": WakeInsideCombiner: metadata_push pending"; |
|
|
|
<< LogTag() << ": WakeInsideCombiner: metadata_push pending"; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
if (send_message() != nullptr) { |
|
|
|
if (send_message() != nullptr) { |
|
|
|
if (send_trailing_state_ == |
|
|
|
if (send_trailing_state_ == |
|
|
|
SendTrailingState::kQueuedButHaventClosedSends) { |
|
|
|
SendTrailingState::kQueuedButHaventClosedSends) { |
|
|
|