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

Fixing code style.

Browse Source
This commit is contained in:
Max Romanov
2017-12-27 17:47:42 +03:00
parent bef2ec483e
commit baa8c9387b
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/nxt_router.c
View File

@@ -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) {