GRPC Core
9.0.0
|
Transport op: a set of operations to perform on a transport as a whole. More...
#include <transport.h>
Data Fields | |
grpc_closure * | on_consumed = nullptr |
Called when processing of this op is done. More... | |
grpc_core::OrphanablePtr< grpc_core::ConnectivityStateWatcherInterface > | start_connectivity_watch |
connectivity monitoring - set connectivity_state to NULL to unsubscribe More... | |
grpc_connectivity_state | start_connectivity_watch_state = GRPC_CHANNEL_IDLE |
grpc_core::ConnectivityStateWatcherInterface * | stop_connectivity_watch |
grpc_error * | disconnect_with_error = nullptr |
should the transport be disconnected Error contract: the transport that gets this op must cause disconnect_with_error to be unref'ed after processing it More... | |
grpc_error * | goaway_error = nullptr |
what should the goaway contain? Error contract: the transport that gets this op must cause goaway_error to be unref'ed after processing it More... | |
bool | set_accept_stream = false |
set the callback for accepting new streams; this is a permanent callback, unlike the other one-shot closures. More... | |
void(* | set_accept_stream_fn )(void *user_data, grpc_transport *transport, const void *server_data) = nullptr |
void * | set_accept_stream_user_data = nullptr |
grpc_pollset * | bind_pollset = nullptr |
add this transport to a pollset More... | |
grpc_pollset_set * | bind_pollset_set = nullptr |
add this transport to a pollset_set More... | |
struct { | |
grpc_closure * on_initiate = nullptr | |
Ping may be delayed by the transport, on_initiate callback will be called when the ping is actually being sent. More... | |
grpc_closure * on_ack = nullptr | |
Called when the ping ack is received. More... | |
} | send_ping |
send a ping, if either on_initiate or on_ack is not NULL More... | |
bool | reset_connect_backoff = false |
grpc_handler_private_op_data | handler_private |
Transport op: a set of operations to perform on a transport as a whole.
grpc_pollset* grpc_transport_op::bind_pollset = nullptr |
add this transport to a pollset
grpc_pollset_set* grpc_transport_op::bind_pollset_set = nullptr |
add this transport to a pollset_set
grpc_error* grpc_transport_op::disconnect_with_error = nullptr |
should the transport be disconnected Error contract: the transport that gets this op must cause disconnect_with_error to be unref'ed after processing it
grpc_error* grpc_transport_op::goaway_error = nullptr |
what should the goaway contain? Error contract: the transport that gets this op must cause goaway_error to be unref'ed after processing it
grpc_handler_private_op_data grpc_transport_op::handler_private |
grpc_closure* grpc_transport_op::on_ack = nullptr |
Called when the ping ack is received.
grpc_closure* grpc_transport_op::on_consumed = nullptr |
Called when processing of this op is done.
grpc_closure* grpc_transport_op::on_initiate = nullptr |
Ping may be delayed by the transport, on_initiate callback will be called when the ping is actually being sent.
bool grpc_transport_op::reset_connect_backoff = false |
struct { ... } grpc_transport_op::send_ping |
send a ping, if either on_initiate or on_ack is not NULL
bool grpc_transport_op::set_accept_stream = false |
set the callback for accepting new streams; this is a permanent callback, unlike the other one-shot closures.
If true, the callback is set to set_accept_stream_fn, with its user_data argument set to set_accept_stream_user_data
void(* grpc_transport_op::set_accept_stream_fn) (void *user_data, grpc_transport *transport, const void *server_data) = nullptr |
void* grpc_transport_op::set_accept_stream_user_data = nullptr |
grpc_core::OrphanablePtr<grpc_core::ConnectivityStateWatcherInterface> grpc_transport_op::start_connectivity_watch |
connectivity monitoring - set connectivity_state to NULL to unsubscribe
grpc_connectivity_state grpc_transport_op::start_connectivity_watch_state = GRPC_CHANNEL_IDLE |
grpc_core::ConnectivityStateWatcherInterface* grpc_transport_op::stop_connectivity_watch |