51 RpcServer::RpcServer(std::unique_ptr<RpcTransportCtx> ctx) : mCtx(std::move(ctx)) {}  in RpcServer()  function in android::RpcServer
52 RpcServer::~RpcServer() {  in ~RpcServer()
57 sp<RpcServer> RpcServer::make(std::unique_ptr<RpcTransportCtxFactory> rpcTransportCtxFactory) {  in make()
63     return sp<RpcServer>::make(std::move(ctx));  in make()
66 status_t RpcServer::setupUnixDomainSocketBootstrapServer(unique_fd bootstrapFd) {  in setupUnixDomainSocketBootstrapServer()
67     return setupExternalServer(std::move(bootstrapFd), &RpcServer::recvmsgSocketConnection);  in setupUnixDomainSocketBootstrapServer()
70 status_t RpcServer::setupUnixDomainServer(const char* path) {  in setupUnixDomainServer()
74 status_t RpcServer::setupVsockServer(unsigned int bindCid, unsigned int port) {  in setupVsockServer()
78 status_t RpcServer::setupInetServer(const char* address, unsigned int port,  in setupInetServer()
117 void RpcServer::setMaxThreads(size_t threads) {  in setMaxThreads()
123 size_t RpcServer::getMaxThreads() {  in getMaxThreads()
127 bool RpcServer::setProtocolVersion(uint32_t version) {  in setProtocolVersion()
136 void RpcServer::setSupportedFileDescriptorTransportModes(  in setSupportedFileDescriptorTransportModes()
144 void RpcServer::setRootObject(const sp<IBinder>& binder) {  in setRootObject()
150 void RpcServer::setRootObjectWeak(const wp<IBinder>& binder) {  in setRootObjectWeak()
156 void RpcServer::setPerSessionRootObject(  in setPerSessionRootObject()
164 void RpcServer::setConnectionFilter(std::function<bool(const void*, size_t)>&& filter) {  in setConnectionFilter()
170 void RpcServer::setServerSocketModifier(std::function<void(borrowed_fd)>&& modifier) {  in setServerSocketModifier()
176 sp<IBinder> RpcServer::getRootObject() {  in getRootObject()
184 std::vector<uint8_t> RpcServer::getCertificate(RpcCertificateFormat format) {  in getCertificate()
189 static void joinRpcServer(sp<RpcServer>&& thiz) {  in joinRpcServer()
193 void RpcServer::start() {  in start()
197             std::make_unique<RpcMaybeThread>(&joinRpcServer, sp<RpcServer>::fromExisting(this));  in start()
201 status_t RpcServer::acceptSocketConnection(const RpcServer& server, RpcTransportFd* out) {  in acceptSocketConnection()
214 status_t RpcServer::recvmsgSocketConnection(const RpcServer& server, RpcTransportFd* out) {  in recvmsgSocketConnection()
240 void RpcServer::join() {  in join()
282                     RpcMaybeThread(&RpcServer::establishConnection,  in join()
283                                    sp<RpcServer>::fromExisting(this), std::move(clientSocket), addr,  in join()
304 bool RpcServer::shutdown() {  in shutdown()
355 std::vector<sp<RpcSession>> RpcServer::listSessions() {  in listSessions()
365 size_t RpcServer::numUninitializedSessions() {  in numUninitializedSessions()
370 void RpcServer::establishConnection(  in establishConnection()
371         sp<RpcServer>&& server, RpcTransportFd clientFd, std::array<uint8_t, kRpcAddressSize> addr,  in establishConnection()
524                                        sp<RpcServer::EventListener>::fromExisting(  in establishConnection()
525                                                static_cast<RpcServer::EventListener*>(  in establishConnection()
561 status_t RpcServer::setupSocketServer(const RpcSocketAddress& addr) {  in setupSocketServer()
600 status_t RpcServer::setupRawSocketServer(unique_fd socket_fd) {  in setupRawSocketServer()
619 void RpcServer::onSessionAllIncomingThreadsEnded(const sp<RpcSession>& session) {  in onSessionAllIncomingThreadsEnded()
633 void RpcServer::onSessionIncomingThreadEnded() {  in onSessionIncomingThreadEnded()
637 bool RpcServer::hasServer() {  in hasServer()
642 unique_fd RpcServer::releaseServer() {  in releaseServer()
647 status_t RpcServer::setupExternalServer(  in setupExternalServer()
648         unique_fd serverFd, std::function<status_t(const RpcServer&, RpcTransportFd*)>&& acceptFn) {  in setupExternalServer()  argument
659 status_t RpcServer::setupExternalServer(unique_fd serverFd) {  in setupExternalServer()
660     return setupExternalServer(std::move(serverFd), &RpcServer::acceptSocketConnection);  in setupExternalServer()
663 bool RpcServer::hasActiveRequests() {  in hasActiveRequests()