Work queue thread assertions. Reset thread after fork.

This commit is contained in:
Max Romanov
2017-07-18 00:21:17 +03:00
parent 803855138c
commit 8ad2c3fd3a
6 changed files with 54 additions and 3 deletions

View File

@@ -660,3 +660,19 @@ nxt_event_engine_request_find_remove(nxt_event_engine_t *engine,
return NULL;
}
#if (NXT_DEBUG)
void nxt_event_engine_thread_adopt(nxt_event_engine_t *engine)
{
nxt_work_queue_thread_adopt(&engine->fast_work_queue);
nxt_work_queue_thread_adopt(&engine->accept_work_queue);
nxt_work_queue_thread_adopt(&engine->read_work_queue);
nxt_work_queue_thread_adopt(&engine->socket_work_queue);
nxt_work_queue_thread_adopt(&engine->connect_work_queue);
nxt_work_queue_thread_adopt(&engine->write_work_queue);
nxt_work_queue_thread_adopt(&engine->shutdown_work_queue);
nxt_work_queue_thread_adopt(&engine->close_work_queue);
}
#endif