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)
 {