Completing buffers immediately

This fixes crash introduced in 039b00e32e3d.

1 files changed, 2 insertions, 5 deletions

diff --git a/src/nxt_h1proto.c b/src/nxt_h1proto.c
index 19b84108..abc92dd4 100644
--- a/src/nxt_h1proto.c
+++ b/src/nxt_h1proto.c
@@ -1369,14 +1369,12 @@ nxt_h1p_complete_buffers(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_bool_t all)
     size_t            size;
     nxt_buf_t         *b, *in, *next;
     nxt_conn_t        *c;
-    nxt_work_queue_t  *wq;
 
     nxt_debug(task, "h1p complete buffers");
 
     b = h1p->buffers;
     c = h1p->conn;
     in = c->read;
-    wq = &task->thread->engine->fast_work_queue;
 
     if (b != NULL) {
         if (in == NULL) {
@@ -1392,7 +1390,7 @@ nxt_h1p_complete_buffers(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_bool_t all)
             next = b->next;
             b->next = NULL;
 
-            nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent);
+            b->completion_handler(task, b, b->parent);
 
             b = next;
         }
@@ -1405,8 +1403,7 @@ nxt_h1p_complete_buffers(nxt_task_t *task, nxt_h1proto_t *h1p, nxt_bool_t all)
         size = nxt_buf_mem_used_size(&in->mem);
 
         if (size == 0 || all) {
-            nxt_work_queue_add(wq, in->completion_handler, task, in,
-                               in->parent);
+            in->completion_handler(task, in, in->parent);
 
             c->read = NULL;
         }