ptrecv.c File Reference

ポートからメッセージを受信する。受信前にメッセージが空の場合はブロッキングする。 More...

#include <xinu.h>

Include dependency graph for ptrecv.c:

Go to the source code of this file.

Functions
uint32	ptrecv (int32 portid)
	ポートからメッセージを受信する。受信前にメッセージが空の場合はブロッキングする。 More...

Detailed Description

ポートからメッセージを受信する。受信前にメッセージが空の場合はブロッキングする。

Definition in file ptrecv.c.

Function Documentation

ptrecv()

uint32 ptrecv

(

int32

portid

)

ポートからメッセージを受信する。受信前にメッセージが空の場合はブロッキングする。

Step1. 割り込みを禁止する。
Step2. ポートIDが不正、もしくはポートがALLOC状態でなければ割り込み状態を復元し、処理を終了する。
Step3. 送信側セマフォに空きが出るまで待機する。
セマフォ待機後、以下の状態のいずれかであれば割り込み状態を復元し、処理を終了する。
　・セマフォ待機結果がエラー
　・ポートがALLOC状態以外
　・シーケンス番号が変化した場合
Step4. ポートフリーノードがNULL状態であれば（メッセージを使い果たした場合）、Panic状態とする。
Step5. ポートフリーノードからメッセージノード1個を切り出し、メッセージノードにメッセージを追加する。
Step6. メッセージノードをメッセージリストの末尾に追加する。
Step7. 受信セマフォにシグナルを送る。
Step8. 割り込み状態を復元する。

Parameters

[in]

portid

使用するポートのID

Returns

メッセージ送信時はOKを返し、以下の場合はSYSERRを返す。
　・引数のポートIDが不正
・セマフォ待機結果がエラー
　・ポートがALLOC状態以外
　・シーケンス番号が変化した場合

Definition at line 29 of file ptrecv.c.

References disable(), isbadport, NULL, porttab, PT_ALLOC, ptfree, ptentry::pthead, ptnode::ptmsg, ptnode::ptnext, ptentry::ptrsem, ptentry::ptseq, ptentry::ptssem, ptentry::ptstate, ptentry::pttail, restore(), signal(), SYSERR, and wait().

{
    intmask mask;           /* Saved interrupt mask     */
    struct ptentry *ptptr;  /* Pointer to table entry   */
    int32 seq;              /* Local copy of sequence num.  */
    umsg32 msg;             /* Message to return        */
    struct ptnode *msgnode; /* First node on message list   */

    mask = disable();
    if (isbadport(portid) ||
        (ptptr = &porttab[portid])->ptstate != PT_ALLOC)
    {
        restore(mask);
        return (uint32)SYSERR;
    }

    /* Wait for message and verify that the port is still allocated */

    seq = ptptr->ptseq; /* Record orignal sequence  */
    if (wait(ptptr->ptrsem) == SYSERR || ptptr->ptstate != PT_ALLOC || ptptr->ptseq != seq)
    {
        restore(mask);
        return (uint32)SYSERR;
    }

    /* Dequeue first message that is waiting in the port */

    msgnode = ptptr->pthead;
    msg = msgnode->ptmsg;
    if (ptptr->pthead == ptptr->pttail) /* Delete last item */
        ptptr->pthead = ptptr->pttail = NULL;
    else
        ptptr->pthead = msgnode->ptnext;
    msgnode->ptnext = ptfree; /* Return to free list    */
    ptfree = msgnode;
    signal(ptptr->ptssem);
    restore(mask);
    return msg;
}

Here is the call graph for this function: