/*********************************************************************************
 *      Copyright:  (C) 2025 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  mq_send.c
 *    Description:  This file is Message Queue(sender) example program.
 *
 *        Version:  1.0.0(11/10/2025)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
 *      ChangeLog:  1, Release initial version on "11/10/2025 10:06:53 AM"
 *
 ********************************************************************************/
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define FTOK_PATH           "/dev/zero"
#define FTOK_PROJID         0x22

typedef struct msg_s
{
    long  mtype;
    char  mtext[512];
} msg_t;

int main(int argc, char **argv)
{
    key_t             key;
    msg_t             msg;
    int               msgid;
    int               type=2;
    int               i;

    if( (key=ftok(FTOK_PATH, FTOK_PROJID)) < 0 )
    {
        printf("ftok() get IPC token failure: %s\n", strerror(errno));
        return -1;
    }

    msgid = msgget(key, IPC_CREAT|0666);
    if( msgid < 0)
    {
        printf("shmget() create shared memroy failure: %s\n", strerror(errno));
        return -2;
    }
    printf("key[%d] msgid[%d] msgypte[0x%0x]\n", (int)key, msgid, type);

    while (1)
    {
        printf("Input message: ");
        memset(msg.mtext, 0, sizeof(msg.mtext));
        fgets(msg.mtext, sizeof(msg.mtext), stdin);
        msg.mtype = type;

        if( msgsnd(msgid, &msg, strlen(msg.mtext)+1, IPC_NOWAIT) < 0)
        {
            printf("msgsnd() send message failure: %s\n", strerror(errno));
            break;
        }

        if (strncasecmp(msg.mtext, "exit", 4) == 0)
            break;
    }

    msgctl(msgid, IPC_RMID, NULL);
    return 0;
}