Home
last modified time | relevance | path

Searched refs:fetching_send_message (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc342 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()
Dchttp2_transport.cc745 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 …]
Dinternal.h502 grpc_core::OrphanablePtr<grpc_core::ByteStream> fetching_send_message; member