#include "config/compiler.h"#include "include/queues.h"#include "include/flow_control.h"#include "interface/wmp_interface.h"#include "include/queue_core.h"#include "include/frames.h"#include "include/task_timing.h"
Include dependency graph for queues.c:
Go to the source code of this file.
Functions | |
| void | wmp_queue_free (void) |
| void | wmp_queue_init (int rx_nelems, int tx_nelems, int max_msg_size, int num_ports) |
| int | wmp_queue_rx_get_count (int port) |
| char * | wmp_queue_rx_get_elem_data (int id) |
| int | wmp_queue_rx_get_elem_priority (int id) |
| int | wmp_queue_rx_get_elem_size (int id) |
| int | wmp_queue_rx_get_elem_source (int id) |
| int | wmp_queue_rx_get_len () |
| int | wmp_queue_rx_get_room (void) |
| int | wmp_queue_rx_get_size () |
| int | wmp_queue_rx_push_part (longMsg_t *p) |
| void | wmp_queue_rx_set_elem_done (int id) |
| int | wmp_queue_tx_confirm () |
| void | wmp_queue_tx_drop_elem (int id) |
| void | wmp_queue_tx_drop_next (void) |
| void | wmp_queue_tx_force_sort (int blocking) |
| int | wmp_queue_tx_get_count (void) |
| int | wmp_queue_tx_get_elem_age (int id) |
| int | wmp_queue_tx_get_elem_burst (int id) |
| int | wmp_queue_tx_get_elem_dest (int id) |
| int | wmp_queue_tx_get_elem_port (int id) |
| int | wmp_queue_tx_get_elem_priority (int id) |
| int | wmp_queue_tx_get_elem_rescheduled (int id) |
| int | wmp_queue_tx_get_head_id () |
| void | wmp_queue_tx_get_last_popped_info (int *age, int *port, int *priority) |
| int | wmp_queue_tx_get_len (void) |
| int | wmp_queue_tx_get_mpm_age (void) |
| int | wmp_queue_tx_get_mpm_dest (void) |
| int | wmp_queue_tx_get_room (void) |
| int | wmp_queue_tx_get_size (void) |
| int | wmp_queue_tx_inspect (void) |
| int | wmp_queue_tx_pop_part (longMsg_t **p) |
| void | wmp_queue_tx_pop_part_done (int id) |
| int | wmp_queue_tx_remove_head () |
| int | wmp_queue_tx_reschedule () |
| void | wmpAddDest (unsigned int dest, char id) |
| void | wmpForceBurst (int port) |
| int | wmpGetNumOfElementsInRXQueue (int port) |
| int | wmpGetNumOfElementsInTXQueue (void) |
| int | wmpNonBlockingPop (Msg *p) |
| unsigned int | wmpPop (Msg *p) |
| int | wmpPopData (unsigned int port, char **p, unsigned int *size, unsigned char *src, signed char *priority) |
| int | wmpPopDataCopy (unsigned int port, char *p, unsigned int *size, unsigned char *src, signed char *priority) |
| void | wmpPopDataDone (int id) |
| int | wmpPopDataTimeout (unsigned int port, char **p, unsigned int *size, unsigned char *src, signed char *priority, int to) |
| int | wmpPopDataTimeoutCopy (unsigned int port, char *p, unsigned int *size, unsigned char *src, signed char *priority, int to) |
| int | wmpPush (Msg *p) |
| int | wmpPushData (unsigned int port, char *p, unsigned int size, unsigned int dest, signed char priority) |
| int | wmpTimedPop (Msg *p, int timeout_ms) |
| int | wmpWaitData (unsigned int port, int to) |
Variables | |
| queue_t | wmp_queue_rx |
| queue_t | wmp_queue_tx |
Function Documentation
| void wmp_queue_free | ( | void | ) |
| void wmp_queue_init | ( | int | rx_nelems, |
| int | tx_nelems, | ||
| int | max_msg_size, | ||
| int | num_ports | ||
| ) |
| int wmp_queue_rx_get_count | ( | int | port | ) |
| char* wmp_queue_rx_get_elem_data | ( | int | id | ) |
| int wmp_queue_rx_get_elem_priority | ( | int | id | ) |
| int wmp_queue_rx_get_elem_size | ( | int | id | ) |
| int wmp_queue_rx_get_elem_source | ( | int | id | ) |
| int wmp_queue_rx_get_len | ( | void | ) |
| int wmp_queue_rx_get_room | ( | void | ) |
| int wmp_queue_rx_get_size | ( | void | ) |
| int wmp_queue_rx_push_part | ( | longMsg_t * | p | ) |
| void wmp_queue_rx_set_elem_done | ( | int | id | ) |
| int wmp_queue_tx_confirm | ( | void | ) |
| void wmp_queue_tx_drop_elem | ( | int | id | ) |
| void wmp_queue_tx_drop_next | ( | void | ) |
| void wmp_queue_tx_force_sort | ( | int | blocking | ) |
| int wmp_queue_tx_get_count | ( | void | ) |
| int wmp_queue_tx_get_elem_age | ( | int | id | ) |
| int wmp_queue_tx_get_elem_burst | ( | int | id | ) |
| int wmp_queue_tx_get_elem_dest | ( | int | id | ) |
| int wmp_queue_tx_get_elem_port | ( | int | id | ) |
| int wmp_queue_tx_get_elem_priority | ( | int | id | ) |
| int wmp_queue_tx_get_elem_rescheduled | ( | int | id | ) |
| int wmp_queue_tx_get_head_id | ( | void | ) |
| void wmp_queue_tx_get_last_popped_info | ( | int * | age, |
| int * | port, | ||
| int * | priority | ||
| ) |
| int wmp_queue_tx_get_len | ( | void | ) |
| int wmp_queue_tx_get_mpm_age | ( | void | ) |
| int wmp_queue_tx_get_mpm_dest | ( | void | ) |
| int wmp_queue_tx_get_room | ( | void | ) |
| int wmp_queue_tx_get_size | ( | void | ) |
| int wmp_queue_tx_inspect | ( | void | ) |
| int wmp_queue_tx_pop_part | ( | longMsg_t ** | p | ) |
| void wmp_queue_tx_pop_part_done | ( | int | id | ) |
| int wmp_queue_tx_remove_head | ( | void | ) |
| int wmp_queue_tx_reschedule | ( | void | ) |
| void wmpAddDest | ( | unsigned int | dest, |
| char | id | ||
| ) |
| void wmpForceBurst | ( | int | port | ) |
| int wmpGetNumOfElementsInRXQueue | ( | int | port | ) |
| int wmpGetNumOfElementsInTXQueue | ( | void | ) |
| int wmpNonBlockingPop | ( | Msg * | p | ) |
| int wmpPopData | ( | unsigned int | port, |
| char ** | p, | ||
| unsigned int * | size, | ||
| unsigned char * | src, | ||
| signed char * | priority | ||
| ) |
| int wmpPopDataCopy | ( | unsigned int | port, |
| char * | p, | ||
| unsigned int * | size, | ||
| unsigned char * | src, | ||
| signed char * | priority | ||
| ) |
| void wmpPopDataDone | ( | int | id | ) |
| int wmpPopDataTimeout | ( | unsigned int | port, |
| char ** | p, | ||
| unsigned int * | size, | ||
| unsigned char * | src, | ||
| signed char * | priority, | ||
| int | to | ||
| ) |
| int wmpPopDataTimeoutCopy | ( | unsigned int | port, |
| char * | p, | ||
| unsigned int * | size, | ||
| unsigned char * | src, | ||
| signed char * | priority, | ||
| int | to | ||
| ) |
| int wmpPushData | ( | unsigned int | port, |
| char * | p, | ||
| unsigned int | size, | ||
| unsigned int | dest, | ||
| signed char | priority | ||
| ) |
| int wmpTimedPop | ( | Msg * | p, |
| int | timeout_ms | ||
| ) |
Dequeue a message from the RX Queue if already in the queue or enqueued within timeous_ms milliseconds. If there are not message to dequeue, returns a negative value
- Parameters:
-
p the message to pop timeout_ms pop timeout in milliseconds
- Returns:
- time spent in the queue (age) if dequeued -1 if timeout expired
| int wmpWaitData | ( | unsigned int | port, |
| int | to | ||
| ) |