Searched refs:fetching_send_message (Results 1 – 3 of 3) sorted by relevance
342 s_->fetching_send_message == nullptr); in FlushCompressedBytes()426 if (!t_->is_client && s_->fetching_send_message == nullptr && in FlushInitialMetadata()517 if (s_->fetching_send_message != nullptr) return; in FlushTrailingMetadata()
745 GPR_ASSERT(s->fetching_send_message == nullptr); in destroy_stream_locked()1286 if (s->fetching_send_message == nullptr) { in continue_fetching_send_locked()1291 if (s->fetched_send_message_length == s->fetching_send_message->length()) { in continue_fetching_send_locked()1308 s->fetching_send_message->flags() & GRPC_WRITE_THROUGH in continue_fetching_send_locked()1314 s->fetching_send_message.reset(); in continue_fetching_send_locked()1316 } else if (s->fetching_send_message->Next(UINT32_MAX, in continue_fetching_send_locked()1318 grpc_error* error = s->fetching_send_message->Pull(&s->fetching_slice); in continue_fetching_send_locked()1320 s->fetching_send_message.reset(); in continue_fetching_send_locked()1333 error = s->fetching_send_message->Pull(&s->fetching_slice); in complete_fetch_locked()1340 s->fetching_send_message.reset(); in complete_fetch_locked()[all …]
502 grpc_core::OrphanablePtr<grpc_core::ByteStream> fetching_send_message; member