Home
last modified time | relevance | path

Searched refs:grpc_transport (Results 1 – 25 of 36) sorted by relevance

12

/external/grpc-grpc/src/core/lib/transport/
Dtransport_impl.h35 int (*init_stream)(grpc_transport* self, grpc_stream* stream,
40 void (*set_pollset)(grpc_transport* self, grpc_stream* stream,
44 void (*set_pollset_set)(grpc_transport* self, grpc_stream* stream,
48 void (*perform_stream_op)(grpc_transport* self, grpc_stream* stream,
52 void (*perform_op)(grpc_transport* self, grpc_transport_op* op);
55 void (*destroy_stream)(grpc_transport* self, grpc_stream* stream,
59 void (*destroy)(grpc_transport* self);
62 grpc_endpoint* (*get_endpoint)(grpc_transport* self);
66 struct grpc_transport { struct
Dtransport.h44 typedef struct grpc_transport grpc_transport; typedef
270 void (*set_accept_stream_fn)(void* user_data, grpc_transport* transport,
297 size_t grpc_transport_stream_size(grpc_transport* transport);
309 int grpc_transport_init_stream(grpc_transport* transport, grpc_stream* stream,
313 void grpc_transport_set_pops(grpc_transport* transport, grpc_stream* stream,
326 void grpc_transport_destroy_stream(grpc_transport* transport,
347 void grpc_transport_perform_stream_op(grpc_transport* transport,
351 void grpc_transport_perform_op(grpc_transport* transport,
357 void grpc_transport_ping(grpc_transport* transport, grpc_closure* cb);
360 void grpc_transport_goaway(grpc_transport* transport, grpc_status_code status,
[all …]
Dtransport.cc151 size_t grpc_transport_stream_size(grpc_transport* transport) {
155 void grpc_transport_destroy(grpc_transport* transport) {
159 int grpc_transport_init_stream(grpc_transport* transport, grpc_stream* stream,
166 void grpc_transport_perform_stream_op(grpc_transport* transport,
172 void grpc_transport_perform_op(grpc_transport* transport,
177 void grpc_transport_set_pops(grpc_transport* transport, grpc_stream* stream,
192 void grpc_transport_destroy_stream(grpc_transport* transport,
198 grpc_endpoint* grpc_transport_get_endpoint(grpc_transport* transport) {
/external/grpc-grpc/test/core/end2end/fixtures/
Dh2_sockpair.cc44 static void server_setup_transport(void* ts, grpc_transport* transport) { in server_setup_transport()
58 static void client_setup_transport(void* ts, grpc_transport* transport) { in client_setup_transport()
91 grpc_transport* transport; in chttp2_init_client_socketpair()
105 grpc_transport* transport; in chttp2_init_server_socketpair()
Dh2_sockpair+trace.cc50 static void server_setup_transport(void* ts, grpc_transport* transport) { in server_setup_transport()
64 static void client_setup_transport(void* ts, grpc_transport* transport) { in client_setup_transport()
96 grpc_transport* transport; in chttp2_init_client_socketpair()
110 grpc_transport* transport; in chttp2_init_server_socketpair()
Dh2_sockpair_1byte.cc44 static void server_setup_transport(void* ts, grpc_transport* transport) { in server_setup_transport()
58 static void client_setup_transport(void* ts, grpc_transport* transport) { in client_setup_transport()
102 grpc_transport* transport; in chttp2_init_client_socketpair()
116 grpc_transport* transport; in chttp2_init_server_socketpair()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.h34 grpc_transport* grpc_create_chttp2_transport(
42 grpc_transport* transport, grpc_slice_buffer* read_buffer,
/external/grpc-grpc/src/core/ext/transport/cronet/client/secure/
Dcronet_channel_create.cc35 grpc_transport base; // must be first element in this structure
49 grpc_transport* ct = in grpc_cronet_secure_channel_create()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc55 grpc_transport base;
60 void (*accept_stream_cb)(void* user_data, grpc_transport* transport,
224 static int init_stream(grpc_transport* gt, grpc_stream* gs, in init_stream()
905 static void perform_stream_op(grpc_transport* gt, grpc_stream* gs, in perform_stream_op()
1106 static void perform_transport_op(grpc_transport* gt, grpc_transport_op* op) { in perform_transport_op()
1139 static void destroy_stream(grpc_transport* gt, grpc_stream* gs, in destroy_stream()
1147 static void destroy_transport(grpc_transport* gt) { in destroy_transport()
1161 static void set_pollset(grpc_transport* gt, grpc_stream* gs, in set_pollset()
1166 static void set_pollset_set(grpc_transport* gt, grpc_stream* gs, in set_pollset_set()
1171 static grpc_endpoint* get_endpoint(grpc_transport* t) { return nullptr; } in get_endpoint()
[all …]
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc38 grpc_transport* transport;
219 cd->transport = static_cast<grpc_transport*>(t); in bind_transport()
228 grpc_transport_stream_size(static_cast<grpc_transport*>(t)); in bind_transport()
234 grpc_transport* t = grpc_channel_stack_builder_get_transport(builder); in grpc_add_connected_filter()
Dchannel_stack_builder.h51 grpc_channel_stack_builder* builder, grpc_transport* transport);
54 grpc_transport* grpc_channel_stack_builder_get_transport(
Dchannel_stack_builder.cc42 grpc_transport* transport;
161 grpc_channel_stack_builder* builder, grpc_transport* transport) { in grpc_channel_stack_builder_set_transport()
166 grpc_transport* grpc_channel_stack_builder_get_transport( in grpc_channel_stack_builder_get_transport()
Dchannel_stack.h60 grpc_transport* optional_transport;
209 const grpc_channel_args* args, grpc_transport* optional_transport,
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc416 int InitStream(grpc_transport* self, grpc_stream* stream, in InitStream()
423 void SetPollset(grpc_transport* self, grpc_stream* stream, in SetPollset()
427 void SetPollsetSet(grpc_transport* self, grpc_stream* stream, in SetPollsetSet()
431 void PerformStreamOp(grpc_transport* self, grpc_stream* stream, in PerformStreamOp()
437 void PerformOp(grpc_transport* self, grpc_transport_op* op) {} in PerformOp()
440 void DestroyStream(grpc_transport* self, grpc_stream* stream, in DestroyStream()
444 void Destroy(grpc_transport* self) {} in Destroy()
447 grpc_endpoint* GetEndpoint(grpc_transport* self) { return nullptr; } in GetEndpoint()
455 static grpc_transport dummy_transport = {&dummy_transport_vtable};
Dfullstack_fixtures.h250 grpc_transport* client_transport_;
251 grpc_transport* server_transport_;
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.h26 grpc_transport* grpc_create_cronet_transport(void* engine, const char* target,
Dcronet_transport.cc104 grpc_transport base; /* must be first element in this structure */
1357 static int init_stream(grpc_transport* gt, grpc_stream* gs, in init_stream()
1390 static void set_pollset_do_nothing(grpc_transport* gt, grpc_stream* gs, in set_pollset_do_nothing()
1393 static void set_pollset_set_do_nothing(grpc_transport* gt, grpc_stream* gs, in set_pollset_set_do_nothing()
1396 static void perform_stream_op(grpc_transport* gt, grpc_stream* gs, in perform_stream_op()
1426 static void destroy_stream(grpc_transport* gt, grpc_stream* gs, in destroy_stream()
1436 static void destroy_transport(grpc_transport* gt) {} in destroy_transport()
1438 static grpc_endpoint* get_endpoint(grpc_transport* gt) { return nullptr; } in get_endpoint()
1440 static void perform_op(grpc_transport* gt, grpc_transport_op* op) {} in perform_op()
1454 grpc_transport* grpc_create_cronet_transport(void* engine, const char* target, in grpc_create_cronet_transport()
/external/grpc-grpc/src/core/lib/surface/
Dserver.h46 void grpc_server_setup_transport(grpc_server* server, grpc_transport* transport,
Dchannel.h32 grpc_transport* optional_transport);
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dconnector.h46 grpc_transport* transport;
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc91 grpc_transport* transport = grpc_create_chttp2_transport( in EndpointPairFixture()
114 grpc_transport* transport = in EndpointPairFixture()
/external/grpc-grpc/src/core/ext/transport/chttp2/server/insecure/
Dserver_chttp2_posix.cc53 grpc_transport* transport = grpc_create_chttp2_transport( in grpc_server_add_insecure_channel_from_fd()
/external/grpc-grpc/src/core/ext/transport/chttp2/client/insecure/
Dchannel_create_posix.cc55 grpc_transport* transport = in grpc_insecure_channel_create_from_fd()
/external/grpc-grpc/src/core/ext/filters/http/
Dhttp_filters_plugin.cc41 grpc_transport* t = grpc_channel_stack_builder_get_transport(builder); in is_building_http_like_transport()
/external/grpc-grpc/test/core/bad_client/
Dbad_client.cc65 static void server_setup_transport(void* ts, grpc_transport* transport) { in server_setup_transport()
190 grpc_transport* transport; in grpc_run_bad_client_test()

12