Searched refs:core_server (Results 1 – 8 of 8) sorted by relevance
| /third_party/grpc/src/core/ext/transport/chttp2/server/insecure/ |
| D | server_chttp2_posix.cc | 44 grpc_core::Server* core_server = server->core_server.get(); in grpc_server_add_insecure_channel_from_fd() local
46 const grpc_channel_args* server_args = core_server->channel_args(); in grpc_server_add_insecure_channel_from_fd()
55 core_server->SetupTransport(transport, nullptr, server_args, nullptr); in grpc_server_add_insecure_channel_from_fd()
57 for (grpc_pollset* pollset : core_server->pollsets()) { in grpc_server_add_insecure_channel_from_fd()
|
| D | server_chttp2.cc | 45 server->core_server.get(), addr, in grpc_server_add_insecure_http2_port()
46 grpc_channel_args_copy(server->core_server->channel_args()), in grpc_server_add_insecure_http2_port()
|
| /third_party/grpc/src/core/ext/transport/chttp2/server/secure/ |
| D | server_secure_chttp2.cc | 96 if (server->core_server->config_fetcher() != nullptr) { in grpc_server_add_secure_http2_port()
99 args = grpc_channel_args_copy_and_add(server->core_server->channel_args(), in grpc_server_add_secure_http2_port()
114 args = grpc_channel_args_copy_and_add(server->core_server->channel_args(), in grpc_server_add_secure_http2_port()
119 err = grpc_core::Chttp2ServerAddPort(server->core_server.get(), addr, args, in grpc_server_add_secure_http2_port()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.cc | 1475 c_server->core_server = grpc_core::MakeOrphanable<grpc_core::Server>(args); in grpc_server_create()
1495 server->core_server->RegisterCompletionQueue(cq); in grpc_server_register_completion_queue()
1506 return server->core_server->RegisterMethod(method, host, payload_handling, in grpc_server_register_method()
1513 server->core_server->Start(); in grpc_server_start()
1522 server->core_server->ShutdownAndNotify(cq, tag); in grpc_server_shutdown_and_notify()
1529 server->core_server->CancelAllCalls(); in grpc_server_cancel_all_calls()
1554 return server->core_server->RequestCall(call, details, request_metadata, in grpc_server_request_call()
1579 return server->core_server->RequestRegisteredCall( in grpc_server_request_registered_call()
1590 server->core_server->set_config_fetcher( in grpc_server_set_config_fetcher()
|
| D | call.cc | 248 grpc_core::Server* core_server; member
383 call->final_op.server.core_server = args->server; in grpc_call_create()
485 } else if (call->final_op.server.core_server != nullptr) { in grpc_call_create()
487 call->final_op.server.core_server->channelz_node(); in grpc_call_create()
770 call->final_op.server.core_server->channelz_node(); in set_final_status()
|
| D | server.h | 404 grpc_core::OrphanablePtr<grpc_core::Server> core_server; member
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 1066 server_->core_server->SetRegisteredMethodAllocator( in RegisterService()
1107 server_->core_server->SetBatchMethodAllocator(cq->cq(), [this, cq] { in RegisterCallbackGenericService()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 1279 server->core_server->channel_args(), args_to_remove, in grpc_inproc_channel_create()
1296 grpc_error* error = server->core_server->SetupTransport( in grpc_inproc_channel_create()
|