Home
last modified time | relevance | path

Searched refs:flow_controlled_buffer (Results 1 – 7 of 7) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc168 s->flow_controlled_buffer.length, in report_stall()
342 max_outgoing(), s_->flow_controlled_buffer.length); in FlushUncompressedBytes()
343 is_last_frame_ = send_bytes == s_->flow_controlled_buffer.length && in FlushUncompressedBytes()
347 grpc_chttp2_encode_data(s_->id, &s_->flow_controlled_buffer, send_bytes, in FlushUncompressedBytes()
361 s_->flow_controlled_buffer.length == 0 && in FlushCompressedBytes()
366 s_->stream_compression_ctx, &s_->flow_controlled_buffer, in FlushCompressedBytes()
398 s_->uncompressed_data_size = s_->flow_controlled_buffer.length; in CompressMoreBytes()
400 s_->stream_compression_ctx, &s_->flow_controlled_buffer, in CompressMoreBytes()
450 s_->flow_controlled_buffer.length == 0 && in FlushInitialMetadata()
502 if (s_->flow_controlled_buffer.length == 0 && in FlushData()
[all …]
Dchttp2_transport.cc635 grpc_slice_buffer_init(&flow_controlled_buffer);
677 grpc_slice_buffer_destroy_internal(&flow_controlled_buffer); in ~grpc_chttp2_stream()
1233 s->flow_controlled_buffer.length > t->write_buffer_size)) { in maybe_become_writable_due_to_send_msg()
1243 grpc_slice_buffer_add(&s->flow_controlled_buffer, s->fetching_slice); in add_fetched_slice_locked()
1464 &s->flow_controlled_buffer, GRPC_HEADER_SIZE_IN_BYTES); in perform_stream_op_locked()
1477 static_cast<int64_t>(s->flow_controlled_buffer.length) + in perform_stream_op_locked()
Dinternal.h632 grpc_slice_buffer flow_controlled_buffer; member
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc151 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 …]
Dchttp2_transport.cc683 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()
Dinternal.h587 grpc_slice_buffer flow_controlled_buffer; member
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc183 client_stream ? client_stream->flow_controlled_buffer.length : 0, in Log()
184 server_stream ? server_stream->flow_controlled_buffer.length : 0); in Log()