就像标题所说的我正在尝试制作一个数据包路由器,但它被卡在select()上。我使用的是一个带有4个主机(H1,H2,H3,R0),3个开关(S1,S2,S3)和3个接口(R0-ETH1,R0-ETH2,R0-ETH3)的挖掘环境。我正在编译C代码并在R0上运行可执行文件。这是代码:
int main(int argc, char *argv[])
{
int sock1, sock2, sock3;
int status = 0;
fd_set readfds;
int buffer[256];
// Create 3 sockets
if ((sock1 = socket(AF_PACKET, SOCK_DGRAM, htons(ETH_P_IP))) < 0){
perror("socket() failed");
exit(1);
}
if ((sock2 = socket(AF_PACKET, SOCK_DGRAM, htons(ETH_P_IP))) < 0){
perror("socket() failed");
exit(1);
}
if ((sock3 = socket(AF_PACKET, SOCK_DGRAM, htons(ETH_P_IP))) < 0){
perror("socket() failed");
exit(1);
}
// Bind sockets to interfaces
struct ifreq ifr;
memset(&ifr, 0, sizeof(ifr));
snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "r0-eth1");
if (setsockopt(sock1, SOL_SOCKET, SO_BINDTODEVICE, (void *)&ifr, sizeof(ifr)) < 0) {
perror("setsockopt() inf config failed");
exit(1);
}
memset(&ifr, 0, sizeof(ifr));
snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "r0-eth2");
if (setsockopt(sock2, SOL_SOCKET, SO_BINDTODEVICE, (void *)&ifr, sizeof(ifr)) < 0) {
perror("setsockopt() inf config failed");
exit(1);
}
memset(&ifr, 0, sizeof(ifr));
snprintf(ifr.ifr_name, sizeof(ifr.ifr_name), "r0-eth3");
if (setsockopt(sock3, SOL_SOCKET, SO_BINDTODEVICE, (void *)&ifr, sizeof(ifr)) < 0) {
perror("setsockopt() inf config failed");
exit(1);
}
//Setup select
FD_ZERO(&readfds);
FD_SET(sock1, &readfds);
FD_SET(sock2, &readfds);
FD_SET(sock3, &readfds);
status = select( sock3 + 1 , &readfds , NULL , NULL , NULL);
while(1)
{
// Check select
if (status > 0) {
// Read IP datagram
if (FD_ISSET(sock1, &readfds)) {
struct sockaddr_in sockAddr;
socklen_t sockLen = sizeof(sockAddr);
memset(&sockAddr, 0, sockLen);
sockAddr.sin_family = AF_INET;
sockAddr.sin_addr.s_addr = htonl(INADDR_ANY);
int bufLen = recvfrom(sock1, buffer, 65535, 0, (struct sockaddr *) &sockAddr, (socklen_t *)&sockLen);
}
}
}
我用此命令运行它:
r0 ./router &
然后我做
pingall
查看主机是否可以彼此到达。我的可执行文件被卡在select()上,永远不会继续前进。在Pingall H1,H2和H3期间,所有其他数据包都可以达到R0。我知道我尚未完成路由部分,但是直到解决此问题之前,我才真正继续前进。
感谢帮助。
在我看来,您的问题很简单。注意此代码段:
status = select( sock3 + 1 , &readfds , NULL , NULL , NULL);
while(1)
{
// Check select
if (status > 0) {
// Read IP datagram
if (FD_ISSET(sock1, &readfds)) {
struct sockaddr_in sockAddr;
socklen_t sockLen = sizeof(sockAddr);
memset(&sockAddr, 0, sockLen);
sockAddr.sin_family = AF_INET;
sockAddr.sin_addr.s_addr = htonl(INADDR_ANY);
int bufLen = recvfrom(sock1, buffer, 65535, 0, (struct sockaddr *) &sockAddr, (socklen_t *)&sockLen);
}
}
}
您设置为使用select()
。然后,您输入while(1)
循环并检查status
的情况...但是您永远不会再次调用Select,切勿更新状态的值,并且永远不会允许while
循环结束。
此外,使用select()
和FD_SET
时,您需要在每个信号后重置FD_SET
。
我想您需要检查数据包是否发送到主机。