dataqueue.h

#include <queue.h>

ソースコードを見る。

データ構造
struct	dataqueue_initialization_block
struct	dataqueue_control_block
struct	dataqueue_waiting_information
マクロ定義
#define	DTQID(p_dtqcb)   ((ID)(((p_dtqcb) - dtqcb_table) + TMIN_DTQID))
型定義
typedef struct dataqueue_initialization_block	DTQINIB
typedef struct dataqueue_control_block	DTQCB
typedef struct dataqueue_waiting_information	WINFO_DTQ
関数
void	initialize_dataqueue (void)
void	enqueue_data (DTQCB *p_dtqcb, intptr_t data)
void	force_enqueue_data (DTQCB *p_dtqcb, intptr_t data)
void	dequeue_data (DTQCB *p_dtqcb, intptr_t *p_data)
bool_t	send_data (DTQCB *p_dtqcb, intptr_t data, bool_t *p_reqdsp)
bool_t	force_send_data (DTQCB *p_dtqcb, intptr_t data)
bool_t	receive_data (DTQCB *p_dtqcb, intptr_t *p_data, bool_t *p_reqdsp)
変数
const ID	tmax_dtqid
const DTQINIB	dtqinib_table []
DTQCB	dtqcb_table []

---

マクロ定義

#define DTQID

(

p_dtqcb

)

((ID)(((p_dtqcb) - dtqcb_table) + TMIN_DTQID))

dataqueue.h の 114 行で定義されています。

参照元 ref_tsk().

---

型定義

typedef struct dataqueue_control_block DTQCB

typedef struct dataqueue_initialization_block DTQINIB

typedef struct dataqueue_waiting_information WINFO_DTQ

---

関数

void dequeue_data	(	DTQCB *	p_dtqcb,
		intptr_t *	p_data
	)

dataqueue.c の 225 行で定義されています。

参照先 dataqueue_control_block::count, dataqueue_initialization_block::dtqcnt, dataqueue_control_block::head, dataqueue_control_block::p_dtqinib, と dataqueue_initialization_block::p_dtqmb.

{
    *p_data = *(p_dtqcb->p_dtqinib->p_dtqmb + p_dtqcb->head);
    p_dtqcb->count--;
    p_dtqcb->head++;
    if (p_dtqcb->head >= p_dtqcb->p_dtqinib->dtqcnt) {
        p_dtqcb->head = 0U;
    }
}

void enqueue_data	(	DTQCB *	p_dtqcb,
		intptr_t	data
	)

dataqueue.c の 184 行で定義されています。

参照先 dataqueue_control_block::count, dataqueue_initialization_block::dtqcnt, dataqueue_control_block::p_dtqinib, dataqueue_initialization_block::p_dtqmb, と dataqueue_control_block::tail.

{
    *(p_dtqcb->p_dtqinib->p_dtqmb + p_dtqcb->tail) = data;
    p_dtqcb->count++;
    p_dtqcb->tail++;
    if (p_dtqcb->tail >= p_dtqcb->p_dtqinib->dtqcnt) {
        p_dtqcb->tail = 0U;
    }
}

void force_enqueue_data	(	DTQCB *	p_dtqcb,
		intptr_t	data
	)

dataqueue.c の 202 行で定義されています。

参照先 dataqueue_control_block::count, dataqueue_initialization_block::dtqcnt, dataqueue_control_block::head, dataqueue_control_block::p_dtqinib, dataqueue_initialization_block::p_dtqmb, と dataqueue_control_block::tail.

{
    *(p_dtqcb->p_dtqinib->p_dtqmb + p_dtqcb->tail) = data;
    p_dtqcb->tail++;
    if (p_dtqcb->tail >= p_dtqcb->p_dtqinib->dtqcnt) {
        p_dtqcb->tail = 0U;
    }
    if (p_dtqcb->count < p_dtqcb->p_dtqinib->dtqcnt) {
        p_dtqcb->count++;
    }
    else {
        p_dtqcb->head = p_dtqcb->tail;
    }
}

bool_t force_send_data	(	DTQCB *	p_dtqcb,
		intptr_t	data
	)

dataqueue.c の 271 行で定義されています。

参照先 force_enqueue_data, task_control_block::p_winfo, queue_delete_next(), queue_empty(), dataqueue_control_block::rwait_queue, と wait_complete.

{
    TCB     *p_tcb;

    if (!queue_empty(&(p_dtqcb->rwait_queue))) {
        p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->rwait_queue));
        ((WINFO_DTQ *)(p_tcb->p_winfo))->data = data;
        return(wait_complete(p_tcb));
    }
    else {
        force_enqueue_data(p_dtqcb, data);
        return(false);
    }
}

void initialize_dataqueue

(

void

)

dataqueue.c の 161 行で定義されています。

参照先 dataqueue_control_block::count, dtqcb_table, dtqinib_table, dataqueue_control_block::head, dataqueue_control_block::p_dtqinib, queue_initialize(), dataqueue_control_block::rwait_queue, dataqueue_control_block::swait_queue, dataqueue_control_block::tail, と tnum_dtq.

{
    uint_t  i;
    DTQCB   *p_dtqcb;

    for (p_dtqcb = dtqcb_table, i = 0; i < tnum_dtq; p_dtqcb++, i++) {
        queue_initialize(&(p_dtqcb->swait_queue));
        p_dtqcb->p_dtqinib = &(dtqinib_table[i]);
        queue_initialize(&(p_dtqcb->rwait_queue));
        p_dtqcb->count = 0U;
        p_dtqcb->head = 0U;
        p_dtqcb->tail = 0U;
    }
}

bool_t receive_data	(	DTQCB *	p_dtqcb,
		intptr_t *	p_data,
		bool_t *	p_reqdsp
	)

dataqueue.c の 294 行で定義されています。

参照先 dataqueue_control_block::count, dequeue_data, enqueue_data, task_control_block::p_winfo, queue_delete_next(), queue_empty(), dataqueue_control_block::swait_queue, と wait_complete.

{
    TCB     *p_tcb;
    intptr_t data;

    if (p_dtqcb->count > 0U) {
        dequeue_data(p_dtqcb, p_data);
        if (!queue_empty(&(p_dtqcb->swait_queue))) {
            p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->swait_queue));
            data = ((WINFO_DTQ *)(p_tcb->p_winfo))->data;
            enqueue_data(p_dtqcb, data);
            *p_reqdsp = wait_complete(p_tcb);
        }
        else {
            *p_reqdsp = false;
        }
        return(true);
    }
    else if (!queue_empty(&(p_dtqcb->swait_queue))) {
        p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->swait_queue));
        *p_data = ((WINFO_DTQ *)(p_tcb->p_winfo))->data;
        *p_reqdsp = wait_complete(p_tcb);
        return(true);
    }
    else {
        return(false);
    }
}

bool_t send_data	(	DTQCB *	p_dtqcb,
		intptr_t	data,
		bool_t *	p_reqdsp
	)

dataqueue.c の 243 行で定義されています。

参照先 dataqueue_control_block::count, dataqueue_initialization_block::dtqcnt, enqueue_data, dataqueue_control_block::p_dtqinib, task_control_block::p_winfo, queue_delete_next(), queue_empty(), dataqueue_control_block::rwait_queue, と wait_complete.

{
    TCB     *p_tcb;

    if (!queue_empty(&(p_dtqcb->rwait_queue))) {
        p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->rwait_queue));
        ((WINFO_DTQ *)(p_tcb->p_winfo))->data = data;
        *p_reqdsp = wait_complete(p_tcb);
        return(true);
    }
    else if (p_dtqcb->count < p_dtqcb->p_dtqinib->dtqcnt) {
        enqueue_data(p_dtqcb, data);
        *p_reqdsp = false;
        return(true);
    }
    else {
        return(false);
    }
}

---

変数

DTQCB dtqcb_table[]

const DTQINIB dtqinib_table[]

const ID tmax_dtqid