Work queue thread assertions. Reset thread after fork.

1 files changed, 20 insertions, 0 deletions

diff --git a/src/nxt_work_queue.c b/src/nxt_work_queue.c
index 85f5cc3e..1b989eab 100644
--- a/src/nxt_work_queue.c
+++ b/src/nxt_work_queue.c
@@ -58,6 +58,26 @@ nxt_work_queue_thread_assert(nxt_work_queue_t *wq)
     nxt_abort();
 }
 
+
+void nxt_work_queue_thread_adopt(nxt_work_queue_t *wq)
+{
+    nxt_thread_t  *thread;
+
+    thread = nxt_thread();
+
+    wq->pid = nxt_pid;
+    wq->tid = nxt_thread_tid(thread);
+}
+
+
+void
+nxt_work_queue_name(nxt_work_queue_t *wq, const char* name)
+{
+    nxt_work_queue_thread_assert(wq);
+
+    wq->name = name;
+}
+
 #else
 
 #define nxt_work_queue_thread_assert(wq)