RpcServer.cpp File Reference

#include "esi/backends/RpcServer.h"
#include "esi/Context.h"
#include "esi/Utils.h"
#include "esi/backends/RpcClient.h"
#include "RpcWire.h"
#include <ixwebsocket/IXBase64.h>
#include <ixwebsocket/IXNetSystem.h>
#include <ixwebsocket/IXWebSocket.h>
#include <ixwebsocket/IXWebSocketServer.h>
#include <nlohmann/json.hpp>
#include <algorithm>
#include <atomic>
#include <cassert>
#include <condition_variable>
#include <cstdint>
#include <cstdio>
#include <cstring>
#include <deque>
#include <format>
#include <map>
#include <mutex>
#include <optional>
#include <string>
#include <thread>
#include <unordered_map>
#include <unordered_set>
#include <utility>
#include <vector>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>

Include dependency graph for RpcServer.cpp:

Go to the source code of this file.

Classes
class	esi::cosim::RpcServer::Impl
struct	esi::cosim::RpcServer::Impl::ChannelInfo
struct	esi::cosim::RpcServer::Impl::ClientSession

Typedefs
using	Impl = esi::cosim::RpcServer::Impl

Functions
static bool	parseConsumedEvent (const json &frame, std::vector< std::pair< uint64_t, uint64_t > > &out, std::string &err)
	Parse the channels list of a consumed event into (channel_id, count) pairs.

Typedef Documentation

Impl

using Impl = esi::cosim::RpcServer::Impl

Definition at line 285 of file RpcServer.cpp.

Function Documentation

parseConsumedEvent()

bool parseConsumedEvent ( const json & frame, std::vector< std::pair< uint64_t, uint64_t > > & out, std::string & err )

static

Parse the channels list of a consumed event into (channel_id, count) pairs.

Returns false (with err set) on a malformed event.

Definition at line 1040 of file RpcServer.cpp.

Referenced by esi::cosim::RpcServer::Impl::handleEvent().