FilesExpand file tree

 master

/

CLinuxMsgQueue.cpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

88 lines (40 loc) · 1.08 KB

 master

/

CLinuxMsgQueue.cpp

Copy path

Top

File metadata and controls

• Code
• Blame

executable file

·

88 lines (40 loc) · 1.08 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

#include "CLinuxMsgQueue.h"

#include "COperatingSystemFactory.h"

CLinuxMsgQueue::CLinuxMsgQueue(const char *pName):

CMsgQueue(pName)

{

p_mutex=COperatingSystemFactory::newMutex("Msg Mutex");

p_sem=COperatingSystemFactory::newCountingSem(0);

}

CLinuxMsgQueue::~CLinuxMsgQueue()

{

}

bool CLinuxMsgQueue::recvMsg(unsigned int &m_msg_code,void *&p_msg)

{

bool result;

Elements queue_element;

p_sem->Get();

p_mutex->Lock();

if (m_queue.empty()) {

p_mutex->UnLock();

return false;

}

queue_element = m_queue.front();

m_queue.pop_front();

m_msg_code = queue_element.msg_code;

p_msg = queue_element.p_message;

p_mutex->UnLock();

return true;

}

bool CLinuxMsgQueue::sendMsg(unsigned int m_msg_code,void *p_msg)

{

bool result;

Elements queue_element;

queue_element.msg_code=m_msg_code;

queue_element.p_message=p_msg;

p_mutex->Lock();

m_queue.push_back(queue_element);

p_mutex->UnLock();

p_sem->Post();

return true;

}