stream_lists.cc File Reference

#include <grpc/support/port_platform.h>
#include <grpc/support/log.h>
#include "src/core/ext/transport/chttp2/transport/frame.h"
#include "src/core/ext/transport/chttp2/transport/internal.h"
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gprpp/bitset.h"

Include dependency graph for stream_lists.cc:

Go to the source code of this file.

Functions
void	grpc_chttp2_list_add_stalled_by_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
void	grpc_chttp2_list_add_stalled_by_transport (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
void	grpc_chttp2_list_add_waiting_for_concurrency (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_add_writable_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_add_writing_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_have_writing_streams (grpc_chttp2_transport *t)
bool	grpc_chttp2_list_pop_stalled_by_stream (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
bool	grpc_chttp2_list_pop_stalled_by_transport (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
bool	grpc_chttp2_list_pop_waiting_for_concurrency (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
bool	grpc_chttp2_list_pop_writable_stream (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
bool	grpc_chttp2_list_pop_writing_stream (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
bool	grpc_chttp2_list_remove_stalled_by_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
void	grpc_chttp2_list_remove_stalled_by_transport (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
void	grpc_chttp2_list_remove_waiting_for_concurrency (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_remove_writable_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
static bool	stream_list_add (grpc_chttp2_transport *t, grpc_chttp2_stream *s, grpc_chttp2_stream_list_id id)
static void	stream_list_add_tail (grpc_chttp2_transport *t, grpc_chttp2_stream *s, grpc_chttp2_stream_list_id id)
static bool	stream_list_empty (grpc_chttp2_transport *t, grpc_chttp2_stream_list_id id)
static const char *	stream_list_id_string (grpc_chttp2_stream_list_id id)
static bool	stream_list_maybe_remove (grpc_chttp2_transport *t, grpc_chttp2_stream *s, grpc_chttp2_stream_list_id id)
static bool	stream_list_pop (grpc_chttp2_transport *t, grpc_chttp2_stream **stream, grpc_chttp2_stream_list_id id)
static void	stream_list_remove (grpc_chttp2_transport *t, grpc_chttp2_stream *s, grpc_chttp2_stream_list_id id)

Variables
grpc_core::TraceFlag	grpc_trace_http2_stream_state (false, "http2_stream_state")

Function Documentation

grpc_chttp2_list_add_stalled_by_stream()

void grpc_chttp2_list_add_stalled_by_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 203 of file stream_lists.cc.

grpc_chttp2_list_add_stalled_by_transport()

void grpc_chttp2_list_add_stalled_by_transport	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 188 of file stream_lists.cc.

grpc_chttp2_list_add_waiting_for_concurrency()

void grpc_chttp2_list_add_waiting_for_concurrency	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 173 of file stream_lists.cc.

grpc_chttp2_list_add_writable_stream()

bool grpc_chttp2_list_add_writable_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 143 of file stream_lists.cc.

grpc_chttp2_list_add_writing_stream()

bool grpc_chttp2_list_add_writing_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 159 of file stream_lists.cc.

grpc_chttp2_list_have_writing_streams()

bool grpc_chttp2_list_have_writing_streams

(

grpc_chttp2_transport *

t

)

Definition at line 164 of file stream_lists.cc.

grpc_chttp2_list_pop_stalled_by_stream()

bool grpc_chttp2_list_pop_stalled_by_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream **	s
	)

Definition at line 208 of file stream_lists.cc.

grpc_chttp2_list_pop_stalled_by_transport()

bool grpc_chttp2_list_pop_stalled_by_transport	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream **	s
	)

Definition at line 193 of file stream_lists.cc.

grpc_chttp2_list_pop_waiting_for_concurrency()

bool grpc_chttp2_list_pop_waiting_for_concurrency	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream **	s
	)

Definition at line 178 of file stream_lists.cc.

grpc_chttp2_list_pop_writable_stream()

bool grpc_chttp2_list_pop_writable_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream **	s
	)

Get a writable stream returns non-zero if there was a stream available

Definition at line 149 of file stream_lists.cc.

grpc_chttp2_list_pop_writing_stream()

bool grpc_chttp2_list_pop_writing_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream **	s
	)

Definition at line 168 of file stream_lists.cc.

grpc_chttp2_list_remove_stalled_by_stream()

bool grpc_chttp2_list_remove_stalled_by_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 213 of file stream_lists.cc.

grpc_chttp2_list_remove_stalled_by_transport()

void grpc_chttp2_list_remove_stalled_by_transport	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 198 of file stream_lists.cc.

grpc_chttp2_list_remove_waiting_for_concurrency()

void grpc_chttp2_list_remove_waiting_for_concurrency	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 183 of file stream_lists.cc.

grpc_chttp2_list_remove_writable_stream()

bool grpc_chttp2_list_remove_writable_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Definition at line 154 of file stream_lists.cc.

stream_list_add()

static bool stream_list_add ( grpc_chttp2_transport *  t, grpc_chttp2_stream *  s, grpc_chttp2_stream_list_id  id  )

static

Definition at line 132 of file stream_lists.cc.

stream_list_add_tail()

static void stream_list_add_tail ( grpc_chttp2_transport *  t, grpc_chttp2_stream *  s, grpc_chttp2_stream_list_id  id  )

static

Definition at line 111 of file stream_lists.cc.

stream_list_empty()

static bool stream_list_empty ( grpc_chttp2_transport *  t, grpc_chttp2_stream_list_id  id  )

static

Definition at line 50 of file stream_lists.cc.

stream_list_id_string()

static const char* stream_list_id_string ( grpc_chttp2_stream_list_id  id )

static

Definition at line 28 of file stream_lists.cc.

stream_list_maybe_remove()

static bool stream_list_maybe_remove ( grpc_chttp2_transport *  t, grpc_chttp2_stream *  s, grpc_chttp2_stream_list_id  id  )

static

Definition at line 100 of file stream_lists.cc.

stream_list_pop()

static bool stream_list_pop ( grpc_chttp2_transport *  t, grpc_chttp2_stream **  stream, grpc_chttp2_stream_list_id  id  )

static

Definition at line 55 of file stream_lists.cc.

stream_list_remove()

static void stream_list_remove ( grpc_chttp2_transport *  t, grpc_chttp2_stream *  s, grpc_chttp2_stream_list_id  id  )

static

Definition at line 79 of file stream_lists.cc.

Variable Documentation

grpc_trace_http2_stream_state

grpc_core::TraceFlag grpc_trace_http2_stream_state(false, "http2_stream_state")