hoo2
/
rtes_messenger
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
A messenger application for Raspberry Pi Zerofor A.U.TH (Real time Embedded systems).
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
12 Commits
1 Branch
952 KiB
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
rtes_messenger/src/core.h

64 lines
1.9 KiB
Raw Permalink Blame History 

  1. /*!

  2.  * \file core.h

  3.  *

  4.  * \author Christos Choutouridis AEM:8997 <cchoutou@ece.auth.gr>

  5.  */

  6. 

  7. #ifndef __core_h__

  8. #define __core_h__

  9. 

  10. #include <netinet/in.h>

  11. 

  12. #include "msg_impl.h"

  13. 

  14. extern msgList_t msgList;

  15. 

  16. devAEM_t  addr2devAEM (in_addr_t in_addr);

  17. in_addr_t devAEM2addr (devAEM_t dev);

  18. devAEM_t  ip2AEM (devIP_t* ip);

  19. devIP_t   AEM2ip (devAEM_t dev);

  20. 

  21. void      cMsg_make (cMsg_t* msg);

  22. size_t    cMsg_serialize (cMsg_t* msg, char_t* buffer);

  23. status_t  cMsg_parse (cMsg_t* cMsg, char_t* rawMsg, size_t size);

  24. uint32_t  cMsg_getFrom (cMsg_t* cMsg);

  25. uint32_t  cMsg_getTo (cMsg_t* cMsg);

  26. uint64_t  cMsg_getTs (cMsg_t* cMsg);

  27. char_t*   cMsg_getText (cMsg_t* cMsg);

  28. bool_t    cMsg_equal (cMsg_t* m1, cMsg_t* m2);

  29. 

  30. void      msg_init (msg_t* msg);

  31. 

  32. status_t  devList_init (devList_t* devList);

  33. dIter_t   devList_getIter (devAEM_t dev);

  34. void      devList_acquire (void);

  35. void      devList_release (void);

  36. 

  37. mIter_t   msgList_preInc (mIter_t* it);

  38. mIter_t   msgList_preDec (mIter_t* it);

  39. status_t  msgList_init (msgList_t* msgList);

  40. mIter_t   msgList_begin (msgList_t* this);

  41. mIter_t   msgList_last (msgList_t* this);

  42. size_t    msgList_size (msgList_t* this);

  43. mIter_t   msgList_find (msgList_t* this, msg_t* msg);

  44. mIter_t   msgList_add (msgList_t* this, msg_t* msg);

  45. void      msgList_acquire ();

  46. void      msgList_release ();

  47. 

  48. status_t stats_init (stats_t* s);

  49. void     statsUpdateCreate (msg_t* msg);

  50. void     statsUpdateIn (msg_t* msg, bool_t dup);

  51. void     statsUpdateOut (msg_t* msg, devAEM_t dev);

  52. status_t statsPrint (stats_t* stats);

  53. status_t statsTimesPrint (devList_t *devList);

  54. 

  55. status_t log_init(void);

  56. void     log_msg_in (msg_t* msg);

  57. void     log_msg_out (msg_t* msg, devAEM_t dev);

  58. void     log_msg_new (msg_t* msg);

  59. void     log_debug (const char *fmt, ...);

  60. void     log_error (const char *fmt, ...);

  61. 

  62. 

  63. #endif /* __core_h__ */