dany/ant-http
1
0
Fork 0
mirror of https://github.com/lxsang/ant-http synced 2024-11-18 01:08:21 +01:00
Code Issues Actions Projects Releases Wiki Activity

fix deadlock

Browse Source
This commit is contained in:
lxsang 2018-10-14 11:02:27 +02:00
parent ba4bfadec0
commit 54bb040ef4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libs/scheduler.c
View File

@ -153,13 +153,13 @@ void antd_scheduler_init(antd_scheduler_t* scheduler, int n)
scheduler->workers_queue = NULL; scheduler->workers_queue = NULL;
scheduler->pending_task = 0 ; scheduler->pending_task = 0 ;
// init semaphore // init semaphore
scheduler->scheduler_sem = shm_open("scheduler", O_RDWR | O_CREAT, S_IRWXU); scheduler->scheduler_sem = sem_open("scheduler", O_RDWR | O_CREAT, S_IRWXU);
if (!scheduler->scheduler_sem) if (!scheduler->scheduler_sem)
{ {
LOG("Cannot open semaphore for scheduler\n"); LOG("Cannot open semaphore for scheduler\n");
exit(-1); exit(-1);
} }
scheduler->worker_sem = shm_open("worker", O_RDWR | O_CREAT, S_IRWXU); scheduler->worker_sem = sem_open("worker", O_RDWR | O_CREAT, S_IRWXU);
if (!scheduler->worker_sem) if (!scheduler->worker_sem)
{ {
LOG("Cannot open semaphore for workers\n"); LOG("Cannot open semaphore for workers\n");