GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2078 from ZhouBox/v2.8

Browse Source 
[v2.8]async queue:add api about length
This commit is contained in:
fengzeroz
2024-06-07 15:43:25 +08:00
committed by GitHub
parent 264796888c 515d31c4e8
commit 250d19af8d
2 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neuron/utils/async_queue.h
+2
View File
@@ -87,4 +87,6 @@ void neu_async_queue_remove(neu_async_queue_t *q, neu_async_queue_filter filter,
*/
void neu_async_queue_clean(neu_async_queue_t *q);
int neu_async_queue_len(neu_async_queue_t *q);
#endif
src/utils/async_queue.c
+12
View File
@@ -159,4 +159,16 @@ void neu_async_queue_clean(neu_async_queue_t *q)
free(el);
}
pthread_mutex_unlock(&q->mtx);
}
int neu_async_queue_len(neu_async_queue_t *q)
{
int count = 0;
element *elt = NULL;
pthread_mutex_lock(&q->mtx);
DL_COUNT(q->list, elt, count);
pthread_mutex_unlock(&q->mtx);
return count;
}