--- mqtt/inc/mqttd.h 2012/01/27 16:19:04 1.2.2.1 +++ mqtt/inc/mqttd.h 2012/01/30 13:39:22 1.2.2.2 @@ -14,6 +14,7 @@ struct tagStore { struct tagSession { /* client session thread id */ pthread_t sess_tid; + pthread_mutex_t sess_mtx; /* server dispatcher */ mqtt_srv_t *sess_srv;