pridataq.h

#include <queue.h>

ソースコードを見る。

データ構造
struct	pridata_management_block
struct	pridataq_initialization_block
struct	pridataq_control_block
struct	pridataq_waiting_information
マクロ定義
#define	PDQID(p_pdqcb)   ((ID)(((p_pdqcb) - pdqcb_table) + TMIN_PDQID))
型定義
typedef struct pridata_management_block	PDQMB
typedef struct pridataq_initialization_block	PDQINIB
typedef struct pridataq_control_block	PDQCB
typedef struct pridataq_waiting_information	WINFO_PDQ
関数
void	initialize_pridataq (void)
void	enqueue_pridata (PDQCB *p_pdqcb, intptr_t data, PRI datapri)
void	dequeue_pridata (PDQCB *p_pdqcb, intptr_t *p_data, PRI *p_datapri)
bool_t	send_pridata (PDQCB *p_pdqcb, intptr_t data, PRI datapri, bool_t *p_reqdsp)
bool_t	receive_pridata (PDQCB *p_pdqcb, intptr_t *p_data, PRI *p_datapri, bool_t *p_reqdsp)
変数
const ID	tmax_pdqid
const PDQINIB	pdqinib_table []
PDQCB	pdqcb_table []

---

マクロ定義

#define PDQID

(

p_pdqcb

)

((ID)(((p_pdqcb) - pdqcb_table) + TMIN_PDQID))

pridataq.h の 129 行で定義されています。

参照元 ref_tsk().

---

型定義

typedef struct pridataq_control_block PDQCB

typedef struct pridataq_initialization_block PDQINIB

typedef struct pridata_management_block PDQMB

pridataq.h の 55 行で定義されています。

typedef struct pridataq_waiting_information WINFO_PDQ

---

関数

void dequeue_pridata	(	PDQCB *	p_pdqcb,
		intptr_t *	p_data,
		PRI *	p_datapri
	)

pridataq.c の 207 行で定義されています。

参照先 pridataq_control_block::count, pridata_management_block::data, pridata_management_block::datapri, pridataq_control_block::p_freelist, pridataq_control_block::p_head, と pridata_management_block::p_next.

{
    PDQMB   *p_pdqmb;

    p_pdqmb = p_pdqcb->p_head;
    p_pdqcb->p_head = p_pdqmb->p_next;
    p_pdqcb->count--;

    *p_data = p_pdqmb->data;
    *p_datapri = p_pdqmb->datapri;

    p_pdqmb->p_next = p_pdqcb->p_freelist;
    p_pdqcb->p_freelist = p_pdqmb;
}

void enqueue_pridata	(	PDQCB *	p_pdqcb,
		intptr_t	data,
		PRI	datapri
	)

pridataq.c の 170 行で定義されています。

参照先 pridataq_control_block::count, pridata_management_block::data, pridata_management_block::datapri, NULL, pridataq_control_block::p_freelist, pridataq_control_block::p_head, pridata_management_block::p_next, pridataq_control_block::p_pdqinib, pridataq_initialization_block::p_pdqmb, と pridataq_control_block::unused.

{
    PDQMB   *p_pdqmb;
    PDQMB   **pp_prev_next, *p_next;

    if (p_pdqcb->p_freelist != NULL) {
        p_pdqmb = p_pdqcb->p_freelist;
        p_pdqcb->p_freelist = p_pdqmb->p_next;
    }
    else {
        p_pdqmb = p_pdqcb->p_pdqinib->p_pdqmb + p_pdqcb->unused;
        p_pdqcb->unused++;
    }

    p_pdqmb->data = data;
    p_pdqmb->datapri = datapri;

    pp_prev_next = &(p_pdqcb->p_head);
    while ((p_next = *pp_prev_next) != NULL) {
        if (p_next->datapri > datapri) {
            break;
        }
        pp_prev_next = &(p_next->p_next);
    }
    p_pdqmb->p_next = p_next;
    *pp_prev_next = p_pdqmb;
    p_pdqcb->count++;
}

void initialize_pridataq

(

void

)

pridataq.c の 146 行で定義されています。

参照先 pridataq_control_block::count, NULL, pridataq_control_block::p_freelist, pridataq_control_block::p_head, pridataq_control_block::p_pdqinib, pdqcb_table, pdqinib_table, queue_initialize(), pridataq_control_block::rwait_queue, pridataq_control_block::swait_queue, tnum_pdq, と pridataq_control_block::unused.

{
    uint_t  i;
    PDQCB   *p_pdqcb;

    for (p_pdqcb = pdqcb_table, i = 0; i < tnum_pdq; p_pdqcb++, i++) {
        queue_initialize(&(p_pdqcb->swait_queue));
        p_pdqcb->p_pdqinib = &(pdqinib_table[i]);
        queue_initialize(&(p_pdqcb->rwait_queue));
        p_pdqcb->count = 0U;
        p_pdqcb->p_head = NULL;
        p_pdqcb->unused = 0U;
        p_pdqcb->p_freelist = NULL;
    }
}

bool_t receive_pridata	(	PDQCB *	p_pdqcb,
		intptr_t *	p_data,
		PRI *	p_datapri,
		bool_t *	p_reqdsp
	)

pridataq.c の 259 行で定義されています。

参照先 pridataq_control_block::count, dequeue_pridata, enqueue_pridata, task_control_block::p_winfo, queue_delete_next(), queue_empty(), pridataq_control_block::swait_queue, と wait_complete.

{
    TCB     *p_tcb;
    intptr_t data;
    PRI     datapri;

    if (p_pdqcb->count > 0U) {
        dequeue_pridata(p_pdqcb, p_data, p_datapri);
        if (!queue_empty(&(p_pdqcb->swait_queue))) {
            p_tcb = (TCB *) queue_delete_next(&(p_pdqcb->swait_queue));
            data = ((WINFO_PDQ *)(p_tcb->p_winfo))->data;
            datapri = ((WINFO_PDQ *)(p_tcb->p_winfo))->datapri;
            enqueue_pridata(p_pdqcb, data, datapri);
            *p_reqdsp = wait_complete(p_tcb);
        }
        else {
            *p_reqdsp = false;
        }
        return(true);
    }
    else if (!queue_empty(&(p_pdqcb->swait_queue))) {
        p_tcb = (TCB *) queue_delete_next(&(p_pdqcb->swait_queue));
        *p_data = ((WINFO_PDQ *)(p_tcb->p_winfo))->data;
        *p_datapri = ((WINFO_PDQ *)(p_tcb->p_winfo))->datapri;
        *p_reqdsp = wait_complete(p_tcb);
        return(true);
    }
    else {
        return(false);
    }
}

bool_t send_pridata	(	PDQCB *	p_pdqcb,
		intptr_t	data,
		PRI	datapri,
		bool_t *	p_reqdsp
	)

pridataq.c の 230 行で定義されています。

参照先 pridataq_control_block::count, enqueue_pridata, pridataq_control_block::p_pdqinib, task_control_block::p_winfo, pridataq_initialization_block::pdqcnt, queue_delete_next(), queue_empty(), pridataq_control_block::rwait_queue, と wait_complete.

{
    TCB     *p_tcb;

    if (!queue_empty(&(p_pdqcb->rwait_queue))) {
        p_tcb = (TCB *) queue_delete_next(&(p_pdqcb->rwait_queue));
        ((WINFO_PDQ *)(p_tcb->p_winfo))->data = data;
        ((WINFO_PDQ *)(p_tcb->p_winfo))->datapri = datapri;
        *p_reqdsp = wait_complete(p_tcb);
        return(true);
    }
    else if (p_pdqcb->count < p_pdqcb->p_pdqinib->pdqcnt) {
        enqueue_pridata(p_pdqcb, data, datapri);
        *p_reqdsp = false;
        return(true);
    }
    else {
        return(false);
    }
}

---

変数

PDQCB pdqcb_table[]

const PDQINIB pdqinib_table[]

const ID tmax_pdqid