lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-25 04:33:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

CHECK ABORT every message dispatch

Browse Source
This commit is contained in:
Cloud Wu
2014-10-11 13:11:00 +08:00
parent 1c62785d71
commit c8b8dc1276
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
skynet-src/skynet_start.c
View File

@@ -125,7 +125,6 @@ _worker(void *p) {
skynet_initthread(THREAD_WORKER); skynet_initthread(THREAD_WORKER);
struct message_queue * q = NULL; struct message_queue * q = NULL;
for (;;) { for (;;) {
CHECK_ABORT
q = skynet_context_message_dispatch(sm, q, weight); q = skynet_context_message_dispatch(sm, q, weight);
if (q == NULL) { if (q == NULL) {
if (pthread_mutex_lock(&m->mutex) == 0) { if (pthread_mutex_lock(&m->mutex) == 0) {
@@ -140,6 +139,7 @@ _worker(void *p) {
} }
} }
} }
CHECK_ABORT
} }
return NULL; return NULL;
} }