我正在写一个小程序来请求文件的一大块，再有另一个程序返回该文件的特定块。 我能得到这个使用文件备份到约555000个字节的工作，但在任何啤酒比，我得到异常行为。
在我的循环，我检查进度缓冲，这是一个整数数组，看看我是否拥有该文件的特定块。 如果我这样做，那么我不发该块的请求，但如果我不这样做，那么我从对等请求块。 我有一个链接列表，我搬过来，在列表中的每个节点有与之相关的sockfd一个。 所以，从某种意义上说，我“循环”的要求进行。 有一次，我送他们出去，我等消息进来，我不知道这是否是最好的方法，但它似乎是最自然的。
但是，对于更大的文件，它挂在选择呼叫。 我不完全知道为什么。 如果任何人都可以在此提供一些线索，或提出一个更好的办法，我很想听到它。
这里是我的代码。 我并没有包括我调用的函数的代码，但我不认为它有必要在这种情况下（他们被修改Beej的sendall和recvall功能的版本）。 还值得一提的是，这是一个多线程应用程序（使用并行线程），但我不使用任何共享变量。 感谢您抽时间阅读！
total = (number of chunks in the file)
my_peers = (linked list of peer structs containing sockfds, etc)
int i;
progress_buf = (array of ints, each representing a chunk in a file, 0 means we don't have the chunk)
while (1) {
/* Send out the chunk requests */
for(z= 0; z < total; z++) {
/* Circles through the peer list */
if (temp -> next != NULL) {
temp_next = temp->next;
} else {
temp_next = my_peers;
}
if (progress_buf[z] == 0) {
/* Request_blocks performs a send */
/* Need to deal with the "hanging bytes" chunk */
if (((z + 1) == total) && (remainder_chunk == 1)) {
check = request_blocks(temp, remainder, remainder_chunk, z);
} else {
check = request_blocks(temp, remainder, 0, z);
}
/* Bad send, remove peer from file descriptors and list */
if (check != 0 ) {
FD_CLR(check, &masterr);
remove_peer(&my_peers, temp->socket);
}
}
temp = temp_next;
}
read_fdss = masterr;
/* HANGS RIGHT HERE */
if (select(fdmax+1, &read_fdss, NULL, NULL, NULL) < 0) {
perror("select");
}
read_fdss = masterr;
int got_block;
/* Means we've received a block */
for(i = 4; i <= fdmax; i++) {
got_block = -1;
if (FD_ISSET(i, &read_fdss)) {
/* Performs a recv */
got_block = receive_block(i, filename_copy, progress_buf);
/* Update the progress buffer */
if (got_block > -1) {
remaining_blocks++;
if (remaining_blocks == total) goto finished;
/* Failure- remove the peer */
} else if (got_block == -2) {
close(i);
FD_CLR(i, &masterr);
remove_peer(&my_peers, i);
}
}
}
}
}
