summaryrefslogtreecommitdiffhomepage
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/nxt_application.c8
-rw-r--r--src/nxt_conn_accept.c3
-rw-r--r--src/nxt_conn_connect.c3
-rw-r--r--src/nxt_http_request.c3
-rw-r--r--src/nxt_listen_socket.c2
-rw-r--r--src/nxt_main_process.c14
-rw-r--r--src/nxt_router.c6
-rw-r--r--src/nxt_sockaddr.c4
-rw-r--r--src/nxt_socket.c12
-rw-r--r--src/nxt_sprintf.c2
-rw-r--r--src/nxt_stream_module.c3
-rw-r--r--src/nxt_upstream_round_robin.c2
-rw-r--r--src/test/nxt_http_parse_test.c5
13 files changed, 39 insertions, 28 deletions
diff --git a/src/nxt_application.c b/src/nxt_application.c
index 69f68616..462767f3 100644
--- a/src/nxt_application.c
+++ b/src/nxt_application.c
@@ -476,7 +476,8 @@ nxt_app_msg_write(nxt_task_t *task, nxt_app_wmsg_t *msg, u_char *c, size_t size)
nxt_memcpy(dst, c, size);
dst[size] = 0;
- nxt_debug(task, "nxt_app_msg_write: %uz %*s", size, (int) size, c);
+ nxt_debug(task, "nxt_app_msg_write: %uz %*s", size, size, c);
+
} else {
dst_length = 1;
@@ -598,8 +599,9 @@ nxt_app_msg_read_str(nxt_task_t *task, nxt_app_rmsg_t *msg, nxt_str_t *str)
buf->mem.pos += length;
- nxt_debug(task, "nxt_read_str: %d %*s", (int) length - 1,
- (int) length - 1, str->start);
+ nxt_debug(task, "nxt_read_str: %uz %*s", length - 1,
+ length - 1, str->start);
+
} else {
str->start = NULL;
str->length = 0;
diff --git a/src/nxt_conn_accept.c b/src/nxt_conn_accept.c
index f2a50301..80b599b4 100644
--- a/src/nxt_conn_accept.c
+++ b/src/nxt_conn_accept.c
@@ -189,7 +189,8 @@ nxt_conn_accept(nxt_task_t *task, nxt_listen_event_t *lev, nxt_conn_t *c)
nxt_sockaddr_text(c->remote);
nxt_debug(task, "client: %*s",
- c->remote->address_length, nxt_sockaddr_address(c->remote));
+ (size_t) c->remote->address_length,
+ nxt_sockaddr_address(c->remote));
nxt_queue_insert_head(&task->thread->engine->idle_connections, &c->link);
diff --git a/src/nxt_conn_connect.c b/src/nxt_conn_connect.c
index 94d25c30..a5736226 100644
--- a/src/nxt_conn_connect.c
+++ b/src/nxt_conn_connect.c
@@ -155,7 +155,8 @@ nxt_conn_connect_test(nxt_task_t *task, void *obj, void *data)
c->socket.error = err;
nxt_log(task, nxt_socket_error_level(err), "connect(%d, %*s) failed %E",
- c->socket.fd, c->remote->length, nxt_sockaddr_start(c->remote));
+ c->socket.fd, (size_t) c->remote->length,
+ nxt_sockaddr_start(c->remote));
nxt_conn_connect_error(task, c, data);
}
diff --git a/src/nxt_http_request.c b/src/nxt_http_request.c
index 270ebba7..9c7d4451 100644
--- a/src/nxt_http_request.c
+++ b/src/nxt_http_request.c
@@ -375,7 +375,8 @@ nxt_http_request_close_handler(nxt_task_t *task, void *obj, void *data)
r->logged = 1;
// STUB
nxt_debug(task, "http request log: \"%*s \"%V %V %V\" %d\"",
- r->remote->address_length, nxt_sockaddr_address(r->remote),
+ (size_t) r->remote->address_length,
+ nxt_sockaddr_address(r->remote),
r->method, &r->target, &r->version, r->status);
}
diff --git a/src/nxt_listen_socket.c b/src/nxt_listen_socket.c
index 7521fec1..6e8ea586 100644
--- a/src/nxt_listen_socket.c
+++ b/src/nxt_listen_socket.c
@@ -305,5 +305,5 @@ nxt_listen_socket_log_handler(void *ctx, u_char *pos, u_char *end)
sa = ctx;
return nxt_sprintf(pos, end, " while creating listening socket on %*s",
- sa->length, sa->start);
+ (size_t) sa->length, sa->start);
}
diff --git a/src/nxt_main_process.c b/src/nxt_main_process.c
index aa935a96..af72c111 100644
--- a/src/nxt_main_process.c
+++ b/src/nxt_main_process.c
@@ -870,13 +870,13 @@ nxt_main_port_socket_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
msg->port_msg.reply_port);
nxt_debug(task, "listening socket \"%*s\"",
- sa->length, nxt_sockaddr_start(sa));
+ (size_t) sa->length, nxt_sockaddr_start(sa));
ret = nxt_main_listening_socket(sa, &ls);
if (ret == NXT_OK) {
nxt_debug(task, "socket(\"%*s\"): %d",
- sa->length, nxt_sockaddr_start(sa), ls.socket);
+ (size_t) sa->length, nxt_sockaddr_start(sa), ls.socket);
type = NXT_PORT_MSG_RPC_READY_LAST | NXT_PORT_MSG_CLOSE_FD;
@@ -927,7 +927,7 @@ nxt_main_listening_socket(nxt_sockaddr_t *sa, nxt_listening_socket_t *ls)
ls->end = nxt_sprintf(ls->start, ls->end,
"socket(\\\"%*s\\\") failed %E",
- sa->length, nxt_sockaddr_start(sa), err);
+ (size_t) sa->length, nxt_sockaddr_start(sa), err);
return NXT_ERROR;
}
@@ -935,7 +935,8 @@ nxt_main_listening_socket(nxt_sockaddr_t *sa, nxt_listening_socket_t *ls)
if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &enable, length) != 0) {
ls->end = nxt_sprintf(ls->start, ls->end,
"setsockopt(\\\"%*s\\\", SO_REUSEADDR) failed %E",
- sa->length, nxt_sockaddr_start(sa), nxt_errno);
+ (size_t) sa->length, nxt_sockaddr_start(sa),
+ nxt_errno);
goto fail;
}
@@ -946,7 +947,8 @@ nxt_main_listening_socket(nxt_sockaddr_t *sa, nxt_listening_socket_t *ls)
if (setsockopt(s, IPPROTO_IPV6, IPV6_V6ONLY, &enable, length) != 0) {
ls->end = nxt_sprintf(ls->start, ls->end,
"setsockopt(\\\"%*s\\\", IPV6_V6ONLY) failed %E",
- sa->length, nxt_sockaddr_start(sa), nxt_errno);
+ (size_t) sa->length, nxt_sockaddr_start(sa),
+ nxt_errno);
goto fail;
}
}
@@ -992,7 +994,7 @@ nxt_main_listening_socket(nxt_sockaddr_t *sa, nxt_listening_socket_t *ls)
}
ls->end = nxt_sprintf(ls->start, ls->end, "bind(\\\"%*s\\\") failed %E",
- sa->length, nxt_sockaddr_start(sa), err);
+ (size_t) sa->length, nxt_sockaddr_start(sa), err);
goto fail;
}
diff --git a/src/nxt_router.c b/src/nxt_router.c
index a09dd498..a2effb57 100644
--- a/src/nxt_router.c
+++ b/src/nxt_router.c
@@ -713,7 +713,7 @@ nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
nxt_debug(task, "nxt_router_conf_data_handler(%d): %*s",
nxt_buf_used_size(msg->buf),
- nxt_buf_used_size(msg->buf), msg->buf->mem.pos);
+ (size_t) nxt_buf_used_size(msg->buf), msg->buf->mem.pos);
b = nxt_buf_chk_make_plain(tmcf->conf->mem_pool, msg->buf, msg->size);
@@ -1384,7 +1384,7 @@ nxt_router_socket_conf(nxt_task_t *task, nxt_router_temp_conf_t *tmcf,
sa->type = SOCK_STREAM;
nxt_debug(task, "router listener: \"%*s\"",
- sa->length, nxt_sockaddr_start(sa));
+ (size_t) sa->length, nxt_sockaddr_start(sa));
skcf = nxt_mp_zget(tmcf->conf->mem_pool, sizeof(nxt_socket_conf_t));
if (nxt_slow_path(skcf == NULL)) {
@@ -1615,7 +1615,7 @@ nxt_router_listen_socket_error(nxt_task_t *task, nxt_port_recv_msg_t *msg,
out->mem.free = nxt_sprintf(out->mem.free, out->mem.end,
"listen socket error: "
"{listener: \"%*s\", code:\"%V\", message: \"%*s\"}",
- sa->length, nxt_sockaddr_start(sa),
+ (size_t) sa->length, nxt_sockaddr_start(sa),
&socket_errors[error], in->mem.free - p, p);
nxt_debug(task, "%*s", out->mem.free - out->mem.pos, out->mem.pos);
diff --git a/src/nxt_sockaddr.c b/src/nxt_sockaddr.c
index af2b8674..cd8a2cd2 100644
--- a/src/nxt_sockaddr.c
+++ b/src/nxt_sockaddr.c
@@ -287,7 +287,7 @@ nxt_sockaddr_text(nxt_sockaddr_t *sa)
#if (NXT_LINUX)
if (p[0] == '\0') {
- int length;
+ size_t length;
/* Linux abstract socket address has no trailing zero. */
length = sa->socklen - offsetof(struct sockaddr_un, sun_path);
@@ -478,7 +478,7 @@ nxt_sockaddr_ntop(nxt_sockaddr_t *sa, u_char *buf, u_char *end, nxt_bool_t port)
p = (u_char *) sa->u.sockaddr_un.sun_path;
if (p[0] == '\0') {
- int length;
+ size_t length;
/* Linux abstract socket address has no trailing zero. */
diff --git a/src/nxt_socket.c b/src/nxt_socket.c
index b9bbac46..529d7f7d 100644
--- a/src/nxt_socket.c
+++ b/src/nxt_socket.c
@@ -190,7 +190,8 @@ nxt_socket_bind(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa,
{
nxt_err_t err;
- nxt_debug(task, "bind(%d, %*s)", s, sa->length, nxt_sockaddr_start(sa));
+ nxt_debug(task, "bind(%d, %*s)", s, (size_t) sa->length,
+ nxt_sockaddr_start(sa));
if (nxt_fast_path(bind(s, &sa->u.sockaddr, sa->socklen) == 0)) {
return NXT_OK;
@@ -203,7 +204,7 @@ nxt_socket_bind(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa,
}
nxt_log(task, NXT_LOG_CRIT, "bind(%d, %*s) failed %E",
- s, sa->length, nxt_sockaddr_start(sa), err);
+ s, (size_t) sa->length, nxt_sockaddr_start(sa), err);
return NXT_ERROR;
}
@@ -216,7 +217,8 @@ nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa)
nxt_int_t ret;
nxt_uint_t level;
- nxt_debug(task, "connect(%d, %*s)", s, sa->length, nxt_sockaddr_start(sa));
+ nxt_debug(task, "connect(%d, %*s)",
+ s, (size_t) sa->length, nxt_sockaddr_start(sa));
if (connect(s, &sa->u.sockaddr, sa->socklen) == 0) {
return NXT_OK;
@@ -228,7 +230,7 @@ nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa)
case NXT_EINPROGRESS:
nxt_debug(task, "connect(%d, %*s) in progress",
- s, sa->length, nxt_sockaddr_start(sa));
+ s, (size_t) sa->length, nxt_sockaddr_start(sa));
return NXT_AGAIN;
case NXT_ECONNREFUSED:
@@ -258,7 +260,7 @@ nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa)
}
nxt_log(task, level, "connect(%d, %*s) failed %E",
- s, sa->length, nxt_sockaddr_start(sa), err);
+ s, (size_t) sa->length, nxt_sockaddr_start(sa), err);
return ret;
}
diff --git a/src/nxt_sprintf.c b/src/nxt_sprintf.c
index c07b44da..5f0314f2 100644
--- a/src/nxt_sprintf.c
+++ b/src/nxt_sprintf.c
@@ -163,7 +163,7 @@ nxt_vsprintf(u_char *buf, u_char *end, const char *fmt, va_list args)
continue;
case '*':
- length = va_arg(args, u_int);
+ length = va_arg(args, size_t);
fmt++;
diff --git a/src/nxt_stream_module.c b/src/nxt_stream_module.c
index 461928c9..25aaec57 100644
--- a/src/nxt_stream_module.c
+++ b/src/nxt_stream_module.c
@@ -65,7 +65,8 @@ nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up)
up->sockaddr->type = SOCK_STREAM;
nxt_log_debug(c->socket.log, "stream connection peer %*s",
- up->sockaddr->length, nxt_sockaddr_start(up->sockaddr));
+ (size_t) up->sockaddr->length,
+ nxt_sockaddr_start(up->sockaddr));
p = nxt_conn_proxy_create(c);
if (nxt_slow_path(p == NULL)) {
diff --git a/src/nxt_upstream_round_robin.c b/src/nxt_upstream_round_robin.c
index 089f22b1..09a3bce3 100644
--- a/src/nxt_upstream_round_robin.c
+++ b/src/nxt_upstream_round_robin.c
@@ -99,7 +99,7 @@ nxt_upstream_round_robin_create(nxt_task_t *task, void *obj, void *data)
nxt_sockaddr_text(sa);
nxt_debug(task, "upstream peer: %*s",
- sa->length, nxt_sockaddr_start(sa));
+ (size_t) sa->length, nxt_sockaddr_start(sa));
/* TODO: memcpy to shared memory pool. */
peer[i].sockaddr = sa;
diff --git a/src/test/nxt_http_parse_test.c b/src/test/nxt_http_parse_test.c
index 3da10766..3b924614 100644
--- a/src/test/nxt_http_parse_test.c
+++ b/src/test/nxt_http_parse_test.c
@@ -712,8 +712,9 @@ nxt_http_parse_test_request_line(nxt_http_request_parse_t *rp,
if (nxt_memcmp(rp->version.str, test->version, 8) != 0) {
nxt_log_alert(log, "http parse test case failed:\n"
" - request:\n\"%V\"\n"
- " - version: \"%*s\" (expected: \"%*s\")",
- request, 8, rp->version.str, 8, test->version);
+ " - version: \"%*s\" (expected: \"%*s\")", request,
+ (size_t) 8, rp->version.str,
+ (size_t) 8, test->version);
return NXT_ERROR;
}
generated by cgit (git 2.34.1) at 2024-11-17 23:35:06 +0000