msgsnd()¶

استدعاء النظام msgsnd() يُلحق نسخة من الرسالة المشار إليها بواسطة msgp إلى طابور الرسائل الذي يُحدد معرفه بواسطة msqid.

إذا توفرت مساحة كافية في الطابور، ينجح msgsnd() فورًا. سعة الطابور تُحكم بواسطة الحقل msg_qbytes في بنية البيانات المرتبطة بطابور الرسائل. أثناء إنشاء الطابور، يُهيأ هذا الحقل إلى MSGMNB بايت، لكن يمكن تعديل هذا الحد باستخدام msgctl(2). يُعتبر طابور الرسائل ممتلئًا إذا تحقق أحد الشرطين التاليين:

•

إضافة رسالة جديدة إلى الطابور ستؤدي إلى تجاوز العدد الإجمالي للبايتات في الطابور للحجم الأقصى للطابور (الحقل msg_qbytes).

•

إضافة رسالة أخرى إلى الطابور ستؤدي إلى تجاوز العدد الإجمالي للرسائل في الطابور للحجم الأقصى للطابور (الحقل msg_qbytes). هذا الفحص ضروري لمنع وضع عدد غير محدود من الرسائل ذات الطول الصفري في الطابور. على الرغم من أن هذه الرسائل لا تحتوي على بيانات، إلا أنها تستهلك ذاكرة نواة (مقفلة).

إذا لم تتوفر مساحة كافية في الطابور، فإن السلوك المبدئي لـ msgsnd() هو الحظر حتى تتوفر مساحة. إذا تم تحديد IPC_NOWAIT في msgflg، فإن الاستدعاء يفشل بدلاً من ذلك مع الخطأ EAGAIN.

قد يفشل استدعاء msgsnd() المحظور أيضًا إذا:

•

تمت إزالة الطابور، وفي هذه الحالة يفشل استدعاء النظام مع تعيين errno إلى EIDRM؛ أو

•

تم التقاط إشارة، وفي هذه الحالة يفشل استدعاء النظام مع تعيين errno إلى EINTR؛ انظر signal(7). (لا يُعاد تشغيل msgsnd() آليًا بعد مقاطعته بواسطة معالج إشارة، بغض النظر عن إعداد العلم SA_RESTART عند إنشاء معالج الإشارة.)

عند الإكمال بنجاح، تُحدث بنية بيانات طابور الرسائل كما يلي:

•

msg_lspid يُضبط إلى معرف العملية للعملية المستدعية.

•

msg_qnum يُزاد بمقدار 1.

•

msg_stime يُضبط إلى الوقت الحالي.

msgrcv()¶

استدعاء النظام msgrcv() يزيل رسالة من الطابور المحدد بواسطة msqid ويضعها في المخزن المؤقت المشار إليه بواسطة msgp.

الوسيط msgsz يُحدد الحجم الأقصى بالبايتات للعضو mtext من البنية المشار إليها بواسطة الوسيط msgp. إذا كان طول نص الرسالة أكبر من msgsz، فإن السلوك يعتمد على ما إذا كان MSG_NOERROR محددًا في msgflg. إذا تم تحديد MSG_NOERROR، فسيُقتطع نص الرسالة (وسيُفقد الجزء المقتطع)؛ إذا لم يُحدد MSG_NOERROR، فلن تُزال الرسالة من الطابور ويفشل استدعاء النظام بإرجاع -1 مع تعيين errno إلى E2BIG.

ما لم يُحدد MSG_COPY في msgflg (انظر أدناه)، فإن الوسيط msgtyp يُحدد نوع الرسالة المطلوبة، كما يلي:

•

إذا كان msgtyp يساوي 0، فتُقرأ أول رسالة في الطابور.

•

إذا كان msgtyp أكبر من 0، فتُقرأ أول رسالة في الطابور من النوع msgtyp، ما لم يُحدد MSG_EXCEPT في msgflg، وفي هذه الحالة تُقرأ أول رسالة في الطابور من نوع لا يساوي msgtyp.

•

إذا كان msgtyp أقل من 0، فتُقرأ أول رسالة في الطابور ذات النوع الأدنى الأصغر من أو المساوي للقيمة المطلقة لـ msgtyp.

الوسيط msgflg هو قناع بتات يُبنى بواسطة OR معًا صفرًا أو أكثر من الأعلام التالية:

IPC_NOWAIT

أرجع فورًا إذا لم تكن هناك رسالة من النوع المطلوب في الطابور. يفشل استدعاء النظام مع تعيين errno إلى ENOMSG.

MSG_COPY (منذ لينكس 3.8)

اجلب نسخة غير مدمرة من الرسالة في الموضع الترتيبي في الطابور المحدد بواسطة msgtyp (تُعتبر الرسائل مرقمة بدءًا من 0).

يجب تحديد هذه العلامة بالتزامن مع IPC_NOWAIT، مما يؤدي إلى أنه إذا لم تكن هناك رسالة متاحة في الموضع المحدد، يفشل الاستدعاء فورًا مع الخطأ ENOMSG. نظرًا لأنهما يغيران معنى msgtyp بطرق متعامدة، لا يمكن تحديد كل من MSG_COPY وMSG_EXCEPT في msgflg.

أُضيفت العلامة MSG_COPY لتنفيذ مرفق استعادة نقطة التفتيش للنواة وهي متاحة فقط إذا بُنيت النواة مع الخيار CONFIG_CHECKPOINT_RESTORE.

MSG_EXCEPT

تُستخدم مع msgtyp أكبر من 0 لقراءة أول رسالة في الطابور بنوع رسالة يختلف عن msgtyp.

MSG_NOERROR

لاقتطاع نص الرسالة إذا كان أطول من msgsz بايت.

إذا لم تكن هناك رسالة من النوع المطلوب متاحة ولم يُحدد IPC_NOWAIT في msgflg، فتُحجب العملية المستدعية حتى يحدث أحد الشروط التالية:

•

تُوضع رسالة من النوع المطلوب في الطابور.

•

تُزال طابور الرسائل من النظام. في هذه الحالة، يفشل استدعاء النظام مع تعيين errno إلى EIDRM.

•

تلتقط العملية المستدعية إشارة. في هذه الحالة، يفشل استدعاء النظام مع تعيين errno إلى EINTR. (لا يُعاد تشغيل msgrcv() آليًا بعد مقاطعته بواسطة معالج إشارة، بغض النظر عن إعداد العلامة SA_RESTART عند إنشاء معالج إشارة.)

عند الإكمال بنجاح، تُحدث بنية بيانات طابور الرسائل كما يلي:

يُعيّن msg_lrpid إلى معرف العملية للعملية المستدعية.

يُقلّص msg_qnum بمقدار 1.

يُعيّن msg_rtime إلى الوقت الحالي.

مصدر البرنامج¶

#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <time.h>
#include <unistd.h>
struct msgbuf {


    long mtype;


    char mtext[80];
};
static void
usage(char *prog_name, char *msg)
{


    if (msg != NULL)


        fputs(msg, stderr);


    fprintf(stderr, "Usage: %s [options]\n", prog_name);


    fprintf(stderr, "Options are:\n");


    fprintf(stderr, "-s        send message using msgsnd()\n");


    fprintf(stderr, "-r        read message using msgrcv()\n");


    fprintf(stderr, "-t        message type (default is 1)\n");


    fprintf(stderr, "-k        message queue key (default is 1234)\n");


    exit(EXIT_FAILURE);
}
static void
send_msg(int qid, int msgtype)
{


    time_t         t;


    struct msgbuf  msg;


    msg.mtype = msgtype;


    time(&t);


    snprintf(msg.mtext, sizeof(msg.mtext), "a message at %s",


             ctime(&t));


    if (msgsnd(qid, &msg, sizeof(msg.mtext),


               IPC_NOWAIT) == -1)


    {


        perror("msgsnd error");


        exit(EXIT_FAILURE);


    }


    printf("sent: %s\n", msg.mtext);
}
static void
get_msg(int qid, int msgtype)
{


    struct msgbuf msg;


    if (msgrcv(qid, &msg, sizeof(msg.mtext), msgtype,


               MSG_NOERROR | IPC_NOWAIT) == -1) {


        if (errno != ENOMSG) {


            perror("msgrcv");


            exit(EXIT_FAILURE);


        }


        printf("No message available for msgrcv()\n");


    } else {


        printf("message received: %s\n", msg.mtext);


    }
}
int
main(int argc, char *argv[])
{


    int  qid, opt;


    int  mode = 0;               /* 1 = send, 2 = receive */


    int  msgtype = 1;


    int  msgkey = 1234;


    while ((opt = getopt(argc, argv, "srt:k:")) != -1) {


        switch (opt) {


        case 's':


            mode = 1;


            break;


        case 'r':


            mode = 2;


            break;


        case 't':


            msgtype = atoi(optarg);


            if (msgtype <= 0)


                usage(argv[0], "-t option must be greater than 0\n");


            break;


        case 'k':


            msgkey = atoi(optarg);


            break;


        default:


            usage(argv[0], "Unrecognized option\n");


        }


    }


    if (mode == 0)


        usage(argv[0], "must use either -s or -r option\n");


    qid = msgget(msgkey, IPC_CREAT | 0666);


    if (qid == -1) {


        perror("msgget");


        exit(EXIT_FAILURE);


    }


    if (mode == 2)


        get_msg(qid, msgtype);


    else


        send_msg(qid, msgtype);


    exit(EXIT_SUCCESS);
}