lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

bugfix: Issue #37

Browse Source
This commit is contained in:
云风
2013-09-11 17:21:05 +08:00
parent 80fe468e8e
commit efb8ecbe84
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
skynet-src/skynet_mq.c
View File

@@ -56,7 +56,6 @@ skynet_globalmq_push(struct message_queue * queue) {
q->queue[tail] = queue; q->queue[tail] = queue;
__sync_synchronize(); __sync_synchronize();
q->flag[tail] = true; q->flag[tail] = true;
__sync_synchronize();
} }
struct message_queue * struct message_queue *
@@ -72,12 +71,13 @@ skynet_globalmq_pop() {
return NULL; return NULL;
} }
__sync_synchronize();
struct message_queue * mq = q->queue[head_ptr]; struct message_queue * mq = q->queue[head_ptr];
if (!__sync_bool_compare_and_swap(&q->head, head, head+1)) { if (!__sync_bool_compare_and_swap(&q->head, head, head+1)) {
return NULL; return NULL;
} }
q->flag[head_ptr] = false; q->flag[head_ptr] = false;
__sync_synchronize();
return mq; return mq;
} }