1

最近在做一个以高速率(超过 500Mbitps)转发数据包的项目。我尝试了 2 种方法,但它们不起作用。主机是一个vm,ubuntu-11.10 32bit,网卡是r8169,1000Mb。

  1. 我使用带有 buff 的 raw sock,其大小取决于接收到的数据包的大小(不超过 1500)。我将 sendto 函数放入循环中(while(1)),确保它可以尽可能快地发送。但发送速度远低于r8169所能做到的速度,大约是100-200Mbitps。我可以假设套接字不能进行高速率发送吗?但是为什么像Iperf 以及使用socket 能表现得更好呢?或者我可以做些什么来加快发送速度?

  2. 我在内核中使用了 dev_queue_xmit()。我使用 schedule() 将函数放入 kthread 中的循环 (while(1)) 中。但发送速度竟然不超过300Mbitps。我知道调用 dev_queue_xmit 可能不是一个好主意,但我仍然不明白为什么速度那么低?

请,需要帮助..

或者任何人都可以为我提供高速转发数据包的经典解决方案?我的插座很简单:

int sockfd = socket(AF_PACKET, SOCK_RAW, htons(ETH_P_IP)/*IPPROTO_RAW*/);
struct ifreq if_idx;
char ifName[IFNAMSIZ];
struct sockaddr_ll socket_address;
char buf[1400];
struct packet_mreq mr;
struct ether_header *eh;
int ret = 0;
struct ifreq if_mac;

strcpy(ifName, "eth1");//used for sending
memset(&if_idx, 0, sizeof(struct ifreq));
strncpy(if_idx.ifr_name, ifName, IFNAMSIZ-1);
if (ioctl(sockfd, SIOCGIFINDEX, &if_idx) < 0)
    perror("SIOCGIFINDEX\n");
memset(&if_mac, 0, sizeof(struct ifreq));
strncpy(if_mac.ifr_name, ifName, IFNAMSIZ-1);
if (ioctl(sockfd, SIOCGIFHWADDR, &if_mac) < 0)
    perror("SIOCGIFHWADDR\n");

socket_address.sll_ifindex = if_idx.ifr_ifindex;
/* Address length*/
socket_address.sll_halen = ETH_ALEN;
/* Destination MAC */
socket_address.sll_family = AF_PACKET;
socket_address.sll_protocol = htons(0xA000);
socket_address.sll_addr[0] = 0x00;
socket_address.sll_addr[1] = 0x24;
socket_address.sll_addr[2] = 0xe8;
socket_address.sll_addr[3] = 0x82;
socket_address.sll_addr[4] = 0xec;
socket_address.sll_addr[5] = 0x82;
printf("%d\n",bind(sockfd, (struct sockaddr *) &socket_address, sizeof(socket_address))); 

memset (&mr, 0, sizeof(mr));
mr.mr_ifindex = if_idx.ifr_ifindex;
//mr.mr_type = PACKET_MR_PROMISC;
setsockopt(sockfd, SOL_PACKET, PACKET_ADD_MEMBERSHIP, &mr,sizeof(mr));

eh = (struct ether_header *)buf;
eh->ether_shost[0] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[0];
eh->ether_shost[1] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[1];
eh->ether_shost[2] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[2];
eh->ether_shost[3] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[3];
eh->ether_shost[4] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[4];
eh->ether_shost[5] = ((uint8_t *)&if_mac.ifr_hwaddr.sa_data)[5];
eh->ether_dhost[0] = 0x00;
eh->ether_dhost[1] = 0x24;
eh->ether_dhost[2] = 0xe8;
eh->ether_dhost[3] = 0x82;
eh->ether_dhost[4] = 0xec;
eh->ether_dhost[5] = 0x82;
eh->ether_type = htons(0xA000);
while(1)
    ret = write(sockfd,buf,1000);
printf("%d\n",ret);
return 0;
4

1 回答 1

0

您是否看过writev()允许您提供多个缓冲区?您是否从文件中获取数据?如果是这样,您可能需要调查 sendfile()。

于 2013-05-23T07:54:16.347 回答