1 files changed, 229 insertions, 0 deletions
diff --git a/src/nSocket/nstack_rd/nstack_rd_type.c b/src/nSocket/nstack_rd/nstack_rd_type.c
new file mode 100644
index 0000000..c5f440e
--- /dev/null
+++ b/src/nSocket/nstack_rd/nstack_rd_type.c
@@ -0,0 +1,229 @@
+/*
+*
+* Copyright (c) 2018 Huawei Technologies Co.,Ltd.
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at:
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+#include <stdlib.h>
+#include <arpa/inet.h>
+#include "nstack_rd_data.h"
+#include "nstack_rd.h"
+#include "nstack_rd_priv.h"
+#include "nstack_rd_type.h"
+#include "nstack_log.h"
+#include "nstack_securec.h"
+
+/*copy rd data*/
+int nstack_rd_type_data_cpy(void *destdata, void *srcdata)
+{
+    rd_data_item *pitem = (rd_data_item *) destdata;
+    rd_route_data *pdata = (rd_route_data *) srcdata;
+
+    pitem->type = pdata->type;
+    pitem->type_data.value = pdata->type_data.value;
+    pitem->type_data.attr = pdata->type_data.attr;
+    pitem->type_data.reserved[0] = pdata->type_data.reserved[0];
+    pitem->type_data.reserved[1] = pdata->type_data.reserved[1];
+    pitem->type_data.reserved[2] = pdata->type_data.reserved[2];
+    pitem->type_data.reserved[3] = pdata->type_data.reserved[3];
+    return NSTACK_RD_SUCCESS;
+}
+
+/*
+ * Add an ip segment to the list and sort it in descending order of ip mask length
+ * If the list already exists in the same list of ip side, then stack_id update
+ *ip is network byte order
+ */
+/*vars are used in macro*/
+int nstack_rd_type_item_insert(nstack_rd_list * hlist, void *rditem)
+{
+    nstack_rd_node *pdatanode = NULL;
+    nstack_rd_node *tempdata = NULL;
+    struct hlist_node *tempnode = NULL;
+    rd_data_item *pitem = (rd_data_item *) rditem;
+
+    NSSOC_LOGDBG("stackid:%d, type value:%u type attr:%u was inserted",
+                 pitem->stack_id, pitem->type_data.value,
+                 pitem->type_data.attr);
+
+    pdatanode = (nstack_rd_node *) malloc(sizeof(nstack_rd_node));      /*this function is necessary */
+    if (!pdatanode)
+    {
+        NSSOC_LOGERR("nstack rd item malloc fail");
+        return NSTACK_RD_FAIL;
+    }
+    /* add return value check */
+    int retVal = memset_s(pdatanode, sizeof(nstack_rd_node), 0,
+                          sizeof(nstack_rd_node));
+    if (EOK != retVal)
+    {
+        NSSOC_LOGERR("memset_s failed]retVal=%d", retVal);
+        free(pdatanode);        /*this function is necessary */
+        return NSTACK_RD_FAIL;
+    }
+    INIT_HLIST_NODE(&pdatanode->rdnode);
+    NSTACK_RD_TYPE_ITEM_COPY(&(pdatanode->item), pitem);
+
+    if (hlist_empty(&(hlist->headlist)))
+    {
+        hlist_add_head(&(pdatanode->rdnode), &(hlist->headlist));
+
+        return NSTACK_RD_SUCCESS;
+
+    }
+
+    hlist_for_each_entry(tempdata, tempnode, &(hlist->headlist), rdnode)
+    {
+        if (tempdata->item.type_data.value == pitem->type_data.value)
+        {
+            NSSOC_LOGDBG
+                ("find duplicate node, type value:%u, old stack_id:%d, new stack_id:%d",
+                 pitem->type_data.value, tempdata->item.stack_id,
+                 pitem->stack_id);
+            tempdata->item.stack_id = pitem->stack_id;
+            tempdata->item.agetime = NSTACK_RD_AGETIME_MAX;
+            free(pdatanode);    /*this function is necessary */
+            return NSTACK_RD_SUCCESS;
+        }
+    }
+    hlist_add_head(&(pdatanode->rdnode), &(hlist->headlist));
+
+    return NSTACK_RD_SUCCESS;
+
+}
+
+/*
+ *find stackid by ip
+ *input ip must be network order
+ */
+int nstack_rd_type_item_find(nstack_rd_list * hlist, void *rdkey,
+                             void *outitem)
+{
+    struct hlist_node *tempnode = NULL;
+    nstack_rd_node *tempdata = NULL;
+    nstack_rd_key *key = (nstack_rd_key *) rdkey;
+    rd_data_item *pitem = (rd_data_item *) outitem;
+
+    hlist_for_each_entry(tempdata, tempnode, &(hlist->headlist), rdnode)
+    {
+        if (tempdata->item.type_data.value == key->socket_type)
+        {
+            NSTACK_RD_TYPE_ITEM_COPY(pitem, &(tempdata->item));
+            return NSTACK_RD_SUCCESS;
+        }
+    }
+
+    /* Optimize log */
+    NSSOC_LOGDBG("socket type:%u item not found", key->socket_type);
+
+    return NSTACK_RD_FAIL;
+}
+
+/*****************************************************************************
+*   Prototype    : nstack_rd_ip_item_age
+*   Description  : delete the ip item that have not been add again for one time
+*   Input        : nstack_rd_list *hlist
+*   Output       : None
+*   Return Value : int
+*   Calls        :
+*   Called By    :
+*****************************************************************************/
+int nstack_rd_type_item_age(nstack_rd_list * hlist)
+{
+    struct hlist_node *tempnode = NULL;
+    nstack_rd_node *tempdata = NULL;
+    nstack_rd_node *prevdata = NULL;
+    struct hlist_node *prevnode = NULL;
+    NSSOC_LOGINF("nstack rd type age begin");
+    hlist_for_each_entry(tempdata, tempnode, &(hlist->headlist), rdnode)
+    {
+        /*if agetime equal 0, remove it */
+        if (tempdata->item.agetime <= 0)
+        {
+            if (prevdata)
+            {
+                /* Optimize log */
+                NSSOC_LOGDBG("stackid=%d, type:%u was aged",
+                             tempdata->item.stack_id,
+                             tempdata->item.type_data.value);
+
+                hlist_del_init(prevnode);
+                free(prevdata); /*this function is necessary */
+            }
+            prevdata = tempdata;
+            prevnode = tempnode;
+        }
+        else
+        {
+            tempdata->item.agetime--;
+        }
+    }
+    if (prevdata)
+    {
+        if (tempdata)
+        {
+            /* Optimize log */
+            NSSOC_LOGDBG("stackid:%d, type:%u was last aged",
+                         tempdata->item.stack_id,
+                         tempdata->item.type_data.value);
+        }
+        hlist_del_init(prevnode);
+        free(prevdata);         /*this function is necessary */
+    }
+    NSSOC_LOGINF("nstack rd type age end");
+    return NSTACK_RD_SUCCESS;
+}
+
+void nstack_rd_type_item_clean(nstack_rd_list * hlist)
+{
+    struct hlist_node *tempnode = NULL;
+    nstack_rd_node *tempdata = NULL;
+    nstack_rd_node *prevdata = NULL;
+    struct hlist_node *prevnode = NULL;
+    NSSOC_LOGINF("nstack rd type item clean begin");
+    hlist_for_each_entry(tempdata, tempnode, &(hlist->headlist), rdnode)
+    {
+        if (prevdata)
+        {
+            NSSOC_LOGDBG("stackid=%d, type:%u was cleaned",
+                         tempdata->item.stack_id,
+                         tempdata->item.type_data.value);
+            hlist_del_init(prevnode);
+            free(prevdata);     /*this function is necessary */
+        }
+
+        prevdata = tempdata;
+        prevnode = tempnode;
+    }
+    if (prevdata)
+    {
+        if (tempdata)
+        {
+            NSSOC_LOGDBG("stackid=%d, type:%u was last cleaned",
+                         tempdata->item.stack_id,
+                         tempdata->item.type_data.value);
+        }
+        hlist_del_init(prevnode);
+        free(prevdata);         /*this function is necessary */
+    }
+    NSSOC_LOGINF("nstack rd type item clean end");
+}
+
+/*
+ *find stackid by spec ip(multicast ip)
+ *input ip must be network order
+ */
+int nstack_rd_type_spec(void *rdkey)
+{
+    return -1;
+}