Home
last modified time | relevance | path

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

12345

/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/tensorflow/tensorflow/core/common_runtime/eager/
Dcontext_distributed_manager.cc129 tensorflow::GrpcServer* grpc_server = in ListRemoteWorkers() local
131 if (grpc_server == nullptr) { in ListRemoteWorkers()
135 grpc_server->master_env()->worker_cache->ListWorkers(remote_workers); in ListRemoteWorkers()
424 tensorflow::GrpcServer* grpc_server; in UpdateContextWithServerDef() local
432 grpc_server = dynamic_cast<tensorflow::GrpcServer*>(new_server.get()); in UpdateContextWithServerDef()
440 grpc_server = dynamic_cast<tensorflow::GrpcServer*>(context->GetServer()); in UpdateContextWithServerDef()
441 LOG_AND_RETURN_IF_ERROR(grpc_server->UpdateServerDef(server_def)); in UpdateContextWithServerDef()
443 ListRemoteWorkers(grpc_server, worker_name, &remote_workers)); in UpdateContextWithServerDef()
454 grpc_server->AddMasterEagerContextToEagerService(context_id, context)); in UpdateContextWithServerDef()
459 grpc_server->master_env()->worker_cache->GetEagerClientCache( in UpdateContextWithServerDef()
[all …]
/external/rust/crates/grpcio-sys/grpc/include/grpc/
Dgrpc.h361 grpc_server* server, grpc_call** call, grpc_call_details* details,
382 grpc_server* server, const char* method, const char* host,
390 grpc_server* server, void* registered_method, grpc_call** call,
403 GRPCAPI grpc_server* grpc_server_create(const grpc_channel_args* args,
410 GRPCAPI void grpc_server_register_completion_queue(grpc_server* server,
426 grpc_server* server, grpc_server_config_fetcher* config_fetcher);
431 GRPCAPI int grpc_server_add_insecure_http2_port(grpc_server* server,
435 GRPCAPI void grpc_server_start(grpc_server* server);
444 GRPCAPI void grpc_server_shutdown_and_notify(grpc_server* server,
450 GRPCAPI void grpc_server_cancel_all_calls(grpc_server* server);
[all …]
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/
Dgrpc.h361 grpc_server* server, grpc_call** call, grpc_call_details* details,
382 grpc_server* server, const char* method, const char* host,
390 grpc_server* server, void* registered_method, grpc_call** call,
403 GRPCAPI grpc_server* grpc_server_create(const grpc_channel_args* args,
410 GRPCAPI void grpc_server_register_completion_queue(grpc_server* server,
426 grpc_server* server, grpc_server_config_fetcher* config_fetcher);
431 GRPCAPI int grpc_server_add_insecure_http2_port(grpc_server* server,
435 GRPCAPI void grpc_server_start(grpc_server* server);
444 GRPCAPI void grpc_server_shutdown_and_notify(grpc_server* server,
450 GRPCAPI void grpc_server_cancel_all_calls(grpc_server* server);
[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/rust/crates/grpcio-sys/grpc/include/grpcpp/
Dserver.h44 struct grpc_server;
99 grpc_server* c_server();
197 grpc_server* server() override { return server_; } in server()
341 grpc_server* server_;
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/
Dserver.h44 struct grpc_server;
99 grpc_server* c_server();
197 grpc_server* server() override { return server_; } in server()
341 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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/insecure/
Dserver_chttp2_posix.cc39 void grpc_server_add_insecure_channel_from_fd(grpc_server* server, in grpc_server_add_insecure_channel_from_fd()
71 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/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/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/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/security/
Dserver_credentials.h30 struct grpc_server;
94 virtual int AddPortToServer(const std::string& addr, grpc_server* server) = 0;
/external/grpc-grpc/test/core/bad_client/tests/
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()
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()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/security/
Dserver_credentials.h30 struct grpc_server;
94 virtual int AddPortToServer(const std::string& addr, grpc_server* server) = 0;
/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()
/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 …]
/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()

12345