diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-10-04 15:03:45 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-10-04 15:03:45 +0300 |
| commit | 00ecf713e36de2a5efffe761458b7ac0328bce87 (patch) | |
| tree | d10e45f41d972326c4e5469a2cf4248a465514b6 /src/nxt_port.c | |
| parent | 0faecee609b66a353d27499ca78ff6abcd3fef14 (diff) | |
| download | unit-00ecf713e36de2a5efffe761458b7ac0328bce87.tar.gz unit-00ecf713e36de2a5efffe761458b7ac0328bce87.tar.bz2 | |
Port message fragmentation supported.
- Each sendmsg() transmits no more than port->max_size payload data.
- Longer buffers are fragmented and send using multiple sendmsg() calls.
- On receive side, buffers are connected in chain.
- Number of handler calls is the same as number of nxt_port_socket_write()
calls.
- nxt_buf_make_plain() function introduced to make single plain buffer from
the chain.
Diffstat (limited to 'src/nxt_port.c')
| -rw-r--r-- | src/nxt_port.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/nxt_port.c b/src/nxt_port.c index df652ac4..52144759 100644 --- a/src/nxt_port.c +++ b/src/nxt_port.c @@ -248,6 +248,8 @@ nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) new_port_msg = (nxt_port_msg_new_port_t *) msg->buf->mem.pos; + /* TODO check b size and make plain */ + nxt_debug(task, "new port %d received for process %PI:%d", msg->fd, new_port_msg->pid, new_port_msg->id); |