stream_lists.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/ext/transport/chttp2/transport/chttp2_transport.h"
#include "src/core/ext/transport/chttp2/transport/internal.h"
#include <grpc/support/log.h>

Functions
bool	grpc_chttp2_list_add_writable_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
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. More...
bool	grpc_chttp2_list_remove_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_writing_stream (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_pop_waiting_for_concurrency (grpc_chttp2_transport *t, grpc_chttp2_stream **s)
void	grpc_chttp2_list_remove_waiting_for_concurrency (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
void	grpc_chttp2_list_add_stalled_by_transport (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_pop_stalled_by_transport (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_add_stalled_by_stream (grpc_chttp2_transport *t, grpc_chttp2_stream *s)
bool	grpc_chttp2_list_pop_stalled_by_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)

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
	)

grpc_chttp2_list_add_stalled_by_transport()

void grpc_chttp2_list_add_stalled_by_transport	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_add_waiting_for_concurrency()

void grpc_chttp2_list_add_waiting_for_concurrency	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_add_writable_stream()

bool grpc_chttp2_list_add_writable_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_add_writing_stream()

bool grpc_chttp2_list_add_writing_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_have_writing_streams()

bool grpc_chttp2_list_have_writing_streams

(

grpc_chttp2_transport *

t

)

grpc_chttp2_list_pop_stalled_by_stream()

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

grpc_chttp2_list_pop_stalled_by_transport()

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

grpc_chttp2_list_pop_waiting_for_concurrency()

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

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.

grpc_chttp2_list_pop_writing_stream()

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

grpc_chttp2_list_remove_stalled_by_stream()

bool grpc_chttp2_list_remove_stalled_by_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_remove_stalled_by_transport()

void grpc_chttp2_list_remove_stalled_by_transport	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_remove_waiting_for_concurrency()

void grpc_chttp2_list_remove_waiting_for_concurrency	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

grpc_chttp2_list_remove_writable_stream()

bool grpc_chttp2_list_remove_writable_stream	(	grpc_chttp2_transport *	t,
		grpc_chttp2_stream *	s
	)

Variable Documentation

grpc_trace_http2_stream_state

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