#include "modules/loggers/sdlog_chibios/msg_queue.h"
#include "modules/tlsf/tlsf_malloc.h"
#include <string.h>

Include dependency graph for msg_queue.c:

Data Structures
union	MsgPtrLen

struct	MsgPtrLen.__unnamed__

Macros
#define	MSGQ_HEAP HEAP_CCM

Functions
void	msgqueue_init (MsgQueue que, tlsf_memory_heap_t heap, msg_t *mb_buf, const cnt_t mb_size)
	initialise MsgQueue More...

bool	msgqueue_is_full (MsgQueue *que)
	test if queue is full More...

bool	msgqueue_is_empty (MsgQueue *que)
	test if queue is empty More...

int32_t	msgqueue_send (MsgQueue que, void msg, const uint16_t msgLen, const MsgQueueUrgency urgency)
	send a buffer previously allocated by msgqueue_malloc_before_send More...

int32_t	msgqueue_send_timeout (MsgQueue que, void msg, const uint16_t msgLen, const MsgQueueUrgency urgency, const systime_t timout)
	send a buffer previously allocated by msgqueue_malloc_before_send More...

int32_t	msgqueue_copy_send_timeout (MsgQueue que, const void msg, const uint16_t msgLen, const MsgQueueUrgency urgency, const systime_t timout)
	send a buffer NOT previously allocated More...

int32_t	msgqueue_copy_send (MsgQueue que, const void msg, const uint16_t msgLen, const MsgQueueUrgency urgency)
	send a buffer NOT previously allocated More...

int32_t	msgqueue_pop (MsgQueue que, void *msgPtr)
	wait then receive message More...

int32_t	msgqueue_pop_timeout (MsgQueue que, void *msgPtr, const systime_t timout)
	receive message specifying timeout More...

const char *	msgqueue_strerror (const MsgQueueStatus _errno)
	debug api More...

Variables
static const char *	_strerror []

Data Structure Documentation

◆ MsgPtrLen

union MsgPtrLen

Definition at line 33 of file msg_queue.c.

Collaboration diagram for MsgPtrLen:

Data Fields
struct MsgPtrLen	__unnamed__
msg_t	msg_ptr_len

◆ MsgPtrLen.unnamed

struct MsgPtrLen.__unnamed__

Definition at line 34 of file msg_queue.c.

Data Fields
uint16_t	len
uint16_t	ptrOfst

Macro Definition Documentation

◆ MSGQ_HEAP

#define MSGQ_HEAP HEAP_CCM

Definition at line 30 of file msg_queue.c.

Function Documentation

◆ msgqueue_copy_send()

int32_t msgqueue_copy_send	(	MsgQueue *	que,
		const void *	msg,
		const uint16_t	msgLen,
		const MsgQueueUrgency	urgency
	)

send a buffer NOT previously allocated

buffer is copied before beeing sent, buffer is still valid after this function returns. Less effective that zero copy alternatives which has been to be preferably used Non blocking, if queue is full, report error and immediately return

Parameters

[in]	que	pointer to opaque MsgQueue object
[in]	msg	pointer to buffer
[in]	msgLen	length of buffer (the same param that has been given to msgqueue_malloc_before_send)
[in]	urgency	regular=queued at end of fifo or out_of_band queued at start of fifo

Returns: if > 0 : requested length if < 0 : error status (see errors at begining of this header file)

Definition at line 127 of file msg_queue.c.

References msg, and msgqueue_copy_send_timeout().

Here is the call graph for this function:

◆ msgqueue_copy_send_timeout()

int32_t msgqueue_copy_send_timeout	(	MsgQueue *	que,
		const void *	msg,
		const uint16_t	msgLen,
		const MsgQueueUrgency	urgency,
		const systime_t	timout
	)

send a buffer NOT previously allocated

buffer is copied before beeing sent, buffer is still valid after this function returns. Less effective that zero copy alternatives which has been to be preferably used

Parameters

[in]	que	pointer to opaque MsgQueue object
[in]	msg	pointer to buffer
[in]	msgLen	length of buffer (the same param that has been given to msgqueue_malloc_before_send)
[in]	urgency	regular=queued at end of fifo or out_of_band queued at start of fifo
[in]	timout	: time to wait for MailBox avaibility (can be TIME_INFINITE or TIME_IMMEDIATE)

Returns: if > 0 : requested length if < 0 : error status (see errors at begining of this header file)

Definition at line 114 of file msg_queue.c.

References msg, MSGQ_HEAP, MsgQueue_MAILBOX_FULL, msgqueue_send_timeout(), and tlsf_malloc_r().

Referenced by msgqueue_copy_send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ msgqueue_init()

void msgqueue_init	(	MsgQueue *	que,
		tlsf_memory_heap_t *	heap,
		msg_t *	mb_buf,
		const cnt_t	mb_size
	)

initialise MsgQueue

init sdQueue objet, tie memory pool buffer, tie mailbox buffer initialize mailbox

Parameters

[out]	que	opaque object to be initialized
[in]	heap	reference to the tlsf heap object (needed if module should free memory)
[in]	mb_buff	internal buffer used by MailBox (see Chibios Doc)
[in]	mb_size	size of previous buffer (length of MailBox queue)

Definition at line 42 of file msg_queue.c.

References MsgQueue::heap, and MsgQueue::mb.

Referenced by sdLogInit().

Here is the caller graph for this function:

◆ msgqueue_is_empty()

bool msgqueue_is_empty ( MsgQueue * que )

test if queue is empty

Parameters

[in] que pointer to opaque MsgQueue object

Returns: true if empty, false otherwise

Definition at line 59 of file msg_queue.c.

References MsgQueue::mb.

◆ msgqueue_is_full()

bool msgqueue_is_full ( MsgQueue * que )

test if queue is full

Parameters

[in] que pointer to opaque MsgQueue object

Returns: true if full, false otherwise

Definition at line 50 of file msg_queue.c.

References MsgQueue::mb.

◆ msgqueue_pop()

int32_t msgqueue_pop	(	MsgQueue *	que,
		void **	msgPtr
	)

wait then receive message

this is zero copy api, blocking call usage : struct MyStruct *msg msgqueue_pop (&que, void (void **) &msg); use msg->myField etc etc tlsf_free(MSGQ_HEAP, msg);

Parameters

[in]	que	pointer to opaque MsgQueue object
[out]	msgPtr	pointer to pointer to buffer

Returns: if > 0 : length of received msg if < 0 : error status (see errors at begining of this header file)

Definition at line 134 of file msg_queue.c.

References msgqueue_pop_timeout().

Here is the call graph for this function:

◆ msgqueue_pop_timeout()

int32_t msgqueue_pop_timeout	(	MsgQueue *	que,
		void **	msgPtr,
		const systime_t	timout
	)

receive message specifying timeout

this is zero copy api, blocking call usage : struct MyStruct *msg msgqueue_pop (&que, void (void **) &msg); use msg->myField etc etc msgqueue_free_after_pop (&que, msg);

Parameters

[in]	que	pointer to opaque MsgQueue object
[out]	msgPtr	pointer to pointer to buffer
[in]	timout	: time to wait for MailBox avaibility (can be TIME_INFINITE or TIME_IMMEDIATE)

Returns: if > 0 : length of received msg if < 0 : error status (see errors at begining of this header file)

Definition at line 139 of file msg_queue.c.

References MsgQueue::mb, MsgPtrLen::msg_ptr_len, MSGQ_HEAP, MsgQueue_MAILBOX_TIMEOUT, status, and tlsf_get_heap_addr().

Referenced by msgqueue_pop().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ msgqueue_send()

int32_t msgqueue_send	(	MsgQueue *	que,
		void *	msg,
		const uint16_t	msgLen,
		const MsgQueueUrgency	urgency
	)

send a buffer previously allocated by msgqueue_malloc_before_send

deallocation is done by the caching thread which actually write data to sd card from the sender point of view, ptr should be considered invalid after beeing sent. Even if msgqueue_send fail, deallocation is done Non blocking, if queue is full, report error and immediately return usage : msg = tlsf_malloc(MSGQ_HEAP, msg, msgLen); msgqueue_send (que, msg, msgLen, urgency);

Parameters

[in]	que	pointer to opaque MsgQueue object
[in]	msg	pointer to buffer given by msgqueue_malloc_before_send
[in]	msgLen	length of buffer (the same param that has been given to msgqueue_malloc_before_send)
[in]	urgency	regular=queued at end of fifo or out_of_band queued at start of fifo

Returns: if > 0 : requested length if < 0 : error status (see errors at begining of this header file)

Definition at line 69 of file msg_queue.c.

References msg, and msgqueue_send_timeout().

Here is the call graph for this function:

◆ msgqueue_send_timeout()

int32_t msgqueue_send_timeout	(	MsgQueue *	que,
		void *	msg,
		const uint16_t	msgLen,
		const MsgQueueUrgency	urgency,
		const systime_t	timout
	)

send a buffer previously allocated by msgqueue_malloc_before_send

deallocation is done by the caching thread which actually write data to sd card from the sender point of view, ptr should be considered invalid after beeing sent. Even if msgqueue_send fail, deallocation is done usage : msg = tlsf_malloc(MSGQ_HEAP, msg, msgLen); msgqueue_send (que, msg, msgLen, urgency);

Parameters

[in]	que	pointer to opaque MsgQueue object
[in]	msg	pointer to buffer given by msgqueue_malloc_before_send
[in]	msgLen	length of buffer (the same param that has been given to msgqueue_malloc_before_send)
[in]	urgency	regular=queued at end of fifo or out_of_band queued at start of fifo
[in]	timout	: time to wait for MailBox avaibility (can be TIME_INFINITE or TIME_IMMEDIATE)

Returns: if > 0 : requested length if < 0 : error status (see errors at begining of this header file)

Definition at line 76 of file msg_queue.c.

References MsgQueue::heap, MsgQueue::mb, msg, MsgPtrLen::msg_ptr_len, MSGQ_HEAP, MsgQueue_INVALID_PTR, MsgQueue_MAILBOX_FULL, MsgQueue_REGULAR, tlsf_free_r(), and tlsf_get_heap_addr().

Referenced by msgqueue_copy_send_timeout(), and msgqueue_send().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ msgqueue_strerror()

const char* msgqueue_strerror ( const MsgQueueStatus errno )

debug api

give ascii string corresponding to the given errno

Parameters

[in] errno : staus

Returns: pointer to error string

Definition at line 168 of file msg_queue.c.

References _strerror, and MsgQueue_MAILBOX_FULL.

Variable Documentation

◆ _strerror

const char* _strerror[]

static

Initial value:

= {"MsgQueue_MAILBOX_FULL",
                                  "MsgQueue_MAILBOX_FAIL",
                                  "MsgQueue_MAILBOX_TIMEOUT",
                                  "MsgQueue_MAILBOX_NOT_EMPTY",
                                  "MsgQueue_OK",
                                  "MsgQueue_INVALID_PTR",
                                  "MsgQueue_INVALID_ERRNO"
                                 }

Definition at line 159 of file msg_queue.c.

Referenced by msgqueue_strerror().

Data Structures

Macros

Functions

Variables

Data Structure Documentation

◆ MsgPtrLen

◆ MsgPtrLen.__unnamed__

Macro Definition Documentation

◆ MSGQ_HEAP

Function Documentation

◆ msgqueue_copy_send()

◆ msgqueue_copy_send_timeout()

◆ msgqueue_init()

◆ msgqueue_is_empty()

◆ msgqueue_is_full()

◆ msgqueue_pop()

◆ msgqueue_pop_timeout()

◆ msgqueue_send()

◆ msgqueue_send_timeout()

◆ msgqueue_strerror()

Variable Documentation

◆ _strerror

◆ MsgPtrLen.unnamed