Home
last modified time | relevance | path

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

1234

/third_party/grpc/src/core/lib/surface/
Dchannel.h33 grpc_channel* grpc_channel_create(const char* target,
42 void grpc_channel_destroy_internal(grpc_channel* channel);
44 grpc_channel* grpc_channel_create_with_builder(
57 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
62 grpc_channel_stack* grpc_channel_get_channel_stack(grpc_channel* channel);
65 grpc_channel* channel);
67 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel);
68 void grpc_channel_update_call_size_estimate(grpc_channel* channel, size_t size);
104 struct grpc_channel { struct
125 const grpc_channel* channel) { in grpc_channel_compression_options() argument
[all …]
Dchannel.cc59 grpc_channel* grpc_channel_create_with_builder( in grpc_channel_create_with_builder()
67 grpc_channel* channel; in grpc_channel_create_with_builder()
74 builder, sizeof(grpc_channel), 1, destroy_channel, nullptr, in grpc_channel_create_with_builder()
223 grpc_channel* grpc_channel_create(const char* target, in grpc_channel_create()
276 grpc_channel* channel = in grpc_channel_create()
284 size_t grpc_channel_get_call_size_estimate(grpc_channel* channel) { in grpc_channel_get_call_size_estimate()
298 void grpc_channel_update_call_size_estimate(grpc_channel* channel, in grpc_channel_update_call_size_estimate()
319 char* grpc_channel_get_target(grpc_channel* channel) { in grpc_channel_get_target()
324 void grpc_channel_get_info(grpc_channel* channel, in grpc_channel_get_info()
333 void grpc_channel_reset_connect_backoff(grpc_channel* channel) { in grpc_channel_reset_connect_backoff()
[all …]
Dserver.h187 void InitTransport(RefCountedPtr<Server> server, grpc_channel* channel,
192 grpc_channel* channel() const { return channel_; } in channel()
215 grpc_channel* channel_;
357 std::vector<grpc_channel*> GetChannelsLocked() const;
/third_party/grpc/include/grpc/
Dgrpc.h189 grpc_channel* channel, int try_to_connect);
195 grpc_channel* channel);
203 grpc_channel* channel, grpc_connectivity_state last_observed_state,
207 GRPCAPI int grpc_channel_support_connectivity_watcher(grpc_channel* channel);
217 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
224 GRPCAPI void* grpc_channel_register_call(grpc_channel* channel,
231 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
285 GRPCAPI char* grpc_channel_get_target(grpc_channel* channel);
291 GRPCAPI void grpc_channel_get_info(grpc_channel* channel,
297 GRPCAPI void grpc_channel_reset_connect_backoff(grpc_channel* channel);
[all …]
/third_party/grpc/test/core/surface/
Dnum_external_connectivity_watchers_test.cc37 grpc_channel* (*create_channel)(const char* addr);
42 static void channel_idle_start_watch(grpc_channel* channel, in channel_idle_start_watch()
54 static void channel_idle_poll_for_timeout(grpc_channel* channel, in channel_idle_poll_for_timeout()
76 grpc_channel* channel = fixture->create_channel(addr.c_str()); in run_timeouts_test()
127 grpc_channel* channel = fixture->create_channel(addr.c_str()); in run_channel_shutdown_before_timeout_test()
157 static grpc_channel* insecure_test_create_channel(const char* addr) { in insecure_test_create_channel()
166 static grpc_channel* secure_test_create_channel(const char* addr) { in secure_test_create_channel()
181 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()
Dsequential_connectivity_test.cc63 static grpc_channel* create_test_channel(const char* addr, in create_test_channel()
66 grpc_channel* channel = nullptr; in create_test_channel()
104 grpc_channel* channels[NUM_CONNECTIONS]; in run_test()
/third_party/grpc/include/grpcpp/
Dchannel.h33 struct grpc_channel;
41 const std::string& host, grpc_channel* c_channel,
78 const std::string& host, grpc_channel* c_channel,
83 Channel(const std::string& host, grpc_channel* c_channel,
108 grpc_channel* const c_channel_; // owned
Dchannel_impl.h33 struct grpc_channel;
41 const std::string& host, grpc_channel* c_channel,
80 const std::string& host, grpc_channel* c_channel,
85 Channel(const std::string& host, grpc_channel* c_channel,
112 grpc_channel* const c_channel_; // owned
/third_party/grpc/src/core/ext/transport/chttp2/client/insecure/
Dchannel_create.cc52 grpc_channel* CreateChannel(const char* target, const grpc_channel_args* args, in CreateChannel()
69 grpc_channel* channel = grpc_channel_create( in CreateChannel()
94 grpc_channel* grpc_insecure_channel_create(const char* target, in grpc_insecure_channel_create()
110 grpc_channel* channel = grpc_core::CreateChannel(target, new_args, &error); in grpc_insecure_channel_create()
Dchannel_create_posix.cc38 grpc_channel* grpc_insecure_channel_create_from_fd( in grpc_insecure_channel_create_from_fd()
60 grpc_channel* channel = in grpc_insecure_channel_create_from_fd()
84 grpc_channel* grpc_insecure_channel_create_from_fd( in grpc_insecure_channel_create_from_fd()
/third_party/grpc/src/cpp/client/
Dcreate_channel_internal.h28 struct grpc_channel;
33 const std::string& host, grpc_channel* c_channel,
Dcreate_channel_internal.cc23 struct grpc_channel;
28 const std::string& host, grpc_channel* c_channel, in CreateChannelInternal()
/third_party/grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc34 grpc_channel* channel, int try_to_connect) { in grpc_channel_check_connectivity_state()
75 grpc_channel* channel;
189 int grpc_channel_num_external_connectivity_watchers(grpc_channel* channel) { in grpc_channel_num_external_connectivity_watchers()
209 int grpc_channel_support_connectivity_watcher(grpc_channel* channel) { in grpc_channel_support_connectivity_watcher()
216 grpc_channel* channel, grpc_connectivity_state last_observed_state, in grpc_channel_watch_connectivity_state()
/third_party/grpc/src/core/ext/transport/chttp2/client/secure/
Dsecure_channel_create.cc130 grpc_channel* CreateChannel(const char* target, const grpc_channel_args* args, in CreateChannel()
147 grpc_channel* channel = grpc_channel_create( in CreateChannel()
172 grpc_channel* grpc_secure_channel_create(grpc_channel_credentials* creds, in grpc_secure_channel_create()
182 grpc_channel* channel = nullptr; in grpc_secure_channel_create()
/third_party/grpc/src/core/ext/transport/cronet/client/secure/
Dcronet_channel_create.cc41 GRPCAPI grpc_channel* grpc_cronet_secure_channel_create( in grpc_cronet_secure_channel_create()
61 grpc_channel* channel = in grpc_cronet_secure_channel_create()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb_channel_secure.cc67 grpc_channel* CreateGrpclbBalancerChannel(const char* target_uri, in CreateGrpclbBalancerChannel()
78 grpc_channel* channel = in CreateGrpclbBalancerChannel()
/third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/
DGRPCInsecureChannelFactory.m35 - (grpc_channel *)createChannelWithHost:(NSString *)host channelArgs:(NSDictionary *)args {
37 grpc_channel *unmanagedChannel =
/third_party/grpc/src/core/ext/filters/client_channel/xds/
Dxds_channel_secure.cc68 grpc_channel* CreateXdsChannel(const XdsBootstrap& bootstrap, in CreateXdsChannel()
100 grpc_channel* channel = grpc_secure_channel_create( in CreateXdsChannel()
Dxds_client.h167 ChannelState(RefCountedPtr<XdsClient> xds_client, grpc_channel* channel);
172 grpc_channel* channel() const { return channel_; } in channel()
196 grpc_channel* channel_;
/third_party/grpc/src/ruby/ext/grpc/
Drb_grpc_imports.generated.h137 typedef grpc_connectivity_state(*grpc_channel_check_connectivity_state_type)(grpc_channel* channel,…
140 typedef int(*grpc_channel_num_external_connectivity_watchers_type)(grpc_channel* channel);
143 typedef void(*grpc_channel_watch_connectivity_state_type)(grpc_channel* channel, grpc_connectivity_…
146 typedef int(*grpc_channel_support_connectivity_watcher_type)(grpc_channel* channel);
149 typedef grpc_call*(*grpc_channel_create_call_type)(grpc_channel* channel, grpc_call* parent_call, u…
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…
179 typedef void(*grpc_channel_reset_connect_backoff_type)(grpc_channel* channel);
[all …]
Drb_channel.c57 grpc_channel* channel;
100 grpc_channel* channel;
112 grpc_channel* channel);
215 grpc_channel* ch = NULL; in grpc_rb_channel_init()
516 grpc_channel* channel) { in bg_watched_channel_list_create_and_add()
831 grpc_channel* grpc_rb_get_wrapped_channel(VALUE v) { in grpc_rb_get_wrapped_channel()
/third_party/grpc/test/core/channel/
Dchannel_args_test.cc94 grpc_channel* c = in test_channel_create_with_args()
130 static bool channel_has_client_idle_filter(grpc_channel* c) { in channel_has_client_idle_filter()
158 grpc_channel* c = in test_channel_create_with_global_mutator()
/third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/GRPCCoreCronet/
DGRPCCronetChannelFactory.m51 - (grpc_channel *)createChannelWithHost:(NSString *)host channelArgs:(NSDictionary *)args {
53 grpc_channel *unmanagedChannel =
/third_party/grpc/test/core/end2end/fixtures/
Dh2_proxy.cc48 static grpc_channel* create_proxy_client(const char* target, in create_proxy_client()
57 grpc_channel* channel = in create_proxy_client()

1234