jafar::ddf Namespace Reference

Decentralized Data Fusion. More...

---

Detailed Description

Decentralized Data Fusion.

Classes
class	ChannelFilterBase
	Implements a channel filter belonging to node i and connected to another channel filter belonging to node j. More...
struct	ChanFltrMsg
class	CommBase
	This is the base class for channel filter communication. More...
class	CommFactoryBase
	The base class for the communication factories. More...
class	CommFactoryGeneric
	The generic class for the communication factories. More...
class	time
	A toolbox for time management (absolute and duration). More...
class	DdfException
	Base class for all exceptions defined in the module ddf. More...
class	ParametersGeneric
struct	SpeedUpInfoStruct
class	InfoContainer
	Class for manipulating information This class is a container class for communicating, storing information in a network of sensor nodes. More...
class	CommThreadFunc
	Class in charge of listening to a communication channel (continuously call the function Read) More...
class	IPCProcComm
	An IPC implementation of CommBase. More...
class	Timer_Command
	This is a class for controlling the execution of a thread (a nodal filter, a channel manager, etc) One can run/stop the execution of the thread, and kill the process (return from the main function) More...
class	Thread_Periodic_Func
	This is the class (functionnal object) associated to a nodal thread. More...
class	FSStorageBase
class	PredictionEngineBase
	This is a virtual class for state prediction. More...
class	PredictionEngineGeneric
	This class allows to customize the set of parameters needed for updating the prediction model (specialization of PredictionEngineBase) More...
class	PredictModelFactoryBase
	The factory for prediction models. More...
class	PredictModelFactoryGeneric
	Specialized factory for prediction models. More...
class	StoreiI
class	SensorNodeBase
	This class implements the core functionalitires for a sensornode i.e. More...
class	SensorNodeGeneric
	This class uses template for binding a generic parameter container to the SensorNodeBase class This parameter is used for updating the prediction model i.e. More...
struct	SNConnectCore
struct	SNConnectStruct
class	ManagerThreadFunc
	The main loop for the channel manager. More...
class	SensorNodeIPC
	Implement a sensor node communications with IPC's (message queues) create a thread that handles connections/deconnections between nodes. More...
class	SensorNodePeriodic
class	StopWatch
	Measure the elapsed time. More...
class	Upd_lin_pred_model
	This class derives from a Linear_invertable_predict_model such as x(k|k-1) = F(x(k-1|k-1)) + G(k)w(k) q(k) = state noise covariance, q(k) is covariance of w(k) G(k) = state noise coupling invF exists and PredictionEngineBase. More...
Typedefs
typedef Bayesian_filter_matrix::SymMatrix	MSYM
typedef Bayesian_filter_matrix::Vec	VEC
typedef Bayesian_filter_matrix::RowMatrix	MROW
typedef Bayesian_filter_matrix::Matrix	MAT
typedef ublas::matrix< double >	MAT_UBLAS
Enumerations
enum	SN_INFO_TYPE { SN_INFO_IJ = 1, SN_INFO_JI }
enum	AXIS_TYPE { AXIS_X, AXIS_Y, AXIS_Z }
enum	MSGQ_RET { MSG_OK, MSG_REC, MSG_NOT_REC }
enum	FS_STORE_TYPE { FS_UPDATE, FS_PREDICT }
enum	SN_CONNECT_TYPE { SN_CONNECT = 1, SN_DISCONNECT, SN_CONFIRM_CONNECTION, SN_CONFIRM_DECONNECTION }
enum	SN_CODE_TYPE { SN_CODE_VOID, SN_CODE_OK, SN_CODE_ALREADY_CONNECTED }
enum	SN_RET_TYPE { SN_RET_OK, SN_RET_NOT_READY, SN_RET_FAIL }
enum	NEED_UPD_TYPE { NEED_UPD_F, NEED_UPD_G, NEED_UPD_Q, NEED_UPD_END }
	flags for enabling/disabling the update
Functions
std::ostream &	operator<< (std::ostream &stream, const time &t)
std::ostream &	operator<< (std::ostream &stream, InfoContainer const &other)
int	mbx_create (key_t key)
	All the functions for IPC communications.
void	mbx_destroy (int msqid)
int	mbx_getq (key_t key)
void	mbx_send (int msqid, struct msgbuf *msgp, size_t msgsz)
MSGQ_RET	mbx_rec (int msqid, struct msgbuf *msgp, size_t msgsz, long msgtyp)
void	mbx_blksend (int msqid, struct msgbuf *msgp, size_t msgsz)
MSGQ_RET	mbx_blkrec (int msqid, struct msgbuf *msgp, size_t msgsz, long msgtyp)
void	PrintSNConnect (SNConnectStruct const &sn)
void	PrettyPrintMatrix (MAT_UBLAS const &my_mat, char const *txt=NULL, double epsilon=ZERO_THRESHOLD)
void	PrettyPrintVector (VEC const &my_vec, char const *txt=NULL, double epsilon=ZERO_THRESHOLD)
Bayesian_filter_matrix::Float	compute_information_corr (Bayesian_filter::Linrz_correlated_observe_model &h, VEC const &z, SpeedUpInfoStruct &sp, VEC &i, MSYM &I)
Bayesian_filter_matrix::Float	compute_information_uncorr (Bayesian_filter::Linrz_uncorrelated_observe_model &h, VEC const &z, VEC &i, MSYM &I)
Bayesian_filter_matrix::Float	compute_state (VEC &y, MSYM &Y, VEC &x, MSYM &X)
void	matsym_assign (MSYM &dest, MSYM const &src)
void	CompPredNewInfo (MAT const &Fk, Bayesian_filter_matrix::ColMatrix const &invFk, MAT const &Gk, MAT const &invQk, VEC const &yk, VEC const &ik, MSYM const &MkY, MSYM const &MkI, MSYM &Ip, VEC &ip, SpeedUpInfoStruct &sp, MAT const &Bk, VEC const &uk)
void	CompPredNewInfo (MAT const &Fk, Bayesian_filter_matrix::ColMatrix const &invFk, MAT const &Gk, MAT const &invQk, VEC const &yk, VEC const &ik, MSYM const &MkY, MSYM const &MkI, MSYM &Ip, VEC &ip, SpeedUpInfoStruct &sp)
bool	vec_compare (VEC const &m1, VEC const &m2)
bool	mat_compare (MAT_UBLAS const &m1, MAT_UBLAS const &m2)
void	fill_diag (MSYM const &m, VEC &diag)
Variables
const char	NODE_IJ_TEXT [][20] = {"VOID", "NODE j receive", "NODE i receive"}
const char	LOGSEP = '\t'
const char	SN_CONNECT_STRING [][30] = {"SN_VOID","Request connect","Request disconnect","Confirm connect", "Confirm disconnect"}
const char	SN_CODE_STRING [][30] = {"SN_CODE_VOID","ok","node already connected"}

---

Function Documentation

int jafar::ddf::mbx_create

(

key_t

key

)

All the functions for IPC communications.

Author:

Pierre Lamon

Referenced by jafar::ddf::SensorNodeIPC< PARAMS >::SetupChanMgrComm().