Home
last modified time | relevance | path

Searched refs:grpc_channel (Results 1 – 25 of 84) sorted by relevance

1234

/external/grpc-grpc/src/core/lib/surface/
Dchannel.h29 grpc_channel* grpc_channel_create(const char* target,
34 grpc_channel* grpc_channel_create_with_builder(
47 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
52 grpc_channel_stack* grpc_channel_get_channel_stack(grpc_channel* channel);
55 grpc_channel* channel);
61 grpc_mdelem grpc_channel_get_reffed_status_elem(grpc_channel* channel,
64 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel);
65 void grpc_channel_update_call_size_estimate(grpc_channel* channel, size_t size);
68 void grpc_channel_internal_ref(grpc_channel* channel, const char* reason);
69 void grpc_channel_internal_unref(grpc_channel* channel, const char* reason);
[all …]
Dchannel.cc61 struct grpc_channel { struct
79 grpc_channel* grpc_channel_create_with_builder( in grpc_channel_create_with_builder() argument
85 grpc_channel* channel; in grpc_channel_create_with_builder()
92 builder, sizeof(grpc_channel), 1, destroy_channel, nullptr, in grpc_channel_create_with_builder()
212 grpc_channel* channel) { in grpc_channel_get_channelz_node()
216 grpc_channel* grpc_channel_create(const char* target, in grpc_channel_create()
236 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel) { in grpc_channel_get_call_size_estimate()
250 void grpc_channel_update_call_size_estimate(grpc_channel* channel, in grpc_channel_update_call_size_estimate()
271 char* grpc_channel_get_target(grpc_channel* channel) { in grpc_channel_get_target()
276 void grpc_channel_get_info(grpc_channel* channel, in grpc_channel_get_info()
[all …]
/external/grpc-grpc/include/grpc/
Dgrpc.h185 grpc_channel* channel, int try_to_connect);
191 grpc_channel* channel);
199 grpc_channel* channel, grpc_connectivity_state last_observed_state,
203 GRPCAPI int grpc_channel_support_connectivity_watcher(grpc_channel* channel);
213 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
219 GRPCAPI void grpc_channel_ping(grpc_channel* channel, grpc_completion_queue* cq,
223 GRPCAPI void* grpc_channel_register_call(grpc_channel* channel,
230 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
281 GRPCAPI char* grpc_channel_get_target(grpc_channel* channel);
287 GRPCAPI void grpc_channel_get_info(grpc_channel* channel,
[all …]
/external/grpc-grpc/test/core/surface/
Dnum_external_connectivity_watchers_test.cc34 grpc_channel* (*create_channel)(const char* addr);
39 static void channel_idle_start_watch(grpc_channel* channel, in channel_idle_start_watch()
51 static void channel_idle_poll_for_timeout(grpc_channel* channel, in channel_idle_poll_for_timeout()
75 grpc_channel* channel = fixture->create_channel(addr); in run_timeouts_test()
129 grpc_channel* channel = fixture->create_channel(addr); in run_channel_shutdown_before_timeout_test()
160 static grpc_channel* insecure_test_create_channel(const char* addr) { in insecure_test_create_channel()
169 static grpc_channel* secure_test_create_channel(const char* addr) { in secure_test_create_channel()
178 grpc_channel* channel = in secure_test_create_channel()
Dsequential_connectivity_test.cc35 grpc_channel* (*create_channel)(const char* addr);
74 grpc_channel* channels[NUM_CONNECTIONS]; in run_test()
126 static grpc_channel* insecure_test_create_channel(const char* addr) { in insecure_test_create_channel()
145 static grpc_channel* secure_test_create_channel(const char* addr) { in secure_test_create_channel()
154 grpc_channel* channel = in secure_test_create_channel()
Dsecure_channel_create_test.cc35 grpc_channel* chan = in test_unknown_scheme_target()
53 grpc_channel* chan = in test_security_connector_already_in_arg()
63 grpc_channel* chan = in test_null_creds()
/external/grpc-grpc/include/grpcpp/
Dchannel.h30 struct grpc_channel;
65 const grpc::string& host, grpc_channel* c_channel);
66 Channel(const grpc::string& host, grpc_channel* c_channel);
84 grpc_channel* const c_channel_; // owned
/external/grpc-grpc/src/core/ext/transport/chttp2/client/insecure/
Dchannel_create.cc54 static grpc_channel* client_channel_factory_create_channel( in client_channel_factory_create_channel()
69 grpc_channel* channel = in client_channel_factory_create_channel()
87 grpc_channel* grpc_insecure_channel_create(const char* target, in grpc_insecure_channel_create()
100 grpc_channel* channel = client_channel_factory_create_channel( in grpc_insecure_channel_create()
Dchannel_create_posix.cc38 grpc_channel* grpc_insecure_channel_create_from_fd( in grpc_insecure_channel_create_from_fd()
58 grpc_channel* channel = grpc_channel_create( in grpc_insecure_channel_create_from_fd()
73 grpc_channel* grpc_insecure_channel_create_from_fd( in grpc_insecure_channel_create_from_fd()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc34 grpc_channel* channel, int try_to_connect) { in grpc_channel_check_connectivity_state()
74 grpc_channel* channel;
174 int grpc_channel_num_external_connectivity_watchers(grpc_channel* channel) { in grpc_channel_num_external_connectivity_watchers()
194 int grpc_channel_support_connectivity_watcher(grpc_channel* channel) { in grpc_channel_support_connectivity_watcher()
201 grpc_channel* channel, grpc_connectivity_state last_observed_state, in grpc_channel_watch_connectivity_state()
Dclient_channel_factory.h53 grpc_channel* (*create_client_channel)(grpc_client_channel_factory* factory,
67 grpc_channel* grpc_client_channel_factory_create_channel(
Dclient_channel_channelz.h46 grpc_channel* channel, size_t channel_tracer_max_nodes,
49 ClientChannelNode(grpc_channel* channel, size_t channel_tracer_max_nodes,
/external/grpc-grpc/src/core/lib/channel/
Dchannelz.h118 grpc_channel* channel, size_t channel_tracer_max_nodes,
121 ChannelNode(grpc_channel* channel, size_t channel_tracer_max_nodes,
166 grpc_channel* channel_ = nullptr;
209 typedef RefCountedPtr<ChannelNode> (*ChannelNodeCreationFunc)(grpc_channel*,
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_grpc_imports.generated.h134 typedef grpc_connectivity_state(*grpc_channel_check_connectivity_state_type)(grpc_channel* channel,…
137 typedef int(*grpc_channel_num_external_connectivity_watchers_type)(grpc_channel* channel);
140 typedef void(*grpc_channel_watch_connectivity_state_type)(grpc_channel* channel, grpc_connectivity_…
143 typedef int(*grpc_channel_support_connectivity_watcher_type)(grpc_channel* channel);
146 typedef grpc_call*(*grpc_channel_create_call_type)(grpc_channel* channel, grpc_call* parent_call, u…
149 typedef void(*grpc_channel_ping_type)(grpc_channel* channel, grpc_completion_queue* cq, void* tag, …
152 typedef void*(*grpc_channel_register_call_type)(grpc_channel* channel, const char* method, const ch…
155 typedef grpc_call*(*grpc_channel_create_registered_call_type)(grpc_channel* channel, grpc_call* par…
173 typedef char*(*grpc_channel_get_target_type)(grpc_channel* channel);
176 typedef void(*grpc_channel_get_info_type)(grpc_channel* channel, const grpc_channel_info* channel_i…
[all …]
Drb_channel.c57 grpc_channel* channel;
100 grpc_channel* channel;
112 grpc_channel* channel);
211 grpc_channel* ch = NULL; in grpc_rb_channel_init()
513 grpc_channel* channel) { in bg_watched_channel_list_create_and_add()
827 grpc_channel* grpc_rb_get_wrapped_channel(VALUE v) { in grpc_rb_get_wrapped_channel()
/external/grpc-grpc/src/core/ext/transport/chttp2/client/secure/
Dsecure_channel_create.cc167 static grpc_channel* client_channel_factory_create_channel( in client_channel_factory_create_channel()
182 grpc_channel* channel = in client_channel_factory_create_channel()
200 grpc_channel* grpc_secure_channel_create(grpc_channel_credentials* creds, in grpc_secure_channel_create()
210 grpc_channel* channel = nullptr; in grpc_secure_channel_create()
/external/grpc-grpc/src/cpp/client/
Dcreate_channel_internal.h26 struct grpc_channel;
32 grpc_channel* c_channel);
Dcreate_channel_internal.cc23 struct grpc_channel;
28 grpc_channel* c_channel) { in CreateChannelInternal()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
DBUILD100 name = "grpc_channel",
101 srcs = ["grpc_channel.cc"],
102 hdrs = ["grpc_channel.h"],
151 ":grpc_channel",
282 ":grpc_channel",
398 ":grpc_channel",
429 ":grpc_channel",
490 ":grpc_channel",
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
DBUILD28 "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
48 "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
/external/grpc-grpc/test/core/channel/
Dchannelz_test.cc141 grpc_channel* channel() { return channel_; } in channel()
144 grpc_channel* channel_;
240 grpc_channel* channel = in TEST()
318 grpc_channel* internal_channel = in TEST()
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dgrpc.pxi149 ctypedef struct grpc_channel:
357 grpc_channel *grpc_insecure_channel_create(const char *target,
361 grpc_channel *channel, grpc_call *parent_call, uint32_t propagation_mask,
365 grpc_channel *channel, int try_to_connect) nogil
367 grpc_channel *channel, grpc_connectivity_state last_observed_state,
369 char *grpc_channel_get_target(grpc_channel *channel) nogil
370 void grpc_channel_destroy(grpc_channel *channel) nogil
497 grpc_channel *grpc_secure_channel_create(
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc82 BaseChannelFixture(grpc_channel* channel) : channel_(channel) {} in BaseChannelFixture()
85 grpc_channel* channel() const { return channel_; } in channel()
88 grpc_channel* const channel_;
161 grpc_channel* channel; in BM_LameChannelCallCreateCore()
235 grpc_channel* channel; in BM_LameChannelCallCreateCoreSeparateBatch()
330 static grpc_channel* CreateClientChannel(grpc_client_channel_factory* factory, in CreateClientChannel()
719 grpc_channel* channel() const { return channel_; } in channel()
724 grpc_channel* channel_;
/external/grpc-grpc/test/core/end2end/fixtures/
Dh2_proxy.cc49 static grpc_channel* create_proxy_client(const char* target, in create_proxy_client()
58 grpc_channel* channel = in create_proxy_client()
/external/grpc-grpc/test/core/end2end/
Dh2_ssl_session_reuse_test.cc65 grpc_channel* client_create(char* server_addr, grpc_ssl_session_cache* cache) { in client_create()
81 grpc_channel* client = grpc_secure_channel_create(client_creds, server_addr, in client_create()
97 grpc_channel* client = client_create(server_addr, cache); in do_round_trip()

1234