发件人：
while (true)
{
sendResult = sendto(sockFD,txBuffer,fSize+headersLength,(struct sockaddr*)&socket_address,sizeof socket_address);
}
接收器：
while (true)
{
recvfrom(sockFD,rxBuffer,fSizeTotal,NULL,NULL);
}
我希望发件人能够检查收到的数据包;如果接收方应用程序退出,它会将数据发送回发送方,说“我退出”,因此发送方将停止发送数据.我在发送器上使用poll()来检查接收到的消息,如下所示,但这显着降低了传输速度,从1Gbps(968Mbps)到大约10Mbps.我正在使用1Gbps网卡的两台PC之间使用交叉电缆进行测试.发送方计算发送的帧数和帧大小,接收方计算接收到的帧数和帧大小,因此要确认,应用程序实际上是以接近线速接收,我不只是看看NIC利用率或类似情况.
民意调查()方法：
int rv;
struct pollfd ufds[1];
ufds[0].fd = sockFD;
ufds[0].events = POLLIN
while (true)
{
sendResult = sendto(sockFD,sizeof(socket_address));
// wait for events on the sockets,1ms timeout
rv = poll(ufds,1,1);
if (rv > 0) {
if (ufds[0].revents & POLLIN) {
recvfrom(sockFD,NULL);
}
}
}
1毫秒是可以为poll()方法设置的最低超时.这就是我的传输程序只能以10Mbps传输的原因.虽然cpu使用率最低,但应用程序可以很容易地使1Gbps链路饱和,我之前提到的速度达到了968Mbps(顺便说一下,这并不意味着峰值,即持续吞吐量).
我删除了poll()调用,并使用下面的示例切换到select(),但同样,使用最小的延迟,我可以在这里传输应用程序只能获得175Mbps.不接近原来的968Mbps;
选择()方法：
fd_set readfds;
struct timeval tv;
int rv,n;
FD_ZERO(&readfds);
FD_SET(sockFD,&readfds);
n = sockFD + 1;
while (true)
{
sendResult = sendto(sockFD,sizeof(socket_address));
tv.tv_sec = 0;
tv.tv_usec = 000001;
rv = select(n,&readfds,&tv);
if (rv > 0) {
if (FD_ISSET(sockFD,&readfds)) {
recvfrom(sockFD,NULL);
}
}
对于今天的系统来说,这两种方法似乎都太慢了(对于上面的所有测试,我的cpu使用率约为2％).我希望尽快将这个应用程序移到一些10GigE机器上并开始测试,但我显然不能使用这两种方法中的任何一种.有没有更快的方法可以检查？
我虽然这些应该是非阻塞的,但是由于要求超时,它们会在某种程度上阻塞;我见过this thread,但这不是我要求的答案.有没有方法我可以在调用它的那个时刻简单地调用那些检查,等待读取数据,然后如果没有数据等待读取则立即返回？
作为一个副节点,我还没有读过recvfrom方法()来查看发布之前延迟的位置但是我确实尝试了以下因为它只需要30秒来更改代码,结果导致最坏的结果低于1Mbps;
发件人：
while (true)
{
// Continually send a frame then check for a frame,send a frame then check for a frame...
sendResult = sendto(sockFD,sizeof(socket_address));
recvfrom(sockFD,NULL);
}
