#include <stdarg.h>
#include "config/compiler.h"
#include "core/interface/wmp_interface.h"
#include "core/include/global.h"
#include "core/include/frames.h"
#include "include/queue_core.h"
#include "core/include/queues.h"
#include "core/include/wmp_misc.h"
Go to the source code of this file.
Classes | |
struct | memory_t |
Functions | |
static int | extend_size_if_necessary (queue_t *q, int idx) |
static int | hash_exists (unsigned short hash, short part_id) |
static int | look_rx (queue_t *q, int port) |
int | queue_push_part (queue_t *q, longMsg_t *m) |
void | queue_rx_free (queue_t *q) |
int | queue_rx_get_count (queue_t *q, int port) |
int | queue_rx_get_mpm_size (queue_t *q, int port) |
int | queue_rx_get_room (queue_t *q) |
void | queue_rx_init (queue_t *q, int max_msg_size, int max_msg_num, int num_ports) |
int | queue_rx_pop_data (queue_t *q, unsigned int delay, unsigned int port, char **data, unsigned int *size, unsigned char *src, signed char *priority) |
void | queue_rx_pop_data_done (queue_t *q, int maxPriId) |
int | queue_rx_push_loop_data (queue_t *q, unsigned int port, char *p, unsigned int size, unsigned int dest, signed char priority, unsigned char src) |
int | queue_rx_wait_data (queue_t *q, int port, int delay) |
Variables | |
static memory_t | memory [10] |
static int | memory_id = 0 |
static int extend_size_if_necessary | ( | queue_t * | q, |
int | idx | ||
) | [static] |
Definition at line 76 of file queue_rx.c.
static int hash_exists | ( | unsigned short | hash, |
short | part_id | ||
) | [static] |
Definition at line 59 of file queue_rx.c.
Definition at line 287 of file queue_rx.c.
int queue_push_part | ( | queue_t * | q, |
longMsg_t * | m | ||
) |
Definition at line 119 of file queue_rx.c.
void queue_rx_free | ( | queue_t * | q | ) |
Definition at line 468 of file queue_rx.c.
int queue_rx_get_count | ( | queue_t * | q, |
int | port | ||
) |
Definition at line 485 of file queue_rx.c.
int queue_rx_get_mpm_size | ( | queue_t * | q, |
int | port | ||
) |
Definition at line 305 of file queue_rx.c.
int queue_rx_get_room | ( | queue_t * | q | ) |
Definition at line 493 of file queue_rx.c.
void queue_rx_init | ( | queue_t * | q, |
int | max_msg_size, | ||
int | max_msg_num, | ||
int | num_ports | ||
) |
Definition at line 399 of file queue_rx.c.
int queue_rx_pop_data | ( | queue_t * | q, |
unsigned int | delay, | ||
unsigned int | port, | ||
char ** | data, | ||
unsigned int * | size, | ||
unsigned char * | src, | ||
signed char * | priority | ||
) |
Definition at line 356 of file queue_rx.c.
void queue_rx_pop_data_done | ( | queue_t * | q, |
int | maxPriId | ||
) |
Definition at line 391 of file queue_rx.c.
int queue_rx_push_loop_data | ( | queue_t * | q, |
unsigned int | port, | ||
char * | p, | ||
unsigned int | size, | ||
unsigned int | dest, | ||
signed char | priority, | ||
unsigned char | src | ||
) |
Definition at line 243 of file queue_rx.c.
int queue_rx_wait_data | ( | queue_t * | q, |
int | port, | ||
int | delay | ||
) |
Definition at line 327 of file queue_rx.c.
Definition at line 57 of file queue_rx.c.
int memory_id = 0 [static] |
Definition at line 58 of file queue_rx.c.