Mirrors_Framework/nuttx
1
0
Fork 0
mirror of https://github.com/apache/nuttx.git synced 2026-05-31 14:27:37 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Use small lock to protect resources related to cpufifo.

Browse Source 
Signed-off-by: wangzhi16 <wangzhi16@xiaomi.com>
This commit is contained in:
wangzhi16
2025-01-20 17:24:51 +08:00
committed by Xiang Xiao
parent e7f38fe6fa
commit 8b5ea40a2b
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
arch/arm/src/cxd56xx/cxd56_cpufifo.c
+9 -7
View File
@@ -28,6 +28,7 @@
#include <nuttx/irq.h> #include <nuttx/irq.h>
#include <nuttx/arch.h> #include <nuttx/arch.h>
#include <nuttx/queue.h> #include <nuttx/queue.h>
#include <nuttx/spinlock.h>
#include <assert.h> #include <assert.h>
#include <debug.h> #include <debug.h>
@@ -79,6 +80,7 @@ static sq_queue_t g_pushqueue;
static sq_queue_t g_emptyqueue; static sq_queue_t g_emptyqueue;
static struct cfpushdata_s g_pushbuffer[NR_PUSHBUFENTRIES]; static struct cfpushdata_s g_pushbuffer[NR_PUSHBUFENTRIES];
static cpufifo_handler_t g_cfrxhandler; static cpufifo_handler_t g_cfrxhandler;
static spinlock_t g_cpufifo_lock = SP_UNLOCKED;
/**************************************************************************** /****************************************************************************
* Private Functions * Private Functions
@@ -175,11 +177,11 @@ int cxd56_cfpush(uint32_t data[2])
irqstate_t flags; irqstate_t flags;
int ret; int ret;
flags = enter_critical_section(); flags = spin_lock_irqsave(&g_cpufifo_lock);
if (!sq_empty(&g_pushqueue)) if (!sq_empty(&g_pushqueue))
{ {
ret = cpufifo_reserve(data); ret = cpufifo_reserve(data);
leave_critical_section(flags); spin_unlock_irqrestore(&g_cpufifo_lock, flags);
return ret; return ret;
} }
@@ -190,7 +192,7 @@ int cxd56_cfpush(uint32_t data[2])
up_enable_irq(CXD56_IRQ_FIFO_TO); up_enable_irq(CXD56_IRQ_FIFO_TO);
} }
leave_critical_section(flags); spin_unlock_irqrestore(&g_cpufifo_lock, flags);
return OK; return OK;
} }
@@ -214,7 +216,7 @@ int cxd56_cfregrxhandler(cpufifo_handler_t handler)
irqstate_t flags; irqstate_t flags;
int ret = OK; int ret = OK;
flags = enter_critical_section(); flags = spin_lock_irqsave(&g_cpufifo_lock);
if (g_cfrxhandler) if (g_cfrxhandler)
{ {
ret = -1; ret = -1;
@@ -224,16 +226,16 @@ int cxd56_cfregrxhandler(cpufifo_handler_t handler)
g_cfrxhandler = handler; g_cfrxhandler = handler;
} }
leave_critical_section(flags); spin_unlock_irqrestore(&g_cpufifo_lock, flags);
return ret; return ret;
} }
void cxd56_cfunregrxhandler(void) void cxd56_cfunregrxhandler(void)
{ {
irqstate_t flags; irqstate_t flags;
flags = enter_critical_section(); flags = spin_lock_irqsave(&g_cpufifo_lock);
g_cfrxhandler = NULL; g_cfrxhandler = NULL;
leave_critical_section(flags); spin_unlock_irqrestore(&g_cpufifo_lock, flags);
} }
int cxd56_cfinitialize(void) int cxd56_cfinitialize(void)