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

sf_enable_thread_notify with false

pull/616/head
YuQing 2022-12-30 17:26:27 +08:00
parent 3f4d273746
commit f5f17ea6e7
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
storage/storage_service.c
View File

@ -1593,7 +1593,6 @@ static int sock_send_done_callback(struct fast_task_info *pTask,
pClientInfo = (StorageClientInfo *)pTask->arg; pClientInfo = (StorageClientInfo *)pTask->arg;
pClientInfo->total_offset += length; pClientInfo->total_offset += length;
if (pClientInfo->total_offset >= pClientInfo->total_length) if (pClientInfo->total_offset >= pClientInfo->total_length)
{ {
if (pClientInfo->total_length == sizeof(TrackerHeader) if (pClientInfo->total_length == sizeof(TrackerHeader)
@ -1653,7 +1652,7 @@ int storage_service_init()
NULL, sock_accept_done_callback, storage_set_body_length, NULL, sock_accept_done_callback, storage_set_body_length,
sock_send_done_callback, storage_deal_task, task_finish_clean_up, sock_send_done_callback, storage_deal_task, task_finish_clean_up,
NULL, 1000, sizeof(TrackerHeader), sizeof(StorageClientInfo)); NULL, 1000, sizeof(TrackerHeader), sizeof(StorageClientInfo));
sf_enable_thread_notify(true); sf_enable_thread_notify(false);
sf_set_remove_from_ready_list(false); sf_set_remove_from_ready_list(false);
return result; return result;