Home
last modified time | relevance | path

Searched refs:grpc_server (Results 1 – 25 of 74) sorted by relevance

123

/external/grpc-grpc/src/core/lib/surface/
Dserver.h37 void grpc_server_add_listener(grpc_server* server, void* listener,
38 void (*start)(grpc_server* server, void* arg,
41 void (*destroy)(grpc_server* server, void* arg,
46 void grpc_server_setup_transport(grpc_server* server, grpc_transport* transport,
51 grpc_server* server);
53 const grpc_channel_args* grpc_server_get_channel_args(grpc_server* server);
55 int grpc_server_has_open_connections(grpc_server* server);
59 void grpc_server_get_pollsets(grpc_server* server, grpc_pollset*** pollsets,
Dserver.cc53 void (*start)(grpc_server* server, void* arg, grpc_pollset** pollsets,
55 void (*destroy)(grpc_server* server, void* arg, grpc_closure* closure);
69 grpc_server* server;
95 grpc_server* server;
162 grpc_server* server;
184 struct grpc_server { struct
233 static void fail_call(grpc_server* server, size_t cq_idx, requested_call* rc, argument
237 static void maybe_finish_shutdown(grpc_server* server);
244 static void channel_broadcaster_init(grpc_server* s, channel_broadcaster* cb) { in channel_broadcaster_init()
312 static void request_matcher_init(request_matcher* rm, grpc_server* server) { in request_matcher_init()
[all …]
/external/grpc-grpc/include/grpc/
Dgrpc.h357 grpc_server* server, grpc_call** call, grpc_call_details* details,
378 grpc_server* server, const char* method, const char* host,
386 grpc_server* server, void* registered_method, grpc_call** call,
399 GRPCAPI grpc_server* grpc_server_create(const grpc_channel_args* args,
406 GRPCAPI void grpc_server_register_completion_queue(grpc_server* server,
413 GRPCAPI int grpc_server_add_insecure_http2_port(grpc_server* server,
417 GRPCAPI void grpc_server_start(grpc_server* server);
426 GRPCAPI void grpc_server_shutdown_and_notify(grpc_server* server,
432 GRPCAPI void grpc_server_cancel_all_calls(grpc_server* server);
438 GRPCAPI void grpc_server_destroy(grpc_server* server);
/external/grpc-grpc/test/core/surface/
Dsequential_connectivity_test.cc34 void (*add_server_port)(grpc_server* server, const char* addr);
41 grpc_server* server;
62 grpc_server* server = grpc_server_create(nullptr, nullptr); in run_test()
122 static void insecure_test_add_port(grpc_server* server, const char* addr) { in insecure_test_add_port()
136 static void secure_test_add_port(grpc_server* server, const char* addr) { in secure_test_add_port()
Dserver_test.cc32 grpc_server* server = grpc_server_create(nullptr, nullptr); in test_register_method_fail()
60 grpc_server* server = grpc_server_create(nullptr, nullptr); in test_request_call_on_no_server_cq()
82 grpc_server* server1 = grpc_server_create(&args, nullptr); in test_bind_server_twice()
83 grpc_server* server2 = grpc_server_create(&args, nullptr); in test_bind_server_twice()
113 grpc_server* server = grpc_server_create(nullptr, nullptr); in test_bind_server_to_addr()
Dserver_chttp2_test.cc34 grpc_server* server = grpc_server_create(&args, nullptr); in test_unparsable_target()
52 grpc_server* server = grpc_server_create(&args, nullptr); in test_add_same_port_twice()
/external/grpc-grpc/include/grpcpp/
Dserver.h39 struct grpc_server;
92 grpc_server* c_server();
162 grpc_server* server() override { return server_; }; in server()
220 grpc_server* server_;
/external/grpc-grpc/src/core/ext/transport/chttp2/server/insecure/
Dserver_chttp2_posix.cc38 void grpc_server_add_insecure_channel_from_fd(grpc_server* server, in grpc_server_add_insecure_channel_from_fd()
70 void grpc_server_add_insecure_channel_from_fd(grpc_server* server, in grpc_server_add_insecure_channel_from_fd()
/external/grpc-grpc/test/core/bad_client/
Dbad_client.h32 typedef void (*grpc_bad_client_server_side_validator)(grpc_server* server,
93 void server_verifier_request_call(grpc_server* server,
/external/grpc-grpc/include/grpcpp/security/
Dserver_credentials.h29 struct grpc_server;
53 grpc_server* server) = 0;
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dgrpc.pxi153 ctypedef struct grpc_server:
372 grpc_server *grpc_server_create(
375 grpc_server *server, grpc_call **call, grpc_call_details *details,
379 void grpc_server_register_completion_queue(grpc_server *server,
383 grpc_server *server, const char *addr) nogil
384 void grpc_server_start(grpc_server *server) nogil
386 grpc_server *server, grpc_completion_queue *cq, void *tag) nogil
387 void grpc_server_cancel_all_calls(grpc_server *server) nogil
388 void grpc_server_destroy(grpc_server *server) nogil
507 int grpc_server_add_secure_http2_port(grpc_server *server, const char *addr,
/external/grpc-grpc/test/core/end2end/
Dh2_ssl_session_reuse_test.cc48 grpc_server* server_create(grpc_completion_queue* cq, char* server_addr) { in server_create()
55 grpc_server* server = grpc_server_create(nullptr, nullptr); in server_create()
94 void do_round_trip(grpc_completion_queue* cq, grpc_server* server, in do_round_trip()
224 grpc_server* server = server_create(cq, server_addr); in TEST()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_grpc_imports.generated.h203 typedef grpc_call_error(*grpc_server_request_call_type)(grpc_server* server, grpc_call** call, grpc…
206 typedef void*(*grpc_server_register_method_type)(grpc_server* server, const char* method, const cha…
209 typedef grpc_call_error(*grpc_server_request_registered_call_type)(grpc_server* server, void* regis…
212 typedef grpc_server*(*grpc_server_create_type)(const grpc_channel_args* args, void* reserved);
215 typedef void(*grpc_server_register_completion_queue_type)(grpc_server* server, grpc_completion_queu…
218 typedef int(*grpc_server_add_insecure_http2_port_type)(grpc_server* server, const char* addr);
221 typedef void(*grpc_server_start_type)(grpc_server* server);
224 typedef void(*grpc_server_shutdown_and_notify_type)(grpc_server* server, grpc_completion_queue* cq,…
227 typedef void(*grpc_server_cancel_all_calls_type)(grpc_server* server);
230 typedef void(*grpc_server_destroy_type)(grpc_server* server);
[all …]
Drb_server.c47 grpc_server* wrapped;
141 grpc_server* srv = NULL; in grpc_rb_server_init()
364 grpc_server* grpc_rb_get_wrapped_server(VALUE v) { in grpc_rb_get_wrapped_server()
Drb_server.h30 grpc_server* grpc_rb_get_wrapped_server(VALUE v);
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc48 grpc_server* server;
207 static void server_start_listener(grpc_server* server, void* arg, in server_start_listener()
241 static void server_destroy_listener(grpc_server* server, void* arg, in server_destroy_listener()
253 grpc_error* grpc_chttp2_server_add_port(grpc_server* server, const char* addr, in grpc_chttp2_server_add_port()
Dchttp2_server.h30 grpc_error* grpc_chttp2_server_add_port(grpc_server* server, const char* addr,
/external/grpc-grpc/test/core/bad_client/tests/
Dserver_registered_method.cc43 static void verifier_succeeds(grpc_server* server, grpc_completion_queue* cq, in verifier_succeeds()
69 static void verifier_fails(grpc_server* server, grpc_completion_queue* cq, in verifier_fails()
Dsimple_request.cc90 static void verifier(grpc_server* server, grpc_completion_queue* cq, in verifier()
116 static void failure_verifier(grpc_server* server, grpc_completion_queue* cq, in failure_verifier()
/external/grpc-grpc/test/core/end2end/fixtures/
Dh2_proxy.cc42 static grpc_server* create_proxy_server(const char* port, in create_proxy_server()
44 grpc_server* s = grpc_server_create(server_args, nullptr); in create_proxy_server()
/external/tensorflow/tensorflow/c/eager/
Dc_api.cc179 tensorflow::GrpcServer* grpc_server = in UpdateTFE_ContextWithServerDef() local
181 if (grpc_server == nullptr) { in UpdateTFE_ContextWithServerDef()
186 LOG_AND_RETURN_IF_ERROR(grpc_server->Start()); in UpdateTFE_ContextWithServerDef()
191 grpc_server->master_env()->worker_cache->ListWorkers(&remote_workers); in UpdateTFE_ContextWithServerDef()
198 remote_workers, grpc_server->master_env()->worker_cache, in UpdateTFE_ContextWithServerDef()
202 grpc_server->channel_cache(); in UpdateTFE_ContextWithServerDef()
213 grpc_server->worker_env()->rendezvous_mgr->Find(rendezvous_id); in UpdateTFE_ContextWithServerDef()
216 TF_RETURN_IF_ERROR(grpc_server->worker_env()->session_mgr->CreateSession( in UpdateTFE_ContextWithServerDef()
221 grpc_server->worker_env()->session_mgr->WorkerSessionForSession( in UpdateTFE_ContextWithServerDef()
227 auto* device_mgr = grpc_server->worker_env()->device_mgr; in UpdateTFE_ContextWithServerDef()
/external/grpc-grpc/src/csharp/ext/
Dgrpc_csharp_ext.c863 GPR_EXPORT grpc_server* GPR_CALLTYPE
869 grpc_server* server, grpc_completion_queue* cq) { in grpcsharp_server_register_completion_queue()
874 grpc_server* server, const char* addr) { in grpcsharp_server_add_insecure_http2_port()
878 GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_start(grpc_server* server) { in grpcsharp_server_start()
883 grpc_server* server, grpc_completion_queue* cq, in grpcsharp_server_shutdown_and_notify_callback()
889 grpcsharp_server_cancel_all_calls(grpc_server* server) { in grpcsharp_server_cancel_all_calls()
893 GPR_EXPORT void GPR_CALLTYPE grpcsharp_server_destroy(grpc_server* server) { in grpcsharp_server_destroy()
898 grpcsharp_server_request_call(grpc_server* server, grpc_completion_queue* cq, in grpcsharp_server_request_call()
998 grpc_server* server, const char* addr, grpc_server_credentials* creds) { in grpcsharp_server_add_secure_http2_port()
/external/grpc-grpc/include/grpc/impl/codegen/
Dgrpc_types.h65 typedef struct grpc_server grpc_server; typedef
/external/grpc-grpc/test/core/bad_ssl/
Dserver_common.h25 void bad_ssl_run(grpc_server* server);
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.h26 grpc_channel* grpc_inproc_channel_create(grpc_server* server,

123