WPILibC++
unspecified
|
Public Member Functions | |
RpcServerThread (int inst, wpi::Logger &logger) | |
bool | Matches (const RpcListenerData &listener, const RpcNotifierData &data) |
void | SetListener (RpcNotifierData *data, unsigned int listener_uid) |
void | DoCallback (std::function< void(const RpcAnswer &call)> callback, const RpcNotifierData &data) |
![]() | |
void | Main () override |
void | SendPoller (unsigned int poller_uid, Args &&...args) |
Public Attributes | |
int | m_inst |
wpi::Logger & | m_logger |
wpi::DenseMap< RpcIdPair, IRpcServer::SendResponseFunc > | m_response_map |
![]() | |
wpi::UidVector< ListenerData, 64 > | m_listeners |
std::queue< std::pair< unsigned int, NotifierData > > | m_queue |
wpi::condition_variable | m_queue_empty |
wpi::UidVector< std::shared_ptr< Poller >, 64 > | m_pollers |
![]() | |
wpi::mutex | m_mutex |
std::atomic_bool | m_active |
wpi::condition_variable | m_cond |
Additional Inherited Members | |
![]() | |
typedef RpcAnswer | UserInfo |
typedef RpcNotifierData | NotifierData |
typedef RpcListenerData | ListenerData |