feature: remove the ltx tunnel.

2 files changed, 24 insertions, 7 deletions

diff --git a/app/src/monit.c b/app/src/monit.c
index 225c6c2..a169ab7 100644
--- a/app/src/monit.c
+++ b/app/src/monit.c
@@ -14,7 +14,6 @@ int vdev_instance_stats_get(struct vdev_instance * vdi, struct vdev_stat_info *
     struct vnode_cons_stat * st_cons_rx = NULL;
     struct vnode_prod_stat * st_prod_tx = NULL;
     struct vnode_prod_stat * st_prod_ftx = NULL;
-    struct vnode_prod_stat * st_prod_ltx = NULL;
 
     stat_info->nr_rxstream = vdi->nr_rxstream;
     stat_info->nr_txstream = vdi->nr_txstream;
@@ -28,7 +27,6 @@ int vdev_instance_stats_get(struct vdev_instance * vdi, struct vdev_stat_info *
     {
         st_prod_tx = vnode_mirror_prod_stat_get(vdi->vnode_tx_prod);
         st_prod_ftx = vnode_mirror_prod_stat_get(vdi->vnode_ftx_prod);
-        st_prod_ltx = vnode_mirror_prod_stat_get(vdi->vnode_ltx_prod);
     }
 
     for (int i = 0; i < vdi->nr_rxstream; i++)
@@ -53,11 +51,6 @@ int vdev_instance_stats_get(struct vdev_instance * vdi, struct vdev_stat_info *
         stat_info->ftx_deliver[i] = VNODE_STAT_READ(&st_prod_ftx[i].deliver);
         stat_info->ftx_missed[i] = VNODE_STAT_READ(&st_prod_ftx[i].missed);
         stat_info->ftx_total_len[i] = VNODE_STAT_READ(&st_prod_ftx[i].total_len);
-
-        stat_info->ltx_on_line[i] = VNODE_STAT_READ(&st_prod_ltx[i].on_line);
-        stat_info->ltx_deliver[i] = VNODE_STAT_READ(&st_prod_ltx[i].deliver);
-        stat_info->ltx_missed[i] = VNODE_STAT_READ(&st_prod_ltx[i].missed);
-        stat_info->ltx_total_len[i] = VNODE_STAT_READ(&st_prod_ltx[i].total_len);
     }
 
     return 0;
diff --git a/app/src/mrb.c b/app/src/mrb.c
index 6465160..b96899a 100644
--- a/app/src/mrb.c
+++ b/app/src/mrb.c
@@ -709,6 +709,15 @@ int marsio_buff_get_metadata(marsio_buff_t * m, enum mr_buff_metadata_type type,
 
     switch (type)
     {
+    case MR_BUFF_REHASH_INDEX:
+        if (unlikely(sz_data < sizeof(uint32_t)))
+        {
+            return -ENOMEM;
+        }
+
+        *(uint32_t *)(data) = (uint32_t)mbuf->hash.usr;
+        return sizeof(uint32_t);
+
     case MR_BUFF_ROUTE_CTX: {
         if (unlikely(sz_data < sizeof(struct mrb_metadata_route_ctx)))
         {
@@ -793,6 +802,16 @@ int marsio_buff_set_metadata(marsio_buff_t * m, enum mr_buff_metadata_type type,
 
     switch (type)
     {
+    case MR_BUFF_REHASH_INDEX:
+        if (unlikely(sz_data < sizeof(uint32_t)))
+        {
+            return -ENOMEM;
+        }
+
+        mbuf->hash.usr = *(uint32_t *)data;
+        return 0;
+
+
     case MR_BUFF_METADATA_VLAN_TCI:
         if (unlikely(sz_data < sizeof(uint16_t)))
         {
@@ -835,6 +854,11 @@ int marsio_buff_set_metadata(marsio_buff_t * m, enum mr_buff_metadata_type type,
         return 0;
     }
 
+    case MR_BUFF_DIR: {
+        mrb_metadata->dir = *(unsigned int *)data;
+        return 0;
+    }
+
     case MR_BUFF_PAYLOAD_OFFSET: {
         mrb_metadata->payload_offset = *(uint16_t *)data;
         return 0;