diff options
| author | Max Romanov <max.romanov@nginx.com> | 2021-11-24 13:11:47 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2021-11-24 13:11:47 +0300 |
| commit | 2c636a03f35c1807fa0744b53d19f364b131dc1d (patch) | |
| tree | c643468c53c4b8af5c64d4afecd4a8789d1c7ef2 /src/nxt_external.c | |
| parent | ef1ebf96f300d9a2f487656ac827a9c166f57197 (diff) | |
| download | unit-2c636a03f35c1807fa0744b53d19f364b131dc1d.tar.gz unit-2c636a03f35c1807fa0744b53d19f364b131dc1d.tar.bz2 | |
Sending shared port to application prototype.
Application process started with shared port (and queue) already configured.
But still waits for PORT_ACK message from router to start request processing
(so-called "ready state").
Waiting for router confirmation is necessary. Otherwise, the application may
produce response and send it to router before the router have the information
about the application process. This is a subject of further optimizations.
Diffstat (limited to 'src/nxt_external.c')
| -rw-r--r-- | src/nxt_external.c | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/src/nxt_external.c b/src/nxt_external.c index b41ca51b..c724b9bd 100644 --- a/src/nxt_external.c +++ b/src/nxt_external.c @@ -106,6 +106,16 @@ nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) return NXT_ERROR; } + rc = nxt_external_fd_no_cloexec(task, conf->shared_port_fd); + if (nxt_slow_path(rc != NXT_OK)) { + return NXT_ERROR; + } + + rc = nxt_external_fd_no_cloexec(task, conf->shared_queue_fd); + if (nxt_slow_path(rc != NXT_OK)) { + return NXT_ERROR; + } + end = buf + sizeof(buf); p = nxt_sprintf(buf, end, @@ -113,12 +123,14 @@ nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) "%PI,%ud,%d;" "%PI,%ud,%d;" "%PI,%ud,%d,%d;" + "%d,%d;" "%d,%z,%uD,%Z", NXT_VERSION, my_port->process->stream, proto_port->pid, proto_port->id, proto_port->pair[1], router_port->pid, router_port->id, router_port->pair[1], my_port->pid, my_port->id, my_port->pair[0], my_port->pair[1], + conf->shared_port_fd, conf->shared_queue_fd, 2, conf->shm_limit, conf->request_limit); if (nxt_slow_path(p == end)) { |