Mirrors/libwebsockets
1
0
Fork 0
mirror of https://github.com/warmcat/libwebsockets.git synced 2025-03-09 00:00:04 +01:00
Code Issues Releases Wiki Activity

threadpool: SYNC timeout on netbsdBE

Browse source 
NetBSD Big-Endian on an RPi 3 + uSD is very slow, increase the threadpool
SYNC timeout a bit and normalize the task stop flow if it is exceeded.
This commit is contained in:
Andy Green 2021-09-21 05:42:55 +01:00
parent 0fda90c40a
commit 8c7d541011
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
lib/misc/threadpool/threadpool.c
View file

@ -426,13 +426,13 @@ lws_threadpool_worker_sync(struct lws_pool *pool,
}
/*
* So tries times this is the maximum time between SYNC asking
* So "tries" times this is the maximum time between SYNC asking
* for a callback on writable and actually getting it we are
* willing to sit still for.
*
* If it is exceeded, we will stop the task.
*/
abstime.tv_sec = time(NULL) + 2;
abstime.tv_sec = time(NULL) + 3;
abstime.tv_nsec = 0;
task->wanted_writeable_cb = 1;
@ -462,8 +462,9 @@ lws_threadpool_worker_sync(struct lws_pool *pool,
__func__, pool->tp->name, task,
task->name, lws_wsi_tag(task_to_wsi(task)));
state_transition(task, LWS_TP_STATUS_STOPPING);
goto done;
pthread_mutex_unlock(&pool->lock); /* ----------------- - pool unlock */
lws_threadpool_dequeue_task(task);
return 1; /* destroyed task */
}
continue;
@ -605,7 +606,10 @@ lws_threadpool_worker(void *d)
}
/* block until writable acknowledges */
then = lws_now_usecs();
lws_threadpool_worker_sync(pool, task);
if (lws_threadpool_worker_sync(pool, task)) {
lwsl_notice("%s: Sync failed\n", __func__);
goto doneski;
}
us_accrue(&task->acc_syncing, then);
break;
case LWS_TP_RETURN_FINISHED: