technocloud-public/nginx-unit
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Libunit: making minor tweaks.

Browse Source 
Removing unnecessary context operations from shared queue processing loop.
Initializing temporary queues only when required.
This commit is contained in:
Max Romanov
2020-11-18 22:33:53 +03:00
parent 8132e1f700
commit 300347a5cf
1 changed files with 4 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/nxt_unit.c
View File

@@ -4675,8 +4675,6 @@ nxt_unit_process_pending_rbuf(nxt_unit_ctx_t *ctx)
nxt_unit_ctx_impl_t *ctx_impl; nxt_unit_ctx_impl_t *ctx_impl;
nxt_unit_read_buf_t *rbuf; nxt_unit_read_buf_t *rbuf;
nxt_queue_init(&pending_rbuf);
ctx_impl = nxt_container_of(ctx, nxt_unit_ctx_impl_t, ctx); ctx_impl = nxt_container_of(ctx, nxt_unit_ctx_impl_t, ctx);
pthread_mutex_lock(&ctx_impl->mutex); pthread_mutex_lock(&ctx_impl->mutex);
@@ -4687,6 +4685,8 @@ nxt_unit_process_pending_rbuf(nxt_unit_ctx_t *ctx)
return NXT_UNIT_OK; return NXT_UNIT_OK;
} }
nxt_queue_init(&pending_rbuf);
nxt_queue_add(&pending_rbuf, &ctx_impl->pending_rbuf); nxt_queue_add(&pending_rbuf, &ctx_impl->pending_rbuf);
nxt_queue_init(&ctx_impl->pending_rbuf); nxt_queue_init(&ctx_impl->pending_rbuf);
@@ -4719,8 +4719,6 @@ nxt_unit_process_ready_req(nxt_unit_ctx_t *ctx)
nxt_unit_request_info_t *req; nxt_unit_request_info_t *req;
nxt_unit_request_info_impl_t *req_impl; nxt_unit_request_info_impl_t *req_impl;
nxt_queue_init(&ready_req);
ctx_impl = nxt_container_of(ctx, nxt_unit_ctx_impl_t, ctx); ctx_impl = nxt_container_of(ctx, nxt_unit_ctx_impl_t, ctx);
pthread_mutex_lock(&ctx_impl->mutex); pthread_mutex_lock(&ctx_impl->mutex);
@@ -4731,6 +4729,8 @@ nxt_unit_process_ready_req(nxt_unit_ctx_t *ctx)
return; return;
} }
nxt_queue_init(&ready_req);
nxt_queue_add(&ready_req, &ctx_impl->ready_req); nxt_queue_add(&ready_req, &ctx_impl->ready_req);
nxt_queue_init(&ctx_impl->ready_req); nxt_queue_init(&ctx_impl->ready_req);
@@ -4917,13 +4917,6 @@ nxt_unit_run_shared(nxt_unit_ctx_t *ctx)
if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { if (nxt_slow_path(rc == NXT_UNIT_ERROR)) {
break; break;
} }
rc = nxt_unit_process_pending_rbuf(ctx);
if (nxt_slow_path(rc == NXT_UNIT_ERROR)) {
break;
}
nxt_unit_process_ready_req(ctx);
} }
nxt_unit_ctx_release(ctx); nxt_unit_ctx_release(ctx);