|
|
@ -152,6 +152,10 @@ static void next_recv_step(stream_obj *s, enum e_caller caller); |
|
|
|
static void set_pollset_do_nothing(grpc_exec_ctx *exec_ctx, grpc_transport *gt, |
|
|
|
static void set_pollset_do_nothing(grpc_exec_ctx *exec_ctx, grpc_transport *gt, |
|
|
|
grpc_stream *gs, grpc_pollset *pollset) {} |
|
|
|
grpc_stream *gs, grpc_pollset *pollset) {} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
static void set_pollset_set_do_nothing(grpc_exec_ctx *exec_ctx, |
|
|
|
|
|
|
|
grpc_transport *gt, grpc_stream *gs, |
|
|
|
|
|
|
|
grpc_pollset_set *pollset_set) {} |
|
|
|
|
|
|
|
|
|
|
|
static void enqueue_callbacks(grpc_closure *callback_list[]) { |
|
|
|
static void enqueue_callbacks(grpc_closure *callback_list[]) { |
|
|
|
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
|
|
|
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
|
|
|
if (callback_list[0]) { |
|
|
|
if (callback_list[0]) { |
|
|
@ -634,7 +638,13 @@ static void destroy_transport(grpc_exec_ctx *exec_ctx, grpc_transport *gt) { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
const grpc_transport_vtable grpc_cronet_vtable = { |
|
|
|
const grpc_transport_vtable grpc_cronet_vtable = {sizeof(stream_obj), |
|
|
|
sizeof(stream_obj), "cronet_http", init_stream, |
|
|
|
"cronet_http", |
|
|
|
set_pollset_do_nothing, perform_stream_op, NULL, |
|
|
|
init_stream, |
|
|
|
destroy_stream, destroy_transport, NULL}; |
|
|
|
set_pollset_do_nothing, |
|
|
|
|
|
|
|
set_pollset_set_do_nothing, |
|
|
|
|
|
|
|
perform_stream_op, |
|
|
|
|
|
|
|
NULL, |
|
|
|
|
|
|
|
destroy_stream, |
|
|
|
|
|
|
|
destroy_transport, |
|
|
|
|
|
|
|
NULL}; |
|
|
|