- 论坛徽章:
- 0
|
pkg_len = (p - out_buff) + file_size + 256*1024 - sizeof(TrackerHeader);
long2buff(pkg_len, \
pHeader->pkg_len);
pHeader->cmd = 100;//cmd;
pHeader->status = 0;
if ((result=tcpsenddata_nb(pStorageServer->sock, out_buff, \
p - out_buff, g_fdfs_network_timeout)) != 0)
{
logError("file: "__FILE__", line: %d, " \
"send data to storage server %s:%d fail, " \
"errno: %d, error info: %s", __LINE__, \
pStorageServer->ip_addr, pStorageServer->port, \
result, STRERROR(result));
break;
}
{
char buff[256*1024];
tcpsenddata_nb(pStorageServer->sock, buff, sizeof(buff), g_fdfs_network_timeout);
while(1) {
int dd = recv(pStorageServer->sock, buff, sizeof(buff), 0);
printf("recv:%d...\n", dd);
}
}
|
|