12

キューメッセージが空かどうか知りたい。私は次のようにmsg_ctl（）を使用しましたが、機能しません：

struct msqid_ds buf;
int num_messages;

rc = msgctl(msqid, IPC_STAT, &buf);

そして私はこのピーク関数を使用しました：

int peek_message( int qid, long type )
{
    int result, length;
    if((result = msgrcv( qid, NULL, 0, type, IPC_NOWAIT)) == -1) {
        if(errno==E2BIG)
            return(1);
    }

    return(0);
}

どちらの場合も、キューにメッセージを送信する前後で同じ結果が得られます。

メッセージは正常にキューに到達します。送信した内容を読み取ってテストしました。

4

1 に答える 1

3

正しく動作しているように見えるサンプル コードを書きました。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <errno.h>

struct msgbuf {
    long mtype;       /* message type, must be > 0 */
    char mtext[1];    /* message data */
};

int main(void) {
    int msqid;
    //msqid = msgget(IPC_PRIVATE, (IPC_CREAT | IPC_EXCL | 0600));
    msqid = msgget((key_t)1235, 0600 | IPC_CREAT);

    printf("Using message queue %d\n", msqid);
    struct msqid_ds buf;

    int rc = msgctl(msqid, IPC_STAT, &buf);

    uint msg = (uint)(buf.msg_qnum);
    printf("# messages before post: %u\n", msg);

    printf("Posting message to queue...\n");
    struct msgbuf qmsg;
    qmsg.mtype = 100;
    qmsg.mtext[0] = 'T';

    int res = msgsnd(msqid, &qmsg, 1, MSG_NOERROR);

    rc = msgctl(msqid, IPC_STAT, &buf);

    msg = (uint)(buf.msg_qnum);
    printf("# messages after post: %u\n", msg);

    return 0;
}

多分それはあなたに役立つでしょうか？このコードを使用すると、キューのメッセージ数が正しく増加するように見えます。

于 2012-10-10T18:00:01.887 に答える