GRPC Core  18.0.0
Functions | Variables
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"   
)