【发布时间】:2016-03-26 01:13:45
【问题描述】:
我试图弄清楚为什么 recv 在下面的代码中被阻塞,如果我 telnet 并发送“GET / HTTP/1.1”,recv 会继续等待数据并阻止另一个 telnet 连接。但是,如果我只使用固定缓冲区而不是 do{} while,它就可以正常工作并且不会阻塞,即
char buffer[1024];
nbytes = recv(i, buffer, sizeof buffer, 0);
到目前为止,据我所知,select() 处于准备阅读状态。我需要将recv 设置为O_NONBLOCK 吗?
char *buffer = NULL;
unsigned long LEN = 200;
unsigned long bytes_received = 0;
unsigned long cur_size = 0;
int status = 0;
FD_SET(listener, &master);
fdmax = listener;
for(;;){
read_fds = master; // copy it
if(select(fdmax+1, &read_fds, NULL, NULL, NULL) == -1){
exit(4);
}
for(i = 0; i <= fdmax; i++){
if(FD_ISSET(i, &read_fds)){
if(i == listener){
// handle new connections
addrlen = sizeof remoteaddr;
newfd = accept(listener, (struct sockaddr *)&remoteaddr, &addrlen);
if(newfd == -1){
perror("accept");
}else{
FD_SET(newfd, &master);
if(newfd > fdmax) {
fdmax = newfd;
}
}
}else{
do{
if(bytes_received >= cur_size){
char * tmp;
cur_size += LEN;
tmp = realloc(buffer, cur_size);
buffer = tmp;
}
status = recv(i, buffer + bytes_received, LEN, 0);
if(status == 0){
printf("Done\n");
}
else if(status > 0){
bytes_received += status;
}
else{
fprintf(stderr, "socket error\n");
}
} while (status > 0);
if(send(i, buffer, strlen(buffer), 0) == -1){
perror("send");
}
}
}
}
}
【问题讨论】:
-
我没有看到任何对 setsockopt(SOL_SOCKET, SO_NONBLOCK, ...) 的调用会将您的套接字设置为非阻塞。您的示例中是否省略了该内容,或者您的程序中实际上缺少该内容?
-
它没有设置为
SO_NONBLOCK,我认为select() 会处理它。谢谢。 -
如果
select()有任何这种神奇的效果,它会在文档中说明。
标签: c sockets blocking nonblocking