8 #ifndef NT_RPCSERVER_H_ 9 #define NT_RPCSERVER_H_ 11 #include "llvm/DenseMap.h" 13 #include "CallbackManager.h" 15 #include "IRpcServer.h" 22 typedef std::pair<unsigned int, unsigned int> RpcIdPair;
27 IRpcServer::SendResponseFunc send_response_)
28 :
RpcAnswer{entry_, call_, name_, params_, conn_},
29 send_response{send_response_} {}
31 IRpcServer::SendResponseFunc send_response;
38 :
public CallbackThread<RpcServerThread, RpcAnswer, RpcListenerData,
42 : m_inst(inst), m_logger(logger) {}
45 return !data.
name.empty() && data.send_response;
49 unsigned int local_id =
Handle{data->
entry}.GetIndex();
50 unsigned int call_uid =
Handle{data->
call}.GetIndex();
51 RpcIdPair lookup_uid{local_id, call_uid};
52 m_response_map.insert(std::make_pair(lookup_uid, data->send_response));
55 void DoCallback(std::function<
void(
const RpcAnswer&
call)> callback,
57 DEBUG4(
"rpc calling " << data.
name);
58 unsigned int local_id =
Handle{data.
entry}.GetIndex();
59 unsigned int call_uid =
Handle{data.
call}.GetIndex();
60 RpcIdPair lookup_uid{local_id, call_uid};
63 std::lock_guard<std::mutex> lock(m_mutex);
64 auto i = m_response_map.find(lookup_uid);
65 if (i != m_response_map.end()) {
68 m_response_map.erase(i);
82 friend class RpcServerTest;
86 RpcServer(int inst, wpi::Logger& logger);
90 unsigned int Add(std::function<void(const RpcAnswer& answer)> callback);
91 unsigned int AddPolled(unsigned int poller_uid);
92 void RemoveRpc(unsigned int rpc_uid) override;
94 void ProcessRpc(unsigned int local_id, unsigned int call_uid, StringRef name,
95 StringRef params, const ConnectionInfo& conn,
96 SendResponseFunc send_response,
97 unsigned int rpc_uid) override;
100 llvm::StringRef result);
109 #endif // NT_RPCSERVER_H_ NetworkTables Connection Information.
Definition: ntcore_cpp.h:57
Definition: DenseMap.h:585
Definition: CallbackManager.h:52
NetworkTables Remote Procedure Call (Server Side)
Definition: ntcore_cpp.h:120
NT_Entry entry
Entry handle.
Definition: ntcore_cpp.h:128
NT_RpcCall call
Call handle.
Definition: ntcore_cpp.h:131
Definition: RpcServer.h:37
void PostRpcResponse(NT_Entry entry, NT_RpcCall call, StringRef result)
Post RPC response (return value) for a polled RPC.
Definition: ntcore_cpp.cpp:561
Definition: IEntryNotifier.h:15
Definition: CallbackManager.h:166
Definition: RpcServer.h:24
std::string name
Entry name.
Definition: ntcore_cpp.h:134
Definition: IRpcServer.h:18
Definition: RpcServer.h:80
Definition: CallbackManager.h:28
StringRef - Represent a constant reference to a string, i.e.
Definition: StringRef.h:42