FilesExpand file tree

master

/

kmsg_queue.c

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

44 lines (34 loc) · 902 Bytes

master

/

kmsg_queue.c

Copy path

Top

File metadata and controls

• Code
• Blame

44 lines (34 loc) · 902 Bytes

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

/*

* Copyright (C) 2021 xiaoliang<[email protected]>.

*/

#include <os/kernel.h>

void kmsg_queue_push(kmsg_queue_t *kmsg_q, slist_node_t *msg)

{

int key;

kevent_t *listen_ev;

key = irq_lock();

if (slist_node_is_del(msg)) {

fifo_push(&kmsg_q->msg_q, msg);

if (!lifo_is_empty(&kmsg_q->wait_q)) {

listen_ev = KEVENT_OF_NODE(lifo_pop(&kmsg_q->wait_q));

kevent_post(listen_ev);

}

}

irq_unlock(key);

}

slist_node_t *kmsg_queue_pop(kmsg_queue_t *kmsg_q, kevent_t *listen_ev)

{

int key;

slist_node_t *node;

key = irq_lock();

if (fifo_is_empty(&kmsg_q->msg_q)) {

node = NULL;

if (listen_ev && !kevent_is_ref(listen_ev)) {

lifo_push(&kmsg_q->wait_q, KEVENT_NODE(listen_ev));

}

} else {

node = fifo_pop(&kmsg_q->msg_q);

}

irq_unlock(key);

return node;

}