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