Searched refs:flow_controlled_buffer (Results 1 – 4 of 4) sorted by relevance
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | writing.cc | 151 t->peer_string, t, s->id, staller, s->flow_controlled_buffer.length, in report_stall() 341 s_->flow_controlled_buffer.length == 0 && in FlushCompressedBytes() 346 s_->stream_compression_ctx, &s_->flow_controlled_buffer, in FlushCompressedBytes() 375 s_->uncompressed_data_size = s_->flow_controlled_buffer.length; in CompressMoreBytes() 377 s_->stream_compression_ctx, &s_->flow_controlled_buffer, in CompressMoreBytes() 427 s_->flow_controlled_buffer.length == 0 && in FlushInitialMetadata() 472 if (s_->flow_controlled_buffer.length == 0 && in FlushData() 490 while ((s_->flow_controlled_buffer.length > 0 || in FlushData() 505 if (s_->flow_controlled_buffer.length > 0 || in FlushData() 518 if (s_->flow_controlled_buffer.length != 0) return; in FlushTrailingMetadata() [all …]
|
D | chttp2_transport.cc | 683 grpc_slice_buffer_init(&s->flow_controlled_buffer); in init_stream() 753 grpc_slice_buffer_destroy_internal(&s->flow_controlled_buffer); in destroy_stream_locked() 1269 s->flow_controlled_buffer.length > t->write_buffer_size)) { in maybe_become_writable_due_to_send_msg() 1279 grpc_slice_buffer_add(&s->flow_controlled_buffer, s->fetching_slice); in add_fetched_slice_locked() 1517 &s->flow_controlled_buffer, GRPC_HEADER_SIZE_IN_BYTES); in perform_stream_op_locked() 1530 static_cast<int64_t>(s->flow_controlled_buffer.length) + in perform_stream_op_locked()
|
D | internal.h | 587 grpc_slice_buffer flow_controlled_buffer; member
|
/external/grpc-grpc/test/cpp/microbenchmarks/ |
D | bm_fullstack_trickle.cc | 183 client_stream ? client_stream->flow_controlled_buffer.length : 0, in Log() 184 server_stream ? server_stream->flow_controlled_buffer.length : 0); in Log()
|