summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_port_memory.c
diff options
context:
space:
mode:
authorMax Romanov <max.romanov@nginx.com>2022-06-07 13:59:45 +0800
committerMax Romanov <max.romanov@nginx.com>2022-06-07 13:59:45 +0800
commitb4540f0960a54908a6bca9c2bd091c239ae76a53 (patch)
tree88876a81f5c4b01f09ffe452e90a169c1f100c54 /src/nxt_port_memory.c
parentdf421e36b368c9595e8adedc078b69f3f0c2466b (diff)
downloadunit-b4540f0960a54908a6bca9c2bd091c239ae76a53.tar.gz
unit-b4540f0960a54908a6bca9c2bd091c239ae76a53.tar.bz2
Removing unused tracking fields and functions.
The message tracking is unused since 1d84b9e4b459 commit. This fixes the issue found by Coverity (CID 376263).
Diffstat (limited to 'src/nxt_port_memory.c')
-rw-r--r--src/nxt_port_memory.c131
1 files changed, 0 insertions, 131 deletions
diff --git a/src/nxt_port_memory.c b/src/nxt_port_memory.c
index e799f860..0a4a6c53 100644
--- a/src/nxt_port_memory.c
+++ b/src/nxt_port_memory.c
@@ -539,137 +539,6 @@ nxt_port_get_port_incoming_mmap(nxt_task_t *task, nxt_pid_t spid, uint32_t id)
}
-nxt_int_t
-nxt_port_mmap_get_tracking(nxt_task_t *task, nxt_port_mmaps_t *mmaps,
- nxt_port_mmap_tracking_t *tracking, uint32_t stream)
-{
- nxt_chunk_id_t c;
- nxt_port_mmap_header_t *hdr;
- nxt_port_mmap_handler_t *mmap_handler;
-
- nxt_debug(task, "request tracking for stream #%uD", stream);
-
- mmap_handler = nxt_port_mmap_get(task, mmaps, &c, 1, 1);
- if (nxt_slow_path(mmap_handler == NULL)) {
- return NXT_ERROR;
- }
-
- nxt_port_mmap_handler_use(mmap_handler, 1);
-
- hdr = mmap_handler->hdr;
-
- tracking->mmap_handler = mmap_handler;
- tracking->tracking = hdr->tracking + c;
-
- *tracking->tracking = stream;
-
- nxt_debug(task, "outgoing tracking allocation: %PI->%PI,%d,%d",
- hdr->src_pid, hdr->dst_pid, hdr->id, c);
-
- return NXT_OK;
-}
-
-
-nxt_bool_t
-nxt_port_mmap_tracking_cancel(nxt_task_t *task,
- nxt_port_mmap_tracking_t *tracking, uint32_t stream)
-{
- nxt_bool_t res;
- nxt_chunk_id_t c;
- nxt_port_mmap_header_t *hdr;
- nxt_port_mmap_handler_t *mmap_handler;
-
- mmap_handler = tracking->mmap_handler;
-
- if (nxt_slow_path(mmap_handler == NULL)) {
- return 0;
- }
-
- hdr = mmap_handler->hdr;
-
- res = nxt_atomic_cmp_set(tracking->tracking, stream, 0);
-
- nxt_debug(task, "%s tracking for stream #%uD",
- (res ? "cancelled" : "failed to cancel"), stream);
-
- if (!res) {
- c = tracking->tracking - hdr->tracking;
- nxt_port_mmap_set_chunk_free(hdr->free_tracking_map, c);
- }
-
- nxt_port_mmap_handler_use(mmap_handler, -1);
-
- return res;
-}
-
-
-nxt_int_t
-nxt_port_mmap_tracking_write(uint32_t *buf, nxt_port_mmap_tracking_t *t)
-{
- nxt_port_mmap_handler_t *mmap_handler;
-
- mmap_handler = t->mmap_handler;
-
-#if (NXT_DEBUG)
- {
- nxt_atomic_t *tracking;
-
- tracking = mmap_handler->hdr->tracking;
-
- nxt_assert(t->tracking >= tracking);
- nxt_assert(t->tracking < tracking + PORT_MMAP_CHUNK_COUNT);
- }
-#endif
-
- buf[0] = mmap_handler->hdr->id;
- buf[1] = t->tracking - mmap_handler->hdr->tracking;
-
- return NXT_OK;
-}
-
-nxt_bool_t
-nxt_port_mmap_tracking_read(nxt_task_t *task, nxt_port_recv_msg_t *msg)
-{
- nxt_buf_t *b;
- nxt_bool_t res;
- nxt_chunk_id_t c;
- nxt_port_mmap_header_t *hdr;
- nxt_port_mmap_handler_t *mmap_handler;
- nxt_port_mmap_tracking_msg_t *tracking_msg;
-
- b = msg->buf;
-
- if (nxt_buf_used_size(b) < (int) sizeof(nxt_port_mmap_tracking_msg_t)) {
- nxt_debug(task, "too small message %O", nxt_buf_used_size(b));
- return 0;
- }
-
- tracking_msg = (nxt_port_mmap_tracking_msg_t *) b->mem.pos;
-
- b->mem.pos += sizeof(nxt_port_mmap_tracking_msg_t);
- mmap_handler = nxt_port_get_port_incoming_mmap(task, msg->port_msg.pid,
- tracking_msg->mmap_id);
-
- if (nxt_slow_path(mmap_handler == NULL)) {
- return 0;
- }
-
- hdr = mmap_handler->hdr;
-
- c = tracking_msg->tracking_id;
- res = nxt_atomic_cmp_set(hdr->tracking + c, msg->port_msg.stream, 0);
-
- nxt_debug(task, "tracking for stream #%uD %s", msg->port_msg.stream,
- (res ? "received" : "already cancelled"));
-
- if (!res) {
- nxt_port_mmap_set_chunk_free(hdr->free_tracking_map, c);
- }
-
- return res;
-}
-
-
nxt_buf_t *
nxt_port_mmap_get_buf(nxt_task_t *task, nxt_port_mmaps_t *mmaps, size_t size)
{