Introducing application timeout.

1 files changed, 18 insertions, 2 deletions

diff --git a/src/nxt_main_process.c b/src/nxt_main_process.c
index 7748d07f..2e91628b 100644
--- a/src/nxt_main_process.c
+++ b/src/nxt_main_process.c
@@ -171,11 +171,14 @@ nxt_port_main_start_worker_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
     nxt_mp_t               *mp;
     nxt_int_t              ret;
     nxt_buf_t              *b;
+    nxt_port_t             *port;
     nxt_conf_value_t       *conf;
     nxt_common_app_conf_t  app_conf;
 
     static nxt_str_t nobody = nxt_string("nobody");
 
+    ret = NXT_ERROR;
+
     b = msg->buf;
 
     nxt_debug(task, "main start worker: %*s", b->mem.free - b->mem.pos,
@@ -196,7 +199,8 @@ nxt_port_main_start_worker_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
 
     if (conf == NULL) {
         nxt_log(task, NXT_LOG_CRIT, "configuration parsing error");
-        return;
+
+        goto failed;
     }
 
     app_conf.user = nobody;
@@ -205,12 +209,24 @@ nxt_port_main_start_worker_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
                               nxt_nitems(nxt_common_app_conf), &app_conf);
     if (ret != NXT_OK) {
         nxt_log(task, NXT_LOG_CRIT, "root map error");
-        return;
+
+        goto failed;
     }
 
     ret = nxt_main_start_worker_process(task, task->thread->runtime,
                                         &app_conf, msg->port_msg.stream);
 
+failed:
+
+    if (ret == NXT_ERROR) {
+        port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid,
+                                     msg->port_msg.reply_port);
+        if (nxt_fast_path(port != NULL)) {
+            nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR,
+                                    -1, msg->port_msg.stream, 0, NULL);
+        }
+    }
+
     nxt_mp_destroy(mp);
 }