pdxx
/
fastdfs
mirror of https://github.com/happyfish100/fastdfs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

adapt to the newest sf_send_done_callback

use_libfastcommon1.70
YuQing 2023-10-26 10:51:30 +08:00
parent cb73cfe1a5
commit 047d858220
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
storage/storage_service.c
View File

@ -1578,7 +1578,7 @@ static int sock_accept_done_callback(struct fast_task_info *task,
} }
static int sock_send_done_callback(struct fast_task_info *pTask, static int sock_send_done_callback(struct fast_task_info *pTask,
const int length) const int length, int *next_stage)
{ {
StorageClientInfo *pClientInfo; StorageClientInfo *pClientInfo;
@ -1599,10 +1599,13 @@ static int sock_send_done_callback(struct fast_task_info *pTask,
/* response done, try to recv again */ /* response done, try to recv again */
pClientInfo->total_length = 0; pClientInfo->total_length = 0;
pClientInfo->total_offset = 0; pClientInfo->total_offset = 0;
*next_stage = SF_NIO_STAGE_RECV;
return 0; return 0;
} }
else //continue to send file content else //continue to send file content
{ {
*next_stage = SF_NIO_STAGE_SEND;
/* continue read from file */ /* continue read from file */
return storage_dio_queue_push(pTask); return storage_dio_queue_push(pTask);
} }