developer
/
xiuos
forked from xuos/xiuos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add config for queue manage

This commit is contained in:
Wang_Weigen 2022-06-14 10:54:08 +08:00
parent 5ed641a8fe
commit 5f49d2ba87
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
Ubiquitous/XiZi/kernel/thread/queue_manager.c
View File

@ -30,6 +30,7 @@ void* g_queue_done[QUEUE_MAX];
void QueuemanagerDoneRegister() void QueuemanagerDoneRegister()
{ {
#ifdef KERNEL_DATAQUEUE
DataQueueDoneType* pdata_queue_done = (DataQueueDoneType*)x_malloc(sizeof(DataQueueDoneType)); DataQueueDoneType* pdata_queue_done = (DataQueueDoneType*)x_malloc(sizeof(DataQueueDoneType));
pdata_queue_done->InitDataqueue = InitDataqueue; pdata_queue_done->InitDataqueue = InitDataqueue;
pdata_queue_done->PushDataqueue = PushDataqueue; pdata_queue_done->PushDataqueue = PushDataqueue;
@ -37,20 +38,27 @@ void QueuemanagerDoneRegister()
pdata_queue_done->DataqueuePeak = DataqueuePeak; pdata_queue_done->DataqueuePeak = DataqueuePeak;
pdata_queue_done->DeInitDataqueue = DeInitDataqueue; pdata_queue_done->DeInitDataqueue = DeInitDataqueue;
g_queue_done[DATA_QUEUE] = pdata_queue_done;
#endif
#ifdef KERNEL_WORKQUEUE
WorkQueueDoneType* pwork_queue_done = (WorkQueueDoneType*)x_malloc(sizeof(WorkQueueDoneType)); WorkQueueDoneType* pwork_queue_done = (WorkQueueDoneType*)x_malloc(sizeof(WorkQueueDoneType));
pwork_queue_done->CreateWorkQueue = CreateWorkQueue; pwork_queue_done->CreateWorkQueue = CreateWorkQueue;
pwork_queue_done->WorkInit = WorkInit; pwork_queue_done->WorkInit = WorkInit;
pwork_queue_done->WorkSubmit = WorkSubmit; pwork_queue_done->WorkSubmit = WorkSubmit;
pwork_queue_done->WorkSubmit_immediate = WorkSubmit_immediate; pwork_queue_done->WorkSubmit_immediate = WorkSubmit_immediate;
g_queue_done[WORK_QUEUE] = pwork_queue_done;
#endif
#ifdef KERNEL_WAITQUEUE
WaitQueueDoneType* pwait_queue_done = (WaitQueueDoneType*)x_malloc(sizeof(WaitQueueDoneType)); WaitQueueDoneType* pwait_queue_done = (WaitQueueDoneType*)x_malloc(sizeof(WaitQueueDoneType));
pwait_queue_done->InitWqueue = InitWqueue; pwait_queue_done->InitWqueue = InitWqueue;
pwait_queue_done->WqueueAdd = WqueueAdd; pwait_queue_done->WqueueAdd = WqueueAdd;
pwait_queue_done->WqueueRemove = WqueueRemove; pwait_queue_done->WqueueRemove = WqueueRemove;
pwait_queue_done->WqueueWait = WqueueWait; pwait_queue_done->WqueueWait = WqueueWait;
pwait_queue_done->WakeupWqueue = WakeupWqueue; pwait_queue_done->WakeupWqueue = WakeupWqueue;
g_queue_done[DATA_QUEUE] = pdata_queue_done;
g_queue_done[WORK_QUEUE] = pwork_queue_done;
g_queue_done[WAIT_QUEUE] = pwait_queue_done; g_queue_done[WAIT_QUEUE] = pwait_queue_done;
#endif
} }