-int32_t xran_ethdi_filter_packet(struct rte_mbuf *pkt, uint64_t rx_time);
-int32_t process_dpdk_io(void);
+int32_t xran_ethdi_filter_packet(struct rte_mbuf *pkt[], uint16_t vf_id, uint16_t q_id, uint16_t num);
+int32_t process_dpdk_io(void* args);
+int32_t process_dpdk_io_tx(void* args);
+int32_t process_dpdk_io_rx(void* args);
+
+struct rte_flow * generate_ecpri_flow(uint16_t port_id, uint16_t rx_q, uint16_t pc_id_be, struct rte_flow_error *error);
+