common code: KW fixes for common code
[samplevnf.git] / common / VIL / pipeline_arpicmp / pipeline_arpicmp_be.c
index 1dbf34a..6176813 100644 (file)
@@ -50,6 +50,7 @@
 #include "lib_arp.h"
 #include "lib_icmpv6.h"
 #include "interface.h"
+#include "gateway.h"
 
 /* Shared among all VNFs including LB */
 struct app_params *myApp;
@@ -209,7 +210,7 @@ void register_pipeline_Qs(uint8_t pipeline_num, struct pipeline *p)
                switch (myApp->pipeline_params[pipeline_num].
                         pktq_in[port_count].type){
 
-               case APP_PKTQ_OUT_HWQ:
+               case APP_PKTQ_IN_HWQ:
                         hwq = rte->ports_in[port_count].h_port;
                         out_swq = rte->ports_out[port_count].h_port;
                         printf("out_swq: %s\n",
@@ -229,7 +230,7 @@ void register_pipeline_Qs(uint8_t pipeline_num, struct pipeline *p)
                        }
                break;
 
-               case APP_PKTQ_OUT_SWQ:
+               case APP_PKTQ_IN_SWQ:
                         in_swq = rte->ports_in[port_count].h_port;
                         out_swq = rte->ports_out[port_count].h_port;
                         printf("in_swq : %s\n",
@@ -431,7 +432,7 @@ void set_phy_inport_id(uint8_t pipeline_num, struct pipeline *p, uint8_t *map)
                switch (myApp->pipeline_params[pipeline_num].
                        pktq_in[port_count].type) {
 
-               case APP_PKTQ_OUT_HWQ:
+               case APP_PKTQ_IN_HWQ:
                        hwq = rte->ports_in[port_count].h_port;
                        map[hwq->port_id] = index++;
                        printf("outport_id[%d]:%d\n", index - 1,
@@ -811,7 +812,7 @@ static void *pipeline_arpicmp_init(struct pipeline_params *params,
 
        p_arp->receivedPktCount = 0;
        p_arp->droppedPktCount = 0;
-
+       gw_init(rte_eth_dev_count());
        lib_arp_init(params, app);
 
        /* Pipeline */