fyb/calcurse-edge
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Mutex for the system message queue

Browse Source 
The main thread only reads and removes events from the queue. All other threads
only insert events in the queue. Hence, only insertion and removal need protection.

Signed-off-by: Lukas Fleischer <lfleischer@calcurse.org>
This commit is contained in:
Lars Henriksen 2018-09-15 22:12:06 +02:00 committed by Lukas Fleischer
parent 53b55930e8
commit d1075e525f
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/queue.c
View File

@ -4,6 +4,7 @@
* A queue for calcurse system messages. * A queue for calcurse system messages.
*/ */
llist_t sysqueue; llist_t sysqueue;
static pthread_mutex_t que_mutex = PTHREAD_MUTEX_INITIALIZER;
void que_init(void) void que_init(void)
{ {
@ -30,7 +31,9 @@ struct event *que_ins(char *mesg, time_t time, int id)
ev->day = time; ev->day = time;
ev->id = id; ev->id = id;
ev->note = NULL; ev->note = NULL;
pthread_mutex_lock(&que_mutex);
LLIST_ADD(&sysqueue, ev); LLIST_ADD(&sysqueue, ev);
pthread_mutex_unlock(&que_mutex);
return ev; return ev;
} }
@ -52,11 +55,14 @@ void que_rem(void)
if (!sysqueue.head) if (!sysqueue.head)
return; return;
else ev = sysqueue.head->data;
ev = sysqueue.head->data;
pthread_mutex_lock(&que_mutex);
LLIST_REMOVE(&sysqueue, sysqueue.head);
pthread_mutex_unlock(&que_mutex);
mem_free(ev->mesg); mem_free(ev->mesg);
mem_free(ev); mem_free(ev);
LLIST_REMOVE(&sysqueue, sysqueue.head);
} }
/* /*