Searched refs:fetching_send_message (Results 1 – 6 of 6) sorted by relevance
344 s_->fetching_send_message == nullptr && in FlushUncompressedBytes()362 s_->fetching_send_message == nullptr); in FlushCompressedBytes()449 if (!t_->is_client && s_->fetching_send_message == nullptr && in FlushInitialMetadata()555 if (s_->fetching_send_message != nullptr) return; in FlushTrailingMetadata()
672 GPR_ASSERT(fetching_send_message == nullptr); in ~grpc_chttp2_stream()1250 if (s->fetching_send_message == nullptr) { in continue_fetching_send_locked()1255 if (s->fetched_send_message_length == s->fetching_send_message->length()) { in continue_fetching_send_locked()1272 s->fetching_send_message->flags() & GRPC_WRITE_THROUGH in continue_fetching_send_locked()1278 s->fetching_send_message.reset(); in continue_fetching_send_locked()1280 } else if (s->fetching_send_message->Next( in continue_fetching_send_locked()1284 grpc_error* error = s->fetching_send_message->Pull(&s->fetching_slice); in continue_fetching_send_locked()1286 s->fetching_send_message.reset(); in continue_fetching_send_locked()1306 error = s->fetching_send_message->Pull(&s->fetching_slice); in complete_fetch_locked()1313 s->fetching_send_message.reset(); in complete_fetch_locked()[all …]
545 grpc_core::OrphanablePtr<grpc_core::ByteStream> fetching_send_message; member
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