diff options
| author | Max Romanov <max.romanov@nginx.com> | 2020-08-11 19:20:10 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2020-08-11 19:20:10 +0300 |
| commit | 3cbc22a6dc45abdeade4deb364601230ddca02c1 (patch) | |
| tree | 3eff409de1a4405c646a2c11633d50711fa22746 /src/nxt_runtime.c | |
| parent | bf647588ff781e606651f001b53a4e83bb34c000 (diff) | |
| download | unit-3cbc22a6dc45abdeade4deb364601230ddca02c1.tar.gz unit-3cbc22a6dc45abdeade4deb364601230ddca02c1.tar.bz2 | |
Changing router to application port exchange protocol.
The application process needs to request the port from the router instead of the
latter pushing the port before sending a request to the application. This is
required to simplify the communication between the router and the application
and to prepare the router to use the application shared port and then the queue.
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_runtime.c | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/src/nxt_runtime.c b/src/nxt_runtime.c index 694ce74d..c25b93cc 100644 --- a/src/nxt_runtime.c +++ b/src/nxt_runtime.c @@ -1389,8 +1389,6 @@ nxt_runtime_process_new(nxt_runtime_t *rt) void nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process) { - nxt_port_t *port; - if (process->registered == 1) { nxt_runtime_process_remove(rt, process); } @@ -1401,11 +1399,6 @@ nxt_runtime_process_release(nxt_runtime_t *rt, nxt_process_t *process) nxt_port_mmaps_destroy(&process->incoming, 1); nxt_port_mmaps_destroy(&process->outgoing, 1); - do { - port = nxt_port_hash_retrieve(&process->connected_ports); - - } while (port != NULL); - nxt_thread_mutex_destroy(&process->incoming.mutex); nxt_thread_mutex_destroy(&process->outgoing.mutex); nxt_thread_mutex_destroy(&process->cp_mutex); |