Jafar
|
Implement a sensor node communications with IPC's (message queues) create a thread that handles connections/deconnections between nodes. More...
Implement a sensor node communications with IPC's (message queues) create a thread that handles connections/deconnections between nodes.
Definition at line 65 of file sensornodeipc.hpp.
#include <sensornodeipc.hpp>
Public Member Functions | |
SensorNodeIPC (unsigned short sv_size, time const &sync_period, PredictModelFactoryBase *pred_factory, CommFactoryBase *comm_factory, bool use_delayed) | |
virtual void | InitNode () |
virtual void | Start (time const &first_deadling) |
virtual void | KillNode () |
key_t | GetChanMgrKey () |
bool | ChanMgrAlive () |
void | DbgWaitInfoFromNode (unsigned short node_id) |
void | SetupChanMgrComm () |
Called by the channel manager thread. | |
void | Listen () |
void | CleanChanMgrComm () |
SN_CODE_TYPE | RequestConnection (unsigned short node_id) |
Connexion function: return SN_CODE_OK or SN_CODE_ALREADY_CONNECTED. | |
Private Attributes | |
ManagerThreadFunc < SensorNodeIPC< PARAMS > > | m_ChanMgr_Fun |
int | m_msqid |
bool | m_chanMgr_alive |
boost::thread * | m_pChanMgr |
boost::mutex | m_msqmutex |
Static Private Attributes | |
static const int | MBOX_OFFSET = 1987 |
Generated on Wed Oct 15 2014 00:37:33 for Jafar by doxygen 1.7.6.1 |