This file is part of CAN/CAN FD bus common support and implements CAN FIFOs and generic hubs/ends for chip and caracter driver interface sides. More...

#include <string.h>
#include <dev/can/can-queue.h>

Include dependency graph for can-queue.c:

Macros
#define	RTEMS_CANQUE_ROUNDROB 1

Functions
int	canque_fifo_flush_slots (struct canque_fifo_t *fifo)
	This function frees all ready slots from the FIFO.

int	canque_fifo_init_slots (struct canque_fifo_t *fifo)
	This function initializes slot chain of one CAN FIFO.

void	__canque_edge_decref (struct canque_edge_t *edge)

int	canque_get_inslot (struct canque_ends_t qends, struct canque_edge_t qedgep, struct canque_slot_t *slotp, int cmd)
	This function finds one outgoing edge and allocates slot from it.

int	canque_get_inslot4prio (struct canque_ends_t qends, struct canque_edge_t qedgep, struct canque_slot_t slotp, const struct can_frame_header header, int cmd, int prio)
	This function finds best outgoing edge and slot for given ID.

int	canque_test_inslot (struct canque_ends_t *qends)
	This function tests whether there is a free space in any outgoing edge.

int	canque_put_inslot (struct canque_ends_t qends, struct canque_edge_t qedge, struct canque_slot_t *slot)
	This function schedules filled slot for processing.

int	canque_abort_inslot (struct canque_ends_t qends, struct canque_edge_t qedge, struct canque_slot_t *slot)
	This function aborts preparation of the message in the slot.

int	canque_filter_frame2edges (struct canque_ends_t qends, struct canque_edge_t src_edge, struct can_frame *frame, unsigned int flags2add)
	This function sends message into all edges which accept its ID.

int	canque_test_outslot (struct canque_ends_t qends, struct canque_edge_t qedgep, struct canque_slot_t *slotp)
	This function tests and retrieves ready slot for given ends.

int	canque_pending_outslot_prio (struct canque_ends_t *qends, int prio_min)
	This function tests ready outslot with minimum priority.

int	canque_free_outslot (struct canque_ends_t qends, struct canque_edge_t qedge, struct canque_slot_t *slot)
	This function frees processed output slot.

int	canque_again_outslot (struct canque_ends_t qends, struct canque_edge_t qedge, struct canque_slot_t *slot)
	This function reschedules output slot to process it again later.

int	canque_flush (struct canque_edge_t *qedge)
	This function flushes all ready slots in the edge.

int	canqueue_ends_init_gen (struct canque_ends_t *qends)
	This function implements subsystem independent routine to initialize ends state.

int	canqueue_connect_edge (struct canque_edge_t qedge, struct canque_ends_t inends, struct canque_ends_t *outends)
	This function connects edge between two communication entities.

int	canqueue_disconnect_edge (struct canque_edge_t *qedge)
	This function disconnects edge from communication entities.

void	canqueue_block_inlist (struct canque_ends_t *qends)
	This function blocks slot allocation of all outgoing edges of specified ends.

void	canqueue_block_outlist (struct canque_ends_t *qends)
	This function blocks slot allocation of all incoming edges of specified ends.

int	canqueue_ends_kill_inlist (struct canque_ends_t *qends, int send_rest)
	This function sends request to die to all outgoing edges.

int	canqueue_ends_kill_outlist (struct canque_ends_t *qends)
	This function sends request to die to all incomming edges.

int	canqueue_ends_flush_inlist (struct canque_ends_t *qends)

int	canqueue_ends_flush_outlist (struct canque_ends_t *qends)
	This function flushes all messages in outgoing edges.

Detailed Description

This file is part of CAN/CAN FD bus common support and implements CAN FIFOs and generic hubs/ends for chip and caracter driver interface sides.

Function Documentation

◆ canque_abort_inslot()

int canque_abort_inslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t *	qedge,
		struct canque_slot_t *	slot
	)

This function aborts preparation of the message in the slot.

Frees slot previously acquired by canque_get_inslot() or canque_get_inslot4prio() function call. Used when message copying into slot fails.

Parameters

qends	Ends structure belonging to calling communication object.
qedge	Edge the slot belongs to.
slot	Pointer to the preprared slot.

Returns: Positive value informs, that queue full state has been negated.

◆ canque_again_outslot()

int canque_again_outslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t *	qedge,
		struct canque_slot_t *	slot
	)

This function reschedules output slot to process it again later.

Function reschedules slot previously acquired by canque_test_outslot() function call for second time processing.

Parameters

qends	Ends structure belonging to calling communication object.
qedge	Edge the slot belongs to.
slot	Pointer to the processed slot.

Returns: Function cannot fail.

◆ canque_fifo_flush_slots()

int canque_fifo_flush_slots ( struct canque_fifo_t * fifo )

This function frees all ready slots from the FIFO.

The caller should be prepared to handle situations, when some slots are held by input or output side slots processing. These slots cannot be flushed or their processing interrupted.

Parameters

fifo	Pointer to the FIFO structure.

Returns: The nonzero value indicates that queue has not been empty before the function call.

◆ canque_fifo_init_slots()

int canque_fifo_init_slots ( struct canque_fifo_t * fifo )

This function initializes slot chain of one CAN FIFO.

The caller should be prepared to handle situations, when some slots are held by input or output side slots processing. These slots cannot be flushed or their processing interrupted.

Parameters

fifo	Pointer to the FIFO structure.

Returns: The negative value indicates that there is no memory to allocate space for the requested number of the slots.

◆ canque_filter_frame2edges()

int canque_filter_frame2edges	(	struct canque_ends_t *	qends,
		struct canque_edge_t *	src_edge,
		struct can_frame *	frame,
		unsigned int	flags2add
	)

This function sends message into all edges which accept its ID.

Sends message to all outgoing edges connected to the given ends, which accepts message communication ID.

Parameters

qends	Ends structure belonging to calling communication object
src_edge	Optional source edge for echo detection
frame	Pointer to CAN frame.
flags2add	Optional additional CAN Frame flags.

Returns: Returns number of edges message has been send to.

◆ canque_flush()

int canque_flush ( struct canque_edge_t * qedge )

This function flushes all ready slots in the edge.

Tries to flush all allocated slots from the edge, but there could exist some slots associated to edge which are processed by input or output side and cannot be flushed at this moment

Parameters

qedge Pointer to the edge.

Returns: The nonzero value indicates, that queue has not been empty before the function call

◆ canque_free_outslot()

int canque_free_outslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t *	qedge,
		struct canque_slot_t *	slot
	)

This function frees processed output slot.

Function releases processed slot previously acquired by canque_test_outslot() function call.

Parameters

qends	Ends structure belonging to calling communication object.
qedge	Edge the slot belongs to.
slot	Pointer to the processed slot.

Returns: Informs if input side has been notified to know about change of edge state

◆ canque_get_inslot()

int canque_get_inslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t **	qedgep,
		struct canque_slot_t **	slotp,
		int	cmd
	)

This function finds one outgoing edge and allocates slot from it.

Function looks for the first non-blocked outgoing edge in @qends structure and tries to allocate slot from it.

Parameters

qends	Ends structure belonging to calling communication object.
qedgep	Place to store pointer to found edge.
slotp	Place to store pointer to allocated slot.
cmd	Command type for slot.

Returns: If there is no usable edge or there is no free slot in edge negative value is returned.

◆ canque_get_inslot4prio()

int canque_get_inslot4prio	(	struct canque_ends_t *	qends,
		struct canque_edge_t **	qedgep,
		struct canque_slot_t **	slotp,
		const struct can_frame_header *	header,
		int	cmd,
		int	prio
	)

This function finds best outgoing edge and slot for given ID.

Function looks for the non-blocked outgoing edge accepting messages with given ID. If edge is found, slot is allocated from that edge. The edges with non-zero mask are preferred over edges open to all messages. If more edges with mask accepts given message ID, the edge with highest priority below or equal to required priority is selected.

Parameters

qends	Ends structure belonging to calling communication object.
qedgep	Place to store pointer to found edge.
slotp	Place to store pointer to allocated slot.
cmd	Command type for slot.
id	Communication ID of message to send into edge.
prio	Optional priority of message,

Returns: If there is no usable edge or there is no free slot in edge negative value is returned.

◆ canque_pending_outslot_prio()

int canque_pending_outslot_prio	(	struct canque_ends_t *	qends,
		int	prio_min
	)

This function tests ready outslot with minimum priority.

Function searches for ready slot in active incoming edge. The difference from canque_test_outslot function is that this function does not retreive the slot from FIFO, it just checks its existence. This can be used to determined whether there is a slot with higher priority class in the infrastruce.

Parameters

qends	Ends structure belonging to calling communication object.
prio_min	Minimum slot priority to be considered

Returns: Negative value informs, that there is no ready output slot for given ends and minimum priority. Positive value informs about the available slot priority.

◆ canque_put_inslot()

int canque_put_inslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t *	qedge,
		struct canque_slot_t *	slot
	)

This function schedules filled slot for processing.

Puts slot previously acquired by canque_get_inslot() or canque_get_inslot4prio() function call into FIFO queue and activates edge processing if needed.

Parameters

qends	Ends structure belonging to calling communication object.
qedge	Edge the slot belongs to.
slot	Pointer to the preprared slot.

Returns: Positive value informs, that activation of output end has been necessary

◆ canque_test_inslot()

int canque_test_inslot ( struct canque_ends_t * qends )

This function tests whether there is a free space in any outgoing edge.

Function looks for the first non-blocked outgoing edge in @qends structure with free space for slot.

Parameters

qends Ends structure belonging to calling communication object.

Returns: 0 if there is usable edge with free space available, -1 otherwise.

◆ canque_test_outslot()

int canque_test_outslot	(	struct canque_ends_t *	qends,
		struct canque_edge_t **	qedgep,
		struct canque_slot_t **	slotp
	)

This function tests and retrieves ready slot for given ends.

Function takes highest priority active incoming edge and retrieves oldest ready slot from it.

Parameters

qends	Ends structure belonging to calling communication object.
qedgep	Place to store pointer to found edge.
slotp	Place to store pointer to received slot.

Returns: Negative value informs, that there is no ready output slot for given ends. Positive value is equal to the command slot has been allocated by the input side.

◆ canqueue_block_inlist()

void canqueue_block_inlist ( struct canque_ends_t * qends )

This function blocks slot allocation of all outgoing edges of specified ends.

Parameters

qends Pointer to ends structure.

Returns: None.

◆ canqueue_block_outlist()

void canqueue_block_outlist ( struct canque_ends_t * qends )

This function blocks slot allocation of all incoming edges of specified ends.

Parameters

qends Pointer to ends structure.

Returns: None.

◆ canqueue_connect_edge()

int canqueue_connect_edge	(	struct canque_edge_t *	qedge,
		struct canque_ends_t *	inends,
		struct canque_ends_t *	outends
	)

This function connects edge between two communication entities.

Parameters

qedge	Pointer to edge.
inends	Pointer to ends the input of the edge should be connected to.
outends	Pointer to ends the output of the edge should be connected to.

Returns: Negative value informs about failed operation.

◆ canqueue_disconnect_edge()

int canqueue_disconnect_edge ( struct canque_edge_t * qedge )

This function disconnects edge from communication entities.

Parameters

qedge Pointer to edge.

Returns: Negative value means, that edge is used by somebody other and cannot be disconnected. Operation has to be delayed.

◆ canqueue_ends_flush_inlist()

int canqueue_ends_flush_inlist ( struct canque_ends_t * qends )

canqueue_ends_flush_inlist - flushes all messages in incoming edges @qends: pointer to ends structure

Return Value: Negative value informs about unsuccessful result

◆ canqueue_ends_flush_outlist()

int canqueue_ends_flush_outlist ( struct canque_ends_t * qends )

This function flushes all messages in outgoing edges.

Parameters

qends Pointer to ends structure.

Returns: Negative value informs about unsuccessful result.

◆ canqueue_ends_init_gen()

int canqueue_ends_init_gen ( struct canque_ends_t * qends )

This function implements subsystem independent routine to initialize ends state.

Parameters

qends Pointer to the end.

Returns: This fucntion cannot fail.

◆ canqueue_ends_kill_inlist()

int canqueue_ends_kill_inlist	(	struct canque_ends_t *	qends,
		int	send_rest
	)

This function sends request to die to all outgoing edges.

Parameters

qends	Pointer to ends structure.
send_rest	Select, whether already allocated slots should be processed by FIFO output side.

Returns: Non-zero value means, that not all edges could be immediately disconnected and that ends structure memory release has to be delayed.

◆ canqueue_ends_kill_outlist()

int canqueue_ends_kill_outlist ( struct canque_ends_t * qends )

This function sends request to die to all incomming edges.

Parameters

qends Pointer to ends structure.

Returns: Non-zero value means, that not all edges could be immediately disconnected and that ends structure memory release has to be delayed.

Macros

Functions

Detailed Description

Function Documentation

◆ canque_abort_inslot()

◆ canque_again_outslot()

◆ canque_fifo_flush_slots()

◆ canque_fifo_init_slots()

◆ canque_filter_frame2edges()

◆ canque_flush()

◆ canque_free_outslot()

◆ canque_get_inslot()

◆ canque_get_inslot4prio()

◆ canque_pending_outslot_prio()

◆ canque_put_inslot()

◆ canque_test_inslot()

◆ canque_test_outslot()

◆ canqueue_block_inlist()

◆ canqueue_block_outlist()

◆ canqueue_connect_edge()

◆ canqueue_disconnect_edge()

◆ canqueue_ends_flush_inlist()

◆ canqueue_ends_flush_outlist()

◆ canqueue_ends_init_gen()

◆ canqueue_ends_kill_inlist()

◆ canqueue_ends_kill_outlist()