Fixing 'find & add' racing condition in connected ports hash.

Missing error log messages added.

1 files changed, 18 insertions, 14 deletions

diff --git a/src/nxt_router.c b/src/nxt_router.c
index d4f25d7e..a70b03d1 100644
--- a/src/nxt_router.c
+++ b/src/nxt_router.c
@@ -735,12 +735,15 @@ nxt_request_app_link_use(nxt_task_t *task, nxt_request_app_link_t *req_app_link,
 
 
 nxt_inline void
-nxt_request_app_link_error(nxt_request_app_link_t *req_app_link, int code,
-    const char *str)
+nxt_request_app_link_error(nxt_task_t *task, nxt_app_t *app,
+    nxt_request_app_link_t *req_app_link, const char *str)
 {
     req_app_link->app_port = NULL;
-    req_app_link->err_code = code;
+    req_app_link->err_code = 500;
     req_app_link->err_str = str;
+
+    nxt_alert(task, "app \"%V\" internal error: %s on #%uD",
+              &app->name, str, req_app_link->stream);
 }
 
 
@@ -3909,7 +3912,7 @@ nxt_router_app_port_error(nxt_task_t *task, nxt_port_recv_msg_t *msg,
         nxt_debug(task, "app '%V' %p abort next stream #%uD",
                   &app->name, app, req_app_link->stream);
 
-        nxt_request_app_link_error(req_app_link, 500,
+        nxt_request_app_link_error(task, app, req_app_link,
                                    "Failed to start application process");
         nxt_request_app_link_use(task, req_app_link, -1);
     }
@@ -4665,7 +4668,7 @@ nxt_router_port_post_select(nxt_task_t *task, nxt_port_select_state_t *state)
             nxt_port_use(task, state->port, -1);
         }
 
-        nxt_request_app_link_error(state->req_app_link, 500,
+        nxt_request_app_link_error(task, app, state->req_app_link,
                             "Failed to allocate shared req<->app link");
 
         return NXT_ERROR;
@@ -4693,7 +4696,7 @@ nxt_router_port_post_select(nxt_task_t *task, nxt_port_select_state_t *state)
     res = nxt_router_start_app_process(task, app);
 
     if (nxt_slow_path(res != NXT_OK)) {
-        nxt_request_app_link_error(req_app_link, 500,
+        nxt_request_app_link_error(task, app, req_app_link,
                                    "Failed to start app process");
 
         return NXT_ERROR;
@@ -4808,25 +4811,26 @@ nxt_router_app_prepare_request(nxt_task_t *task,
 
     apr_action = NXT_APR_REQUEST_FAILED;
 
-    c_port = nxt_process_connected_port_find(port->process, reply_port->pid,
-                                             reply_port->id);
+    c_port = nxt_process_connected_port_find_add(port->process, reply_port);
+
     if (nxt_slow_path(c_port != reply_port)) {
         res = nxt_port_send_port(task, port, reply_port, 0);
 
         if (nxt_slow_path(res != NXT_OK)) {
-            nxt_request_app_link_error(req_app_link, 500,
+            nxt_request_app_link_error(task, port->app, req_app_link,
                                 "Failed to send reply port to application");
+
+            nxt_process_connected_port_remove(port->process, reply_port);
+
             goto release_port;
         }
-
-        nxt_process_connected_port_add(port->process, reply_port);
     }
 
     buf = nxt_router_prepare_msg(task, req_app_link->request, port,
                                  nxt_app_msg_prefix[port->app->type]);
 
     if (nxt_slow_path(buf == NULL)) {
-        nxt_request_app_link_error(req_app_link, 500,
+        nxt_request_app_link_error(task, port->app, req_app_link,
                             "Failed to prepare message for application");
         goto release_port;
     }
@@ -4850,7 +4854,7 @@ nxt_router_app_prepare_request(nxt_task_t *task,
                                      &req_app_link->msg_info.tracking,
                                      req_app_link->stream);
     if (nxt_slow_path(res != NXT_OK)) {
-        nxt_request_app_link_error(req_app_link, 500,
+        nxt_request_app_link_error(task, port->app, req_app_link,
                                    "Failed to get tracking area");
         goto release_port;
     }
@@ -4868,7 +4872,7 @@ nxt_router_app_prepare_request(nxt_task_t *task,
                                  &req_app_link->msg_info.tracking);
 
     if (nxt_slow_path(res != NXT_OK)) {
-        nxt_request_app_link_error(req_app_link, 500,
+        nxt_request_app_link_error(task, port->app, req_app_link,
                                    "Failed to send message to application");
         goto release_port;
     }