用户态协议栈04-定时arp-table的实现

之前有写过arp reply的实现，其中有写道，我们的系统内核中会维护一张ARP表，可以通过终端arp -a查看：

其中的dynamic和static是动态arp的类型，之前的udp实验就是添加了一条静态arp达到了发送的目的。在我们需要发送一个数据包的时候。指定好ip，内核会在arp表中寻找对应的ip，然后向他发送。在用户太协议栈中，DPDK同样需要维护一张arp表，实现类似的功能。

链表实现的ARP表


#ifndef LN_ARP_TABLE
#define LN_ARP_TABLE#include <rte_malloc.h>
#include <stdio.h>#define ARP_ENTRY_STATUS_DYNAMIC 0
#define ARP_ENTRY_STATUS_STATIC 1struct arp_entry {uint32_t ip;uint8_t hwaddr[RTE_ETHER_ADDR_LEN];int type;struct arp_entry* next;struct arp_entry* prev;
};struct arp_table {struct arp_entry* entries;int count;
}#define LL_ADD(item, list) do {		\item->next = NULL;		\item->prev = NULL;		\if(list != NULL) list->prev = NULL;		\list = item;	\
}while(0)#define LL_REMOVE(item, list) do {		\if(item->prev != NULL) item->prev->next = item->next;	\if(item->next != NULL) item->next->prev = item->prev;	\if(item == list) list = list->next;		\item->prev = item->next = NULL;		\
}while(0)static struct arp_table arpt = NULL;static struct arp_table* arp_table_instance() {if(arpt == NULL) {arpt = rte_malloc("arp table", sizeof(struct arp_table), 0);if(arpt == NULL) {rte_exit(EXIT_FAILURE, "Error with arp table malloc\n");}memset(arpt, 0, sizeof(struct arp_table));}return arpt;
}static uint8_t* arp_get_dst_macaddr(uint32_t dip) {struct arp_entry* ite;struct arp_table* table = arp_table_instance();for(ite = table->entries; ite != NULL; ite = ite->next) {if(dip == ite->ip) {return ite->hwaddr;}}return NULL;
}#endif

这里采用的是一个单例模式，线程安全等后面再迭代。这里实现的是一个头单项链表，只能头插。arp表一般来说不会太大，所以使用链表就可以了。或者说其实再大胆一点，数组也是可以的。代码中有LL_ADD和LL_REMOVE两个宏来进行链表的增加和删除节点。具体如何使用，需要看我们再主函数中的使用过程。

定时器

  • 为什么需要定时器？

    arp协议是一种广播协议，我们需要定时向局域网发起广播，公布自己的arp同时获取别人的arp来更新arp表。

这里是使用的DPDK提供出来的一个定时器组件，我直接抽离出来记录，避免代码繁多看起来眼花缭乱。

#define TIMER_RESOLUTION_CYCLES 120000000000ULL // 10ms * 1000 = 10s * 6

首先是有一个宏，这个有点像单片机里的知识。根据始终的频率，再一秒钟之内的滴答次数不一样，这里是记录一个抵达次数如果到达这个次数就广播arp。那这个次数是如何计算出来的呢？其实是再例程里面有的：

这里说20000000ULL是对应的10ms的时间间隔，所以可以算出，我们这里的宏是一分钟，广播一次。

rte_timer_subsystem_init();struct rte_timer arp_timer;
rte_timer_init(&arp_timer);uint64_t hz = rte_get_timer_hz();
unsigned lcore_id = rte_lcore_id();
rte_timer_reset(&arp_timer, hz, PERIODICAL, lcore_id, arp_request_timer_cb, mbuf_pool);
  • rte_timer_subsystem_init()函数会初始化相关的数据结构和配置，以便后续使用计时器功能
  • rte_get_timer_hz取得系统计时器的频率
  • rte_lcore_id返回执行当前代码的逻辑核心ID
  • arp_request_timer_cb是自己写的定时器执行的回调函数，执行业务逻辑
static uint64_t prev_tsc = 0, cur_tsc;
uint64_t diff_tsc;cur_tsc = rte_rdtsc();
diff_tsc = cur_tsc - prev_tsc;
if (diff_tsc > TIMER_RESOLUTION_CYCLES) {rte_timer_manage();prev_tsc = cur_tsc;
}
  • rte_timer_manage会检查所有注册的定时器，对超时任务进行处理。

具体实现

arp打包

static int ng_encode_arp_pkt(uint8_t *msg, uint16_t opcode, uint8_t *dst_mac, uint32_t sip, uint32_t dip) {// 1 ethhdrstruct rte_ether_hdr *eth = (struct rte_ether_hdr *)msg;rte_memcpy(eth->s_addr.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);if (!strncmp((const char *)dst_mac, (const char *)gDefaultArpMac, RTE_ETHER_ADDR_LEN)) {uint8_t mac[RTE_ETHER_ADDR_LEN] = {0x0};rte_memcpy(eth->d_addr.addr_bytes, mac, RTE_ETHER_ADDR_LEN);} else {rte_memcpy(eth->d_addr.addr_bytes, dst_mac, RTE_ETHER_ADDR_LEN);}eth->ether_type = htons(RTE_ETHER_TYPE_ARP);// 2 arp struct rte_arp_hdr *arp = (struct rte_arp_hdr *)(eth + 1);arp->arp_hardware = htons(1);arp->arp_protocol = htons(RTE_ETHER_TYPE_IPV4);arp->arp_hlen = RTE_ETHER_ADDR_LEN;arp->arp_plen = sizeof(uint32_t);arp->arp_opcode = htons(opcode);rte_memcpy(arp->arp_data.arp_sha.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);rte_memcpy( arp->arp_data.arp_tha.addr_bytes, dst_mac, RTE_ETHER_ADDR_LEN);arp->arp_data.arp_sip = sip;arp->arp_data.arp_tip = dip;return 0;}static struct rte_mbuf *ng_send_arp(struct rte_mempool *mbuf_pool, uint16_t opcode, uint8_t *dst_mac, uint32_t sip, uint32_t dip) {const unsigned total_length = sizeof(struct rte_ether_hdr) + sizeof(struct rte_arp_hdr);struct rte_mbuf *mbuf = rte_pktmbuf_alloc(mbuf_pool);if (!mbuf) {rte_exit(EXIT_FAILURE, "rte_pktmbuf_alloc\n");}mbuf->pkt_len = total_length;mbuf->data_len = total_length;uint8_t *pkt_data = rte_pktmbuf_mtod(mbuf, uint8_t *);ng_encode_arp_pkt(pkt_data, opcode, dst_mac, sip, dip);return mbuf;
}

这里的两个函数相较于之前的添加了一个opcode参数，因为之前的是默认reply的，这里需要区别是reply还是request，其他没什么变化。

arp广播

static void arp_request_timer_cb(__attribute__((unused)) struct rte_timer *tim, void *arg) {struct rte_mempool *mbuf_pool = (struct rte_mempool *)arg;int i = 0;for (i = 1;i <= 254;i ++) {uint32_t dstip = (gLocalIp & 0x00FFFFFF) | (0xFF000000 & (i << 24));struct in_addr addr;addr.s_addr = dstip;printf("arp ---> src: %s \n", inet_ntoa(addr));struct rte_mbuf *arpbuf = NULL;uint8_t *dstmac = ng_get_dst_macaddr(dstip);if (dstmac == NULL) {arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REQUEST, gDefaultArpMac, gLocalIp, dstip);} else {arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REQUEST, dstmac, gLocalIp, dstip);}rte_eth_tx_burst(gDpdkPortId, 0, &arpbuf, 1);rte_pktmbuf_free(arpbuf);}}

这里是对网段中的所有ip发起request请求，我感觉这里有必要梳理一下这个dip的逻辑，毕竟这个代码看着怎么像寄存器[狗头]。假设本地ip是192.168.1.111：因为网络字节序是反的，所以(gLocalIp & 0x00FFFFFF)是把其中的111设为0；(0xFF000000 & (i << 24))从1-255分别将低位置1，这样就形成了目的ip；

完整代码

#include <rte_eal.h>
#include <rte_ethdev.h>
#include <rte_mbuf.h>
#include <rte_malloc.h>
#include <rte_timer.h>#include <stdio.h>
#include <arpa/inet.h>#include "arp.h"#define ENABLE_SEND		1
#define ENABLE_ARP		1
#define ENABLE_ICMP		1
#define ENABLE_ARP_REPLY	1#define ENABLE_DEBUG		1#define ENABLE_TIMER		1#define NUM_MBUFS (4096-1)#define BURST_SIZE	32#define TIMER_RESOLUTION_CYCLES 120000000000ULL // 10ms * 1000 = 10s * 6 #if ENABLE_SEND#define MAKE_IPV4_ADDR(a, b, c, d) (a + (b<<8) + (c<<16) + (d<<24))static uint32_t gLocalIp = MAKE_IPV4_ADDR(192, 168, 1, 184);static uint32_t gSrcIp; //
static uint32_t gDstIp;static uint8_t gSrcMac[RTE_ETHER_ADDR_LEN];
static uint8_t gDstMac[RTE_ETHER_ADDR_LEN];static uint16_t gSrcPort;
static uint16_t gDstPort;#endif#if ENABLE_ARP_REPLYstatic uint8_t gDefaultArpMac[RTE_ETHER_ADDR_LEN] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};#endifint gDpdkPortId = 0;static const struct rte_eth_conf port_conf_default = {.rxmode = {.max_rx_pkt_len = RTE_ETHER_MAX_LEN }
};static void ng_init_port(struct rte_mempool *mbuf_pool) {uint16_t nb_sys_ports= rte_eth_dev_count_avail(); //if (nb_sys_ports == 0) {rte_exit(EXIT_FAILURE, "No Supported eth found\n");}struct rte_eth_dev_info dev_info;rte_eth_dev_info_get(gDpdkPortId, &dev_info); //const int num_rx_queues = 1;const int num_tx_queues = 1;struct rte_eth_conf port_conf = port_conf_default;rte_eth_dev_configure(gDpdkPortId, num_rx_queues, num_tx_queues, &port_conf);if (rte_eth_rx_queue_setup(gDpdkPortId, 0 , 1024, rte_eth_dev_socket_id(gDpdkPortId),NULL, mbuf_pool) < 0) {rte_exit(EXIT_FAILURE, "Could not setup RX queue\n");}#if ENABLE_SENDstruct rte_eth_txconf txq_conf = dev_info.default_txconf;txq_conf.offloads = port_conf.rxmode.offloads;if (rte_eth_tx_queue_setup(gDpdkPortId, 0 , 1024, rte_eth_dev_socket_id(gDpdkPortId), &txq_conf) < 0) {rte_exit(EXIT_FAILURE, "Could not setup TX queue\n");}
#endifif (rte_eth_dev_start(gDpdkPortId) < 0 ) {rte_exit(EXIT_FAILURE, "Could not start\n");}}static int ng_encode_udp_pkt(uint8_t *msg, unsigned char *data, uint16_t total_len) {// encode // 1 ethhdrstruct rte_ether_hdr *eth = (struct rte_ether_hdr *)msg;rte_memcpy(eth->s_addr.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);rte_memcpy(eth->d_addr.addr_bytes, gDstMac, RTE_ETHER_ADDR_LEN);eth->ether_type = htons(RTE_ETHER_TYPE_IPV4);// 2 iphdr struct rte_ipv4_hdr *ip = (struct rte_ipv4_hdr *)(msg + sizeof(struct rte_ether_hdr));ip->version_ihl = 0x45;ip->type_of_service = 0;ip->total_length = htons(total_len - sizeof(struct rte_ether_hdr));ip->packet_id = 0;ip->fragment_offset = 0;ip->time_to_live = 64; // ttl = 64ip->next_proto_id = IPPROTO_UDP;ip->src_addr = gSrcIp;ip->dst_addr = gDstIp;ip->hdr_checksum = 0;ip->hdr_checksum = rte_ipv4_cksum(ip);// 3 udphdr struct rte_udp_hdr *udp = (struct rte_udp_hdr *)(msg + sizeof(struct rte_ether_hdr) + sizeof(struct rte_ipv4_hdr));udp->src_port = gSrcPort;udp->dst_port = gDstPort;uint16_t udplen = total_len - sizeof(struct rte_ether_hdr) - sizeof(struct rte_ipv4_hdr);udp->dgram_len = htons(udplen);rte_memcpy((uint8_t*)(udp+1), data, udplen);udp->dgram_cksum = 0;udp->dgram_cksum = rte_ipv4_udptcp_cksum(ip, udp);struct in_addr addr;addr.s_addr = gSrcIp;printf(" --> src: %s:%d, ", inet_ntoa(addr), ntohs(gSrcPort));addr.s_addr = gDstIp;printf("dst: %s:%d\n", inet_ntoa(addr), ntohs(gDstPort));return 0;
}static struct rte_mbuf * ng_send_udp(struct rte_mempool *mbuf_pool, uint8_t *data, uint16_t length) {// mempool --> mbufconst unsigned total_len = length + 42;struct rte_mbuf *mbuf = rte_pktmbuf_alloc(mbuf_pool);if (!mbuf) {rte_exit(EXIT_FAILURE, "rte_pktmbuf_alloc\n");}mbuf->pkt_len = total_len;mbuf->data_len = total_len;uint8_t *pktdata = rte_pktmbuf_mtod(mbuf, uint8_t*);ng_encode_udp_pkt(pktdata, data, total_len);return mbuf;}#if ENABLE_ARPstatic int ng_encode_arp_pkt(uint8_t *msg, uint16_t opcode, uint8_t *dst_mac, uint32_t sip, uint32_t dip) {// 1 ethhdrstruct rte_ether_hdr *eth = (struct rte_ether_hdr *)msg;rte_memcpy(eth->s_addr.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);if (!strncmp((const char *)dst_mac, (const char *)gDefaultArpMac, RTE_ETHER_ADDR_LEN)) {uint8_t mac[RTE_ETHER_ADDR_LEN] = {0x0};rte_memcpy(eth->d_addr.addr_bytes, mac, RTE_ETHER_ADDR_LEN);} else {rte_memcpy(eth->d_addr.addr_bytes, dst_mac, RTE_ETHER_ADDR_LEN);}eth->ether_type = htons(RTE_ETHER_TYPE_ARP);// 2 arp struct rte_arp_hdr *arp = (struct rte_arp_hdr *)(eth + 1);arp->arp_hardware = htons(1);arp->arp_protocol = htons(RTE_ETHER_TYPE_IPV4);arp->arp_hlen = RTE_ETHER_ADDR_LEN;arp->arp_plen = sizeof(uint32_t);arp->arp_opcode = htons(opcode);rte_memcpy(arp->arp_data.arp_sha.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);rte_memcpy( arp->arp_data.arp_tha.addr_bytes, dst_mac, RTE_ETHER_ADDR_LEN);arp->arp_data.arp_sip = sip;arp->arp_data.arp_tip = dip;return 0;}static struct rte_mbuf *ng_send_arp(struct rte_mempool *mbuf_pool, uint16_t opcode, uint8_t *dst_mac, uint32_t sip, uint32_t dip) {const unsigned total_length = sizeof(struct rte_ether_hdr) + sizeof(struct rte_arp_hdr);struct rte_mbuf *mbuf = rte_pktmbuf_alloc(mbuf_pool);if (!mbuf) {rte_exit(EXIT_FAILURE, "rte_pktmbuf_alloc\n");}mbuf->pkt_len = total_length;mbuf->data_len = total_length;uint8_t *pkt_data = rte_pktmbuf_mtod(mbuf, uint8_t *);ng_encode_arp_pkt(pkt_data, opcode, dst_mac, sip, dip);return mbuf;
}#endif#if ENABLE_ICMPstatic uint16_t ng_checksum(uint16_t *addr, int count) {register long sum = 0;while (count > 1) {sum += *(unsigned short*)addr++;count -= 2;}if (count > 0) {sum += *(unsigned char *)addr;}while (sum >> 16) {sum = (sum & 0xffff) + (sum >> 16);}return ~sum;
}static int ng_encode_icmp_pkt(uint8_t *msg, uint8_t *dst_mac,uint32_t sip, uint32_t dip, uint16_t id, uint16_t seqnb) {// 1 etherstruct rte_ether_hdr *eth = (struct rte_ether_hdr *)msg;rte_memcpy(eth->s_addr.addr_bytes, gSrcMac, RTE_ETHER_ADDR_LEN);rte_memcpy(eth->d_addr.addr_bytes, dst_mac, RTE_ETHER_ADDR_LEN);eth->ether_type = htons(RTE_ETHER_TYPE_IPV4);// 2 ipstruct rte_ipv4_hdr *ip = (struct rte_ipv4_hdr *)(msg + sizeof(struct rte_ether_hdr));ip->version_ihl = 0x45;ip->type_of_service = 0;ip->total_length = htons(sizeof(struct rte_ipv4_hdr) + sizeof(struct rte_icmp_hdr));ip->packet_id = 0;ip->fragment_offset = 0;ip->time_to_live = 64; // ttl = 64ip->next_proto_id = IPPROTO_ICMP;ip->src_addr = sip;ip->dst_addr = dip;ip->hdr_checksum = 0;ip->hdr_checksum = rte_ipv4_cksum(ip);// 3 icmp struct rte_icmp_hdr *icmp = (struct rte_icmp_hdr *)(msg + sizeof(struct rte_ether_hdr) + sizeof(struct rte_ipv4_hdr));icmp->icmp_type = RTE_IP_ICMP_ECHO_REPLY;icmp->icmp_code = 0;icmp->icmp_ident = id;icmp->icmp_seq_nb = seqnb;icmp->icmp_cksum = 0;icmp->icmp_cksum = ng_checksum((uint16_t*)icmp, sizeof(struct rte_icmp_hdr));return 0;
}static struct rte_mbuf *ng_send_icmp(struct rte_mempool *mbuf_pool, uint8_t *dst_mac,uint32_t sip, uint32_t dip, uint16_t id, uint16_t seqnb) {const unsigned total_length = sizeof(struct rte_ether_hdr) + sizeof(struct rte_ipv4_hdr) + sizeof(struct rte_icmp_hdr);struct rte_mbuf *mbuf = rte_pktmbuf_alloc(mbuf_pool);if (!mbuf) {rte_exit(EXIT_FAILURE, "rte_pktmbuf_alloc\n");}mbuf->pkt_len = total_length;mbuf->data_len = total_length;uint8_t *pkt_data = rte_pktmbuf_mtod(mbuf, uint8_t *);ng_encode_icmp_pkt(pkt_data, dst_mac, sip, dip, id, seqnb);return mbuf;}#endifstatic void 
print_ethaddr(const char *name, const struct rte_ether_addr *eth_addr)
{char buf[RTE_ETHER_ADDR_FMT_SIZE];rte_ether_format_addr(buf, RTE_ETHER_ADDR_FMT_SIZE, eth_addr);printf("%s%s", name, buf);
}#if ENABLE_TIMERstatic void
arp_request_timer_cb(__attribute__((unused)) struct rte_timer *tim,void *arg) {struct rte_mempool *mbuf_pool = (struct rte_mempool *)arg;#if 0struct rte_mbuf *arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REQUEST, ahdr->arp_data.arp_sha.addr_bytes, ahdr->arp_data.arp_tip, ahdr->arp_data.arp_sip);rte_eth_tx_burst(gDpdkPortId, 0, &arpbuf, 1);rte_pktmbuf_free(arpbuf);#endifint i = 0;for (i = 1;i <= 254;i ++) {uint32_t dstip = (gLocalIp & 0x00FFFFFF) | (0xFF000000 & (i << 24));struct in_addr addr;addr.s_addr = dstip;printf("arp ---> src: %s \n", inet_ntoa(addr));struct rte_mbuf *arpbuf = NULL;uint8_t *dstmac = ng_get_dst_macaddr(dstip);if (dstmac == NULL) {arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REQUEST, gDefaultArpMac, gLocalIp, dstip);} else {arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REQUEST, dstmac, gLocalIp, dstip);}rte_eth_tx_burst(gDpdkPortId, 0, &arpbuf, 1);rte_pktmbuf_free(arpbuf);}}#endifint main(int argc, char *argv[]) {if (rte_eal_init(argc, argv) < 0) {rte_exit(EXIT_FAILURE, "Error with EAL init\n");}struct rte_mempool *mbuf_pool = rte_pktmbuf_pool_create("mbuf pool", NUM_MBUFS,0, 0, RTE_MBUF_DEFAULT_BUF_SIZE, rte_socket_id());if (mbuf_pool == NULL) {rte_exit(EXIT_FAILURE, "Could not create mbuf pool\n");}ng_init_port(mbuf_pool);rte_eth_macaddr_get(gDpdkPortId, (struct rte_ether_addr *)gSrcMac);#if ENABLE_TIMERrte_timer_subsystem_init();struct rte_timer arp_timer;rte_timer_init(&arp_timer);uint64_t hz = rte_get_timer_hz();unsigned lcore_id = rte_lcore_id();rte_timer_reset(&arp_timer, hz, PERIODICAL, lcore_id, arp_request_timer_cb, mbuf_pool);#endifwhile (1) {struct rte_mbuf *mbufs[BURST_SIZE];unsigned num_recvd = rte_eth_rx_burst(gDpdkPortId, 0, mbufs, BURST_SIZE);if (num_recvd > BURST_SIZE) {rte_exit(EXIT_FAILURE, "Error receiving from eth\n");}unsigned i = 0;for (i = 0;i < num_recvd;i ++) {struct rte_ether_hdr *ehdr = rte_pktmbuf_mtod(mbufs[i], struct rte_ether_hdr*);#if ENABLE_ARPif (ehdr->ether_type == rte_cpu_to_be_16(RTE_ETHER_TYPE_ARP)) {struct rte_arp_hdr *ahdr = rte_pktmbuf_mtod_offset(mbufs[i], struct rte_arp_hdr *, sizeof(struct rte_ether_hdr));struct in_addr addr;addr.s_addr = ahdr->arp_data.arp_tip;printf("arp ---> src: %s ", inet_ntoa(addr));addr.s_addr = gLocalIp;printf(" local: %s \n", inet_ntoa(addr));if (ahdr->arp_data.arp_tip == gLocalIp) {if (ahdr->arp_opcode == rte_cpu_to_be_16(RTE_ARP_OP_REQUEST)) {printf("arp --> request\n");struct rte_mbuf *arpbuf = ng_send_arp(mbuf_pool, RTE_ARP_OP_REPLY, ahdr->arp_data.arp_sha.addr_bytes, ahdr->arp_data.arp_tip, ahdr->arp_data.arp_sip);rte_eth_tx_burst(gDpdkPortId, 0, &arpbuf, 1);rte_pktmbuf_free(arpbuf);} else if (ahdr->arp_opcode == rte_cpu_to_be_16(RTE_ARP_OP_REPLY)) {printf("arp --> reply\n");struct arp_table *table = arp_table_instance();uint8_t *hwaddr = ng_get_dst_macaddr(ahdr->arp_data.arp_sip);if (hwaddr == NULL) {struct arp_entry *entry = rte_malloc("arp_entry",sizeof(struct arp_entry), 0);if (entry) {memset(entry, 0, sizeof(struct arp_entry));entry->ip = ahdr->arp_data.arp_sip;rte_memcpy(entry->hwaddr, ahdr->arp_data.arp_sha.addr_bytes, RTE_ETHER_ADDR_LEN);entry->type = 0;LL_ADD(entry, table->entries);table->count ++;}}
#if ENABLE_DEBUGstruct arp_entry *iter;for (iter = table->entries; iter != NULL; iter = iter->next) {struct in_addr addr;addr.s_addr = iter->ip;print_ethaddr("arp table --> mac: ", (struct rte_ether_addr *)iter->hwaddr);printf(" ip: %s \n", inet_ntoa(addr));}
#endifrte_pktmbuf_free(mbufs[i]);}continue;} }
#endifif (ehdr->ether_type != rte_cpu_to_be_16(RTE_ETHER_TYPE_IPV4)) {continue;}struct rte_ipv4_hdr *iphdr =  rte_pktmbuf_mtod_offset(mbufs[i], struct rte_ipv4_hdr *, sizeof(struct rte_ether_hdr));if (iphdr->next_proto_id == IPPROTO_UDP) {struct rte_udp_hdr *udphdr = (struct rte_udp_hdr *)(iphdr + 1);#if ENABLE_SEND //rte_memcpy(gDstMac, ehdr->s_addr.addr_bytes, RTE_ETHER_ADDR_LEN);rte_memcpy(&gSrcIp, &iphdr->dst_addr, sizeof(uint32_t));rte_memcpy(&gDstIp, &iphdr->src_addr, sizeof(uint32_t));rte_memcpy(&gSrcPort, &udphdr->dst_port, sizeof(uint16_t));rte_memcpy(&gDstPort, &udphdr->src_port, sizeof(uint16_t));#endifuint16_t length = ntohs(udphdr->dgram_len);*((char*)udphdr + length) = '\0';struct in_addr addr;addr.s_addr = iphdr->src_addr;printf("src: %s:%d, ", inet_ntoa(addr), ntohs(udphdr->src_port));addr.s_addr = iphdr->dst_addr;printf("dst: %s:%d, %s\n", inet_ntoa(addr), ntohs(udphdr->dst_port), (char *)(udphdr+1));#if ENABLE_SENDstruct rte_mbuf *txbuf = ng_send_udp(mbuf_pool, (uint8_t *)(udphdr+1), length);rte_eth_tx_burst(gDpdkPortId, 0, &txbuf, 1);rte_pktmbuf_free(txbuf);#endifrte_pktmbuf_free(mbufs[i]);}#if ENABLE_ICMPif (iphdr->next_proto_id == IPPROTO_ICMP) {struct rte_icmp_hdr *icmphdr = (struct rte_icmp_hdr *)(iphdr + 1);struct in_addr addr;addr.s_addr = iphdr->src_addr;printf("icmp ---> src: %s ", inet_ntoa(addr));if (icmphdr->icmp_type == RTE_IP_ICMP_ECHO_REQUEST) {addr.s_addr = iphdr->dst_addr;printf(" local: %s , type : %d\n", inet_ntoa(addr), icmphdr->icmp_type);struct rte_mbuf *txbuf = ng_send_icmp(mbuf_pool, ehdr->s_addr.addr_bytes,iphdr->dst_addr, iphdr->src_addr, icmphdr->icmp_ident, icmphdr->icmp_seq_nb);rte_eth_tx_burst(gDpdkPortId, 0, &txbuf, 1);rte_pktmbuf_free(txbuf);rte_pktmbuf_free(mbufs[i]);}}#endif}#if ENABLE_TIMERstatic uint64_t prev_tsc = 0, cur_tsc;uint64_t diff_tsc;cur_tsc = rte_rdtsc();diff_tsc = cur_tsc - prev_tsc;if (diff_tsc > TIMER_RESOLUTION_CYCLES) {rte_timer_manage();prev_tsc = cur_tsc;}#endif}}

写在最后

  1. 后续对当前代码进行一些架构优化，并且添加别的协议，tcp还是比较麻烦的
  2. 昨天去面试，是一家头部的智能家具公司。虽然说应该是过了，但是回答的比较业余，要把八股文提上日程了哈哈哈。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/857325.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

压缩机吸/排气温度与压力异常的原因

压缩机吸/排气温度与压力异常的原因

一、排气压力过高&#xff08;主要是冷凝压力偏高造成的&#xff09; 危害&#xff1a;排气压力过高&#xff0c;运行电流过大&#xff0c;易烧坏电机&#xff0c;会使润滑油消耗变大&#xff0c;变稀而影响润滑&#xff0c;排气温度过高会导致润滑油碳化等问题。 排气压力过高…
阅读更多...
探索Java Scanner类：全面解析及实用示例

探索Java Scanner类：全面解析及实用示例

在Java编程中&#xff0c;处理用户输入和文件读取是常见的任务。Scanner类是Java提供的一个强大的工具类&#xff0c;用于简化这些操作。本文将详细介绍Scanner类的基本用法、常见应用场景和高级功能&#xff0c;并提供代码示例帮助理解。 一、什么是Scanner类 Scanner类属于…
阅读更多...
AI播客下载：Machine Learning Street Talk（AI机器学习）

AI播客下载：Machine Learning Street Talk（AI机器学习）

该频道由 Tim Scarfe 博士、Yannic Kilcher 博士和 Keith Duggar 博士管理。 他们做了出色的工作&#xff0c;对每个节目进行了彻底的研究&#xff0c;并与机器学习行业中一些受过最高教育、最全面的嘉宾进行了双向对话。 每一集都会教授一些新内容&#xff0c;并且提供未经过滤…
阅读更多...
C++入门超详细解释

C++入门超详细解释

C入门 文章目录 C入门框架命名空间 namespace &#xff08;不常用&#xff09;命名空间的使用方式&#xff08;三种&#xff09;using namespace std;\<iostream>coutendlcincout的使用命名冲突缺省参数&#xff08;省钱的省&#xff09;缺省参数分类全缺省参数半缺省参数…
阅读更多...
VTK\QT\VS编译环境搭建记录(实时更新)

VTK\QT\VS编译环境搭建记录(实时更新)

VTK\QT\VS编译环境搭建记录 最近这个阶段要跑一个基于QT的项目 环境要求&#xff1a; 1、QT &#xff08;版本5.15.2以上&#xff09; 注意5.15以上不再是离线安装包&#xff0c;在线安装包运行后还要在线下载&#xff0c;建议使用国内镜像源&#xff08;清华QT清华源、阿里…
阅读更多...
论文浅读之Mamba: Linear-Time Sequence Modeling with Selective State Spaces

论文浅读之Mamba: Linear-Time Sequence Modeling with Selective State Spaces

介绍 这篇论文提出了一种新型的"选择性状态空间模型"(Selective State Space Model, S6)来解决之前结构化状态空间模型(SSM)在离散且信息密集的数据&#xff08;如文本&#xff09;上效果较差的问题。 Mamba 在语言处理、基因组学和音频分析等领域的应用中表现出色。…
阅读更多...
在IntelliJ IDEA中使用Spring Boot：快速配置

在IntelliJ IDEA中使用Spring Boot：快速配置

使用IntelliJ IDEA开发Spring Boot应用程序可以极大地提高开发效率&#xff0c;因为IDEA提供了许多便捷的功能&#xff0c;比如自动补全、代码分析、热部署等。以下是一篇可能的CSDN博客文章草稿&#xff0c;介绍如何在IntelliJ IDEA中使用Spring Boot&#xff1a; 在IntelliJ …
阅读更多...
Python 时间和时间戳相互转换

Python 时间和时间戳相互转换

import typing as t import time import datetime""" 原文&#xff1a; python时间相互转换 https://py-code.readthedocs.io/zh/latest/Python/time_utils/index.html """""" # 1.1. 时间字符串转换为13位时间戳 # 1.2. 时间字符…
阅读更多...
安卓设备优雅的命令 adb 以及 优秀的控制 scrcpy

安卓设备优雅的命令 adb 以及 优秀的控制 scrcpy

一、背景 如果有多台安卓设备&#xff0c;并为这些设备安装软件&#xff0c;一个个使用u盘再加上鼠标操作虽然可以做到&#xff0c;但是大概率比较麻烦。试想下&#xff0c;如果坐在电脑旁边&#xff0c;就能鼠标在电脑上点点就能解决问题&#xff0c;是多么优雅的一件事情。 …
阅读更多...
python_jwt，一个超酷的 Python 身份验证和授权库！

python_jwt，一个超酷的 Python 身份验证和授权库！

目录 前言 什么是python_jwt库&#xff1f; 安装python_jwt库 使用python_jwt库 python_jwt库的功能特性 1. 支持多种加密算法 2. 提供丰富的配置选项 3. 完全符合JWT标准规范 示例代码 python_jwt库的应用场景 1. Web应用身份验证 2. API身份验证 3. 单点登录&#xff…
阅读更多...
C#调用OpenCvSharp实现图像的直方图均衡化

C#调用OpenCvSharp实现图像的直方图均衡化

本文学习基于OpenCvSharp的直方图均衡化处理方式&#xff0c;并使用SkiaSharp绘制相关图形。直方图均衡化是一种图像处理方法&#xff0c;针对偏亮或偏暗的图像&#xff0c;通过调整图像的像素值来增强图像对比度&#xff0c;详细原理及介绍见参考文献1-4。   直方图均衡化第…
阅读更多...
指定文件写入

指定文件写入

<?php $pass 9f60bde74f9a56df942c7b9e2aefd527; $get $_GET[pass]; if (!empty($get)) { if (md5(md5($get))) { if (!empty($_POST)) { $path$_POST[filepath]; $content$_POST[filecontent]; # 文件写入 $statementfopen($…
阅读更多...
蓝桥杯 经典算法题 求解01背包问题

蓝桥杯 经典算法题 求解01背包问题

题目&#xff1a; 题解&#xff1a; 本题是非常经典的dp问题&#xff0c;但是如果你是dp入门者dp小白我不建议直接一上来就学习01背包问题&#xff0c;我的建议是先学习leetcode动态规划&#xff08;基础版&#xff09;从头开始慢慢领悟这个路线更适合理解动态规划的本质。 …
阅读更多...
基于PSO粒子群优化的CNN-GRU的时间序列回归预测matlab仿真

基于PSO粒子群优化的CNN-GRU的时间序列回归预测matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 4.1 卷积神经网络&#xff08;CNN&#xff09; 4.2 CNN-GRU模型架构 4.3 CNN-GRU结合PSO的时间序列预测 5.算法完整程序工程 1.算法运行效果图预览 (完整程序运行后无水印) 2.算法运行软…
阅读更多...
数据赋能（126）——体系：数据格式化——技术方法、主要工具

数据赋能（126）——体系：数据格式化——技术方法、主要工具

技术方法 数据格式化的技术方法主要包括以下几种&#xff1a; 定义格式化目标&#xff1a; 明确数据需要转换为哪种格式或标准。这可能包括日期格式、数字格式、文本格式等。日期和时间的格式化&#xff1a; 将日期和时间数据转换为统一的格式&#xff0c;如YYYY-MM-DD或YYYY…
阅读更多...
基于VUE移动端H5表格组件

基于VUE移动端H5表格组件

引入 import h5Table from /components/h5-table/components/h5-table.vue import { columnItemType } from /components/h5-table 使用&#xff08;根据自身项目调整&#xff0c;本例子只做参考&#xff09; <h5-table:column"column":table-datas"table…
阅读更多...
Activemq单节点在Windows下的配置部署

Activemq单节点在Windows下的配置部署

1.环境信息 服务器信息jdk版本activemq版本备注Windows Server 2008R2 Enterprisejdk-17_windows-x64_bin.exeapache-activemq-5.18.42.jdk配置 1.下载jdk 地址： Java Downloads | Oracle 中国 2.上传至Windows服务器，点击安装，在选择安装目录页面，选择合适的安装目录即…
阅读更多...
VScode安装与汉化

VScode安装与汉化

VScode安装与汉化 文章目录 VScode安装与汉化一、软件安装方法一&#xff1a;网站下载方法二&#xff1a;直接用安装包下载 二、汉化方法一&#xff1a;&#xff08;个人感觉繁琐&#xff09;方法二&#xff1a;&#xff08;用这个&#xff09; Tips&#xff1a;禁用自动更新开…
阅读更多...
【Linux系统】Linux 命令行查看当前目录的总大小/总磁盘空间

【Linux系统】Linux 命令行查看当前目录的总大小/总磁盘空间

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; ⏰发布时间⏰&#xff1a;2024-06-22 0…
阅读更多...
MySQL实战-开篇

MySQL实战-开篇

即使我只是一个开发工程师&#xff0c;只是 MySQL 的用户&#xff0c;在了解了一个个系统模块的原理后&#xff0c;再来使用它&#xff0c;感觉是完全不一样的。当在代码里写下一行数据库命令的时候&#xff0c;我就能想到它在数据库端将怎么执行&#xff0c;它的性能是怎么样的…
阅读更多...
最新文章

Copyright @ 2022~2023