| boundPort | esi::cosim::RpcServer::Impl | private |
| channelById | esi::cosim::RpcServer::Impl | private |
| ChannelDirection typedef | esi::cosim::RpcServer::Impl | private |
| channelsMutex | esi::cosim::RpcServer::Impl | private |
| compressedManifest | esi::cosim::RpcServer::Impl | private |
| ctxt | esi::cosim::RpcServer::Impl | private |
| esiVersion | esi::cosim::RpcServer::Impl | private |
| faultStash | esi::cosim::RpcServer::Impl | private |
| findChannel(ix::WebSocket &ws, uint64_t requestId, uint64_t channelId, ChannelDirection dir) | esi::cosim::RpcServer::Impl | private |
| getContext() | esi::cosim::RpcServer::Impl | inline |
| getPort() const | esi::cosim::RpcServer::Impl | inline |
| getSession() | esi::cosim::RpcServer::Impl | inlineprivate |
| handleBinaryFrame(uint64_t generation, const std::string &data) | esi::cosim::RpcServer::Impl | private |
| handleControlFrame(ix::WebSocket &ws, const std::string &text) | esi::cosim::RpcServer::Impl | private |
| handleEvent(uint64_t generation, const json &frame) | esi::cosim::RpcServer::Impl | private |
| handleHello(ix::WebSocket &ws, uint64_t requestId, const json ¶ms) | esi::cosim::RpcServer::Impl | private |
| handleSubscribe(ix::WebSocket &ws, uint64_t requestId, const json ¶ms) | esi::cosim::RpcServer::Impl | private |
| handleUnsubscribe(ix::WebSocket &ws, uint64_t requestId, const json ¶ms) | esi::cosim::RpcServer::Impl | private |
| idByName | esi::cosim::RpcServer::Impl | private |
| Impl(Context &ctxt, int port) | esi::cosim::RpcServer::Impl | |
| logRefusedFrame(uint64_t channelId, size_t size) | esi::cosim::RpcServer::Impl | |
| manifestMutex | esi::cosim::RpcServer::Impl | private |
| manifestReady | esi::cosim::RpcServer::Impl | private |
| manifestReadyCV | esi::cosim::RpcServer::Impl | private |
| messageConsumed(ReadChannelPort &port) | esi::cosim::RpcServer::Impl | |
| nextChannelId | esi::cosim::RpcServer::Impl | private |
| nextSessionGeneration | esi::cosim::RpcServer::Impl | private |
| onClientMessage(const std::weak_ptr< ix::WebSocket > &wsWeak, ix::WebSocket &ws, const ix::WebSocketMessagePtr &msg) | esi::cosim::RpcServer::Impl | private |
| onClose(ix::WebSocket &ws) | esi::cosim::RpcServer::Impl | private |
| onOpen(const std::weak_ptr< ix::WebSocket > &wsWeak) | esi::cosim::RpcServer::Impl | private |
| readPorts | esi::cosim::RpcServer::Impl | private |
| readyIds | esi::cosim::RpcServer::Impl | |
| registerReadPort(const std::string &name, const std::string &type) | esi::cosim::RpcServer::Impl | |
| registerWritePort(const std::string &name, const std::string &type) | esi::cosim::RpcServer::Impl | |
| retireSession(uint64_t generation) | esi::cosim::RpcServer::Impl | private |
| sendConsumedEvent(const std::unordered_set< uint64_t > &ids) | esi::cosim::RpcServer::Impl | private |
| sendError(ix::WebSocket &ws, uint64_t requestId, const std::string &code, const std::string &message) | esi::cosim::RpcServer::Impl | private |
| sendResult(ix::WebSocket &ws, uint64_t requestId, const json &result) | esi::cosim::RpcServer::Impl | private |
| server | esi::cosim::RpcServer::Impl | private |
| session | esi::cosim::RpcServer::Impl | private |
| sessionFor(const ix::WebSocket &ws) | esi::cosim::RpcServer::Impl | inlineprivate |
| sessionMutex | esi::cosim::RpcServer::Impl | private |
| setManifest(int esiVersion, const std::vector< uint8_t > &compressedManifest) | esi::cosim::RpcServer::Impl | |
| stop(uint32_t timeoutMS) | esi::cosim::RpcServer::Impl | |
| transportLoop() | esi::cosim::RpcServer::Impl | private |
| transportThread | esi::cosim::RpcServer::Impl | private |
| writePorts | esi::cosim::RpcServer::Impl | private |
| ~Impl() | esi::cosim::RpcServer::Impl | |