diff options
| author | Andrei Belov <defan@nginx.com> | 2021-12-02 18:42:23 +0300 |
|---|---|---|
| committer | Andrei Belov <defan@nginx.com> | 2021-12-02 18:42:23 +0300 |
| commit | 7634ab0f21c712e79c5d09e5817f866ff71d4f49 (patch) | |
| tree | 1c4b20be29a9372858088c9faa3f02e7f584402f /src/nxt_unit.c | |
| parent | 5dfde9717d9ef611072defdd211089efa920c728 (diff) | |
| parent | 85908c09f9b7d8d0bd797427d984e2697ece8267 (diff) | |
| download | unit-7634ab0f21c712e79c5d09e5817f866ff71d4f49.tar.gz unit-7634ab0f21c712e79c5d09e5817f866ff71d4f49.tar.bz2 | |
Merged with the 1.26 branch.1.26.1-1
Diffstat (limited to 'src/nxt_unit.c')
| -rw-r--r-- | src/nxt_unit.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/nxt_unit.c b/src/nxt_unit.c index 06ad1636..135c06ed 100644 --- a/src/nxt_unit.c +++ b/src/nxt_unit.c @@ -937,9 +937,9 @@ nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, lib = nxt_container_of(ctx->unit, nxt_unit_impl_t, unit); + recv_msg.incoming_buf = NULL; recv_msg.fd[0] = -1; recv_msg.fd[1] = -1; - port_msg = (nxt_port_msg_t *) rbuf->buf; rc = nxt_socket_msg_oob_get_fds(&rbuf->oob, recv_msg.fd); if (nxt_slow_path(rc != NXT_OK)) { @@ -948,8 +948,6 @@ nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, goto done; } - recv_msg.incoming_buf = NULL; - if (nxt_slow_path(rbuf->size < (ssize_t) sizeof(nxt_port_msg_t))) { if (nxt_slow_path(rbuf->size == 0)) { nxt_unit_debug(ctx, "read port closed"); @@ -965,6 +963,8 @@ nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, goto done; } + port_msg = (nxt_port_msg_t *) rbuf->buf; + nxt_unit_debug(ctx, "#%"PRIu32": process message %d fd[0] %d fd[1] %d", port_msg->stream, (int) port_msg->type, recv_msg.fd[0], recv_msg.fd[1]); |