diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-12-27 17:47:42 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-12-27 17:47:42 +0300 |
| commit | baa8c9387b00dc3cd72cfca14c61c25a2badada9 (patch) | |
| tree | fb7597459fce26952eaa3c1e409ccafced08dc3f /src/nxt_router.c | |
| parent | bef2ec483eaa525da770c024069b31320b63977e (diff) | |
| download | unit-baa8c9387b00dc3cd72cfca14c61c25a2badada9.tar.gz unit-baa8c9387b00dc3cd72cfca14c61c25a2badada9.tar.bz2 | |
Fixing code style.
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_router.c | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/nxt_router.c b/src/nxt_router.c index 61daf746..1f0f0b0f 100644 --- a/src/nxt_router.c +++ b/src/nxt_router.c @@ -658,8 +658,8 @@ nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) return; } - if (msg->u.new_port == NULL || - msg->u.new_port->type != NXT_PROCESS_WORKER) + if (msg->u.new_port == NULL + || msg->u.new_port->type != NXT_PROCESS_WORKER) { msg->port_msg.type = _NXT_PORT_MSG_RPC_ERROR; } @@ -2798,9 +2798,9 @@ nxt_router_app_port_release(nxt_task_t *task, nxt_port_t *port, port->app_pending_responses -= request_failed + got_response; port->app_responses += got_response; - if (app->live != 0 && - port->pair[1] != -1 && - (app->max_pending_responses == 0 + if (app->live != 0 + && port->pair[1] != -1 + && (app->max_pending_responses == 0 || port->app_pending_responses < app->max_pending_responses)) { if (port->app_link.next == NULL) { @@ -2823,9 +2823,9 @@ nxt_router_app_port_release(nxt_task_t *task, nxt_port_t *port, } } - if (app->live != 0 && - !nxt_queue_is_empty(&app->ports) && - !nxt_queue_is_empty(&app->requests)) + if (app->live != 0 + && !nxt_queue_is_empty(&app->ports) + && !nxt_queue_is_empty(&app->requests)) { lnk = nxt_queue_first(&app->requests); nxt_queue_remove(lnk); @@ -2928,9 +2928,9 @@ nxt_router_app_port_close(nxt_task_t *task, nxt_port_t *port) app->workers--; - start_worker = app->live != 0 && - nxt_queue_is_empty(&app->requests) == 0 && - app->workers + app->pending_workers < app->max_workers; + start_worker = app->live != 0 + && nxt_queue_is_empty(&app->requests) == 0 + && app->workers + app->pending_workers < app->max_workers; if (start_worker) { app->pending_workers++; @@ -3643,11 +3643,11 @@ nxt_php_prepare_msg(nxt_task_t *task, nxt_app_request_t *r, RC(nxt_app_msg_write_size(task, wmsg, h->parsed_content_length)); RC(nxt_app_msg_write_size(task, wmsg, r->body.preread_size)); - method_is_post = h->method.length == 4 && - h->method.start[0] == 'P' && - h->method.start[1] == 'O' && - h->method.start[2] == 'S' && - h->method.start[3] == 'T'; + method_is_post = h->method.length == 4 + && h->method.start[0] == 'P' + && h->method.start[1] == 'O' + && h->method.start[2] == 'S' + && h->method.start[3] == 'T'; if (method_is_post) { for(b = r->body.buf; b != NULL; b = b->next) { |