我试图通过TCP套接字发送数据块。服务器代码执行以下操作:从TCP套接字读取错误的数据
#define CHECK(n) if((r=n) <= 0) { perror("Socket error\n"); exit(-1); }
int r;
//send the number of blocks
CHECK(write(sockfd, &(storage->length), 8)); //p->length is uint64_t
for(p=storage->first; p!=NULL; p=p->next) {
//send the size of this block
CHECK(write(sockfd, &(p->blocksize), 8)); //p->blocksize is uint64_t
//send data
CHECK(write(sockfd, &(p->data), p->blocksize));
}
在客户端,我读的大小,然后将数据(相同的检查万客隆):
CHECK(read(sockfd, &block_count, 8));
for(i=0; i<block_count; i++) {
uint64_t block_size;
CHECK(read(sockfd, &block_size, 8));
uint64_t read_in=0;
while(read_in < block_size) {
r = read(sockfd, data+read_in, block_size-read_in); //assume data was previously allocated as char*
read_in += r;
}
}
这只要工作完全正常的客户端和服务器在同一台机器上运行,但只要我通过网络尝试完成,它在某些时候会失败。特别是,第一300-400块(A〜587字节)左右做工精细,但后来我得到一个不正确的block_size阅读:
received block #372 size : 586
read_in: 586 of 586
received block #373 size : 2526107515908
然后它崩溃了,很明显。 我的印象是TCP协议确保没有数据丢失,并且所有信息都按正确的顺序接收,但是考虑到它已经在本地工作,那么这怎么可能?我的错误在哪里?
您是否检查过服务器中的列表实际上是否有效?即'p-> next'对于最后一个节点是'NULL'。 –