diff options
| author | Max Romanov <max.romanov@nginx.com> | 2018-02-20 19:00:30 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2018-02-20 19:00:30 +0300 |
| commit | babf67712e4226527730e2fb8c96babdf5486ca5 (patch) | |
| tree | 732d50d6a28ffb5c8263bdedc66c8c9a7d42ba6d /src/nxt_port_socket.c | |
| parent | ee39da0e00423d2e4f109f90142c3543e819c14d (diff) | |
| download | unit-babf67712e4226527730e2fb8c96babdf5486ca5.tar.gz unit-babf67712e4226527730e2fb8c96babdf5486ca5.tar.bz2 | |
Removed unwanted assertions.
Diffstat (limited to 'src/nxt_port_socket.c')
| -rw-r--r-- | src/nxt_port_socket.c | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/nxt_port_socket.c b/src/nxt_port_socket.c index 04f9c30c..65096177 100644 --- a/src/nxt_port_socket.c +++ b/src/nxt_port_socket.c @@ -676,7 +676,7 @@ nxt_port_frag_find(nxt_task_t *task, nxt_port_t *port, uint32_t stream, return lhq.value; default: - nxt_log(task, NXT_LOG_WARN, "frag stream #%uD not found", stream); + nxt_log(task, NXT_LOG_INFO, "frag stream #%uD not found", stream); return NULL; } @@ -719,7 +719,9 @@ nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, fmsg = nxt_port_frag_find(task, port, msg->port_msg.stream, msg->port_msg.mf == 0); - nxt_assert(fmsg != NULL); + if (nxt_slow_path(fmsg == NULL)) { + goto fmsg_failed; + } if (nxt_fast_path(fmsg->cancelled == 0)) { @@ -757,7 +759,9 @@ nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, fmsg = nxt_port_frag_start(task, port, msg); - nxt_assert(fmsg != NULL); + if (nxt_slow_path(fmsg == NULL)) { + goto fmsg_failed; + } fmsg->port_msg.nf = 0; fmsg->port_msg.mf = 0; @@ -785,6 +789,8 @@ nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, } } +fmsg_failed: + if (msg->port_msg.mmap && orig_b != b) { /* |