#include <grpc/support/port_platform.h>
#include <inttypes.h>
#include <stddef.h>
#include <algorithm>
#include <string>
#include "absl/types/optional.h"
#include <grpc/slice.h>
#include <grpc/slice_buffer.h>
#include <grpc/support/log.h>
#include "src/core/ext/transport/chttp2/transport/chttp2_transport.h"
#include "src/core/ext/transport/chttp2/transport/context_list.h"
#include "src/core/ext/transport/chttp2/transport/flow_control.h"
#include "src/core/ext/transport/chttp2/transport/frame.h"
#include "src/core/ext/transport/chttp2/transport/frame_data.h"
#include "src/core/ext/transport/chttp2/transport/frame_ping.h"
#include "src/core/ext/transport/chttp2/transport/frame_rst_stream.h"
#include "src/core/ext/transport/chttp2/transport/frame_settings.h"
#include "src/core/ext/transport/chttp2/transport/frame_window_update.h"
#include "src/core/ext/transport/chttp2/transport/hpack_encoder.h"
#include "src/core/ext/transport/chttp2/transport/http2_settings.h"
#include "src/core/ext/transport/chttp2/transport/internal.h"
#include "src/core/ext/transport/chttp2/transport/stream_map.h"
#include "src/core/lib/channel/channelz.h"
#include "src/core/lib/debug/stats.h"
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gprpp/debug_location.h"
#include "src/core/lib/gprpp/ref_counted.h"
#include "src/core/lib/gprpp/ref_counted_ptr.h"
#include "src/core/lib/gprpp/time.h"
#include "src/core/lib/iomgr/closure.h"
#include "src/core/lib/iomgr/endpoint.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/slice/slice.h"
#include "src/core/lib/slice/slice_internal.h"
#include "src/core/lib/transport/bdp_estimator.h"
#include "src/core/lib/transport/http2_errors.h"
#include "src/core/lib/transport/metadata_batch.h"
#include "src/core/lib/transport/transport.h"
Go to the source code of this file.
Functions | |
static void | add_to_write_list (grpc_chttp2_write_cb **list, grpc_chttp2_write_cb *cb) |
static void | finish_write_cb (grpc_chttp2_transport *t, grpc_chttp2_stream *s, grpc_chttp2_write_cb *cb, grpc_error_handle error) |
grpc_chttp2_begin_write_result | grpc_chttp2_begin_write (grpc_chttp2_transport *t) |
void | grpc_chttp2_end_write (grpc_chttp2_transport *t, grpc_error_handle error) |
static bool | is_default_initial_metadata (grpc_metadata_batch *initial_metadata) |
static void | maybe_initiate_ping (grpc_chttp2_transport *t) |
static void | report_stall (grpc_chttp2_transport *t, grpc_chttp2_stream *s, const char *staller) |
static uint32_t | target_write_size (grpc_chttp2_transport *) |
static bool | update_list (grpc_chttp2_transport *t, grpc_chttp2_stream *s, int64_t send_bytes, grpc_chttp2_write_cb **list, int64_t *ctr, grpc_error_handle error) |
|
static |
Definition at line 68 of file writing.cc.
|
static |
Definition at line 74 of file writing.cc.
grpc_chttp2_begin_write_result grpc_chttp2_begin_write | ( | grpc_chttp2_transport * | t | ) |
Definition at line 627 of file writing.cc.
void grpc_chttp2_end_write | ( | grpc_chttp2_transport * | t, |
grpc_error_handle | error | ||
) |
Definition at line 674 of file writing.cc.
|
static |
Definition at line 257 of file writing.cc.
|
static |
Definition at line 82 of file writing.cc.
|
static |
Definition at line 207 of file writing.cc.
|
static |
Definition at line 233 of file writing.cc.
|
static |
Definition at line 186 of file writing.cc.