diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-08-02 13:21:32 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-08-02 13:21:32 +0300 |
| commit | 9367dd2bf8982d7dbe5e8c71643d3e5d5ee494e1 (patch) | |
| tree | eb8b27d0f4faa8f630b6d1ec935f369d478d56ba /src/nxt_port.c | |
| parent | bcf99f87e25d3702ec01595a5cf3e91c00cc6a98 (diff) | |
| download | unit-9367dd2bf8982d7dbe5e8c71643d3e5d5ee494e1.tar.gz unit-9367dd2bf8982d7dbe5e8c71643d3e5d5ee494e1.tar.bz2 | |
Implicit port read buffer completion.
To disable implicit completion, handler should reset msg->buf field.
Diffstat (limited to 'src/nxt_port.c')
| -rw-r--r-- | src/nxt_port.c | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/src/nxt_port.c b/src/nxt_port.c index 681fec39..18dc4121 100644 --- a/src/nxt_port.c +++ b/src/nxt_port.c @@ -225,7 +225,6 @@ nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) rt = task->thread->runtime; new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos; - msg->buf->mem.pos = msg->buf->mem.free; nxt_debug(task, "new port %d received for process %PI:%d", msg->fd, new_port_msg->pid, new_port_msg->id); @@ -405,8 +404,6 @@ nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) } nxt_debug(task, "data: %*s", dump_size, b->mem.pos); - - b->mem.pos = b->mem.free; } |