sergiotarxz/nuttx
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

sched/mqueue: move message queue buffer to bss

Browse Source 
Signed-off-by: chao an <anchao@lixiang.com>
This commit is contained in:
chao an 2024-05-29 08:53:32 +08:00 committed by Xiang Xiao
parent 74702085f0
commit 81c140a953
1 changed files with 26 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
sched/mqueue/mq_initialize.c
View File

@ -31,6 +31,21 @@
#include "mqueue/mqueue.h"
#include "mqueue/msg.h"
/****************************************************************************
* Private Type Definitions
****************************************************************************/
struct msgpool_s
{
#ifndef CONFIG_DISABLE_MQUEUE
struct mqueue_msg_s mqueue[CONFIG_PREALLOC_MQ_MSGS +
CONFIG_PREALLOC_MQ_IRQ_MSGS];
#endif
#ifndef CONFIG_DISABLE_MQUEUE_SYSV
struct msgbuf_s msgbuf[CONFIG_PREALLOC_MQ_MSGS];
#endif
};
/****************************************************************************
* Public Data
****************************************************************************/
@ -52,6 +67,14 @@ struct list_node g_msgfreeirq;
#endif
/****************************************************************************
* Private Data
****************************************************************************/
/* This is a pool of pre-allocated message queue buffers */
static struct msgpool_s g_msgpool;
/****************************************************************************
* Private Functions
****************************************************************************/
@ -125,22 +148,10 @@ static FAR void *sysv_msgblockinit(FAR struct list_node *list,
void nxmq_initialize(void)
{
FAR void *msg;
FAR void *msg = &g_msgpool;
sched_trace_begin();
msg = kmm_malloc(
#ifndef CONFIG_DISABLE_MQUEUE
sizeof(struct mqueue_msg_s) *
(CONFIG_PREALLOC_MQ_MSGS + CONFIG_PREALLOC_MQ_IRQ_MSGS)
#endif
#ifndef CONFIG_DISABLE_MQUEUE_SYSV
+ sizeof(struct msgbuf_s) * CONFIG_PREALLOC_MQ_MSGS
#endif
);
DEBUGASSERT(msg != NULL);
/* Initialize a block of messages for general use */
#ifndef CONFIG_DISABLE_MQUEUE