diff options
| author | Max Romanov <max.romanov@nginx.com> | 2020-08-11 19:20:13 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2020-08-11 19:20:13 +0300 |
| commit | 6e31d6cd39be9d3f4ee680fc13c3fe42f5cd39e7 (patch) | |
| tree | 2ef1d993674825791636486a0929ead424c8dd7a /src/nxt_http_websocket.c | |
| parent | 3cbc22a6dc45abdeade4deb364601230ddca02c1 (diff) | |
| download | unit-6e31d6cd39be9d3f4ee680fc13c3fe42f5cd39e7.tar.gz unit-6e31d6cd39be9d3f4ee680fc13c3fe42f5cd39e7.tar.bz2 | |
Changing router to application shared memory exchange protocol.
The application process needs to request the shared memory segment from the
router instead of the latter pushing the segment 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 for using the application
shared port and then the queue.
Diffstat (limited to 'src/nxt_http_websocket.c')
| -rw-r--r-- | src/nxt_http_websocket.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/nxt_http_websocket.c b/src/nxt_http_websocket.c index fb888f5d..4d31b320 100644 --- a/src/nxt_http_websocket.c +++ b/src/nxt_http_websocket.c @@ -69,7 +69,8 @@ nxt_http_websocket_client(nxt_task_t *task, void *obj, void *data) if (buf == NULL || buf_free_size == 0) { buf_free_size = nxt_min(frame_size, PORT_MMAP_DATA_SIZE); - buf = nxt_port_mmap_get_buf(task, req_app_link->app_port, + buf = nxt_port_mmap_get_buf(task, + &req_app_link->app_port->process->outgoing, buf_free_size); *out_tail = buf; |