HISTORY

@@ -1,7 +1,4 @@
 
-Version 1.83  2025-11-15
-  * fast_task_queue.h: remove field finish_callback
-
 Version 1.82  2025-11-04
   * set use_io_uring explicitly
 

INSTALL

@@ -21,5 +21,5 @@ Debian, Ubuntu etc.:
 # the command lines as:
 
    git clone https://github.com/happyfish100/libfastcommon.git
-   cd libfastcommon; git checkout V1.0.83
+   cd libfastcommon; git checkout V1.0.82
    ./make.sh clean && ./make.sh && sudo ./make.sh install

debian/changelog

@@ -1,21 +1,3 @@
-libfastcommon (1.0.83-1) unstable; urgency=medium
-
-  * upgrade to 1.0.83-1
-
- -- YuQing <384681@qq.com>  Sun, 23 Nov 2025 10:47:37 +0000
-
-libfastcommon (1.0.83-1) unstable; urgency=medium
-
-  * upgrade to 1.0.83-1
-
- -- YuQing <384681@qq.com>  Sun, 23 Nov 2025 10:00:00 +0000
-
-libfastcommon (1.0.83-1) unstable; urgency=medium
-
-  * upgrade to 1.0.83-1
-
- -- YuQing <384681@qq.com>  Sun, 23 Nov 2025 09:05:57 +0000
-
 libfastcommon (1.0.78-1) unstable; urgency=medium
 
   * upgrade to 1.0.78-1

libfastcommon.spec

@@ -3,7 +3,7 @@
 %define CommitVersion %(echo $COMMIT_VERSION)
 
 Name: libfastcommon
-Version: 1.0.83
+Version: 1.0.82
 Release: 1%{?dist}
 Summary: c common functions library extracted from my open source projects FastDFS
 License: LGPL

src/fast_task_queue.h

@@ -37,6 +37,7 @@ struct nio_thread_data;
 struct fast_task_info;
 
 typedef int (*ThreadLoopCallback) (struct nio_thread_data *pThreadData);
+typedef int (*TaskFinishCallback) (struct fast_task_info *task);
 typedef void (*TaskCleanUpCallback) (struct fast_task_info *task);
 typedef int (*TaskInitCallback)(struct fast_task_info *task, void *arg);
 typedef void (*TaskReleaseCallback)(struct fast_task_info *task);
@@ -148,6 +149,7 @@ struct fast_task_info
         struct fc_list_head dlink;  //for polling queue
     } polling;  //for RDMA busy polling
     TaskContinueCallback continue_callback; //for continue stage
+    TaskFinishCallback finish_callback;
     struct nio_thread_data *thread_data;
     struct sf_network_handler *handler; //network handler for libserverframe nio
     struct fast_task_info *next;        //for free queue and deleted list

src/ioevent_loop.c

@@ -145,7 +145,10 @@ static void deal_timeouts(FastTimerEntry *head)
         /* must set NULL because NOT in time wheel */
         current->prev = current->next = NULL;
 		pEventEntry = (IOEventEntry *)current;
-        pEventEntry->callback(pEventEntry->fd, IOEVENT_TIMEOUT, current);
+		if (pEventEntry != NULL)
+		{
+			pEventEntry->callback(pEventEntry->fd, IOEVENT_TIMEOUT, current);
+		}
 	}
 }
 
@@ -240,7 +243,7 @@ int ioevent_loop(struct nio_thread_data *thread_data,
         }
 
 		if (thread_data->deleted_list != NULL) {
-			//count = 0;
+			count = 0;
 			while (thread_data->deleted_list != NULL) {
 				task = thread_data->deleted_list;
 				thread_data->deleted_list = task->next;
@@ -254,7 +257,7 @@ int ioevent_loop(struct nio_thread_data *thread_data,
                     }
                 }
 				clean_up_callback(task);
-				//count++;
+				count++;
 			}
 			//logInfo("cleanup task count: %d", count);
 		}