需要增加OpenWRT中IPC消息队列的缓冲区

我只是在学习如何使用消息队列，而且我也遇到了一些困难。 我正在使用两个完全独立的应用程序来进行testing – 一个是“发件人”，另一个是“接收者”。

当我运行发件人时，它发送15个string到pipe道，但随后失败，出现“资源暂时不可用”的错误。 我只需要在接收端使用消息，但为什么只有15条消息呢？ 我可能会发送很多消息，所以我想把它增加到一个更大的数字，比如1000左右。

我试图设置消息队列大小为32767，所以我至less期待31，但显然msg_qbytes是不相关的可以缓冲的消息数量。

发件人代码如下所示：

• 为什么“杀-15”有时失败？
• Perl中的警报（）相当于C？
• 如何监控linux自旋锁等待时间？
• 我如何改变XF86VidModeSetGamma（）我的第二台显示器的伽玛？
• 如何在C中访问驱动器的SMART数据

 #include <stdio.h> #include <stdlib.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <unistd.h> #include <string.h> #define MESSAGE_SIZE 1024 typedef struct msgbuf { long mtype; char mtext[MESSAGE_SIZE]; }; int main(int argc, char *argv[]) { int msgid; int ret; struct msqid_ds msg_settings; long key; struct msgbuf msg; key = strtol(argv[1], NULL, 10); // print the message queue ID for reading via msgrcv printf( "Getting message queue with key = %ld\n", key); usleep( 1000000); msgid = msgget( (key_t)key, 0666 | IPC_CREAT); if (msgid == -1) { perror("msgget failed with error"); exit(EXIT_FAILURE); } // read in current queue settings and then set the new // queue size. ret = msgctl(msgid, IPC_STAT, &msg_settings); msg_settings.msg_qbytes = 32767; msgctl( msgid, IPC_SET, &msg_settings); while( 1) { msg.mtype = 1; // we'll always leave this as 1 memset( &(msg.mtext), 0, MESSAGE_SIZE); sprintf( msg.mtext, "hi"); printf( "Sending data: %s\n", msg.mtext); ret = msgsnd( 1, &msg, MESSAGE_SIZE, IPC_NOWAIT); usleep( 500000); if( ret == -1) { perror( "msgsnd failed\n"); } printf( "leaving...\n"); return EXIT_SUCCESS; } 

接收器代码如下所示：

 #include <stdio.h> #include <stdlib.h> #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> #include <unistd.h> #include <string.h> #include <errno.h> #define MESSAGE_SIZE 1024 typedef struct msgbuf { long mtype; char mtext[MESSAGE_SIZE]; }; int main(int argc, char *argv[]) { long int msgtyp = 1; int ret; size_t msgsz; struct msgbuf mymsg; int msgid; msgid = strtol(argv[1], NULL, 10); printf( "Reading message queue with ID = %d\n", msgid); usleep( 1000000); while( 1) { msgsz = (size_t)MESSAGE_SIZE; ret = msgrcv( msgid, &mymsg, msgsz, msgtyp, IPC_NOWAIT); if( ret == ENOMSG) { usleep( 100000); continue; } if( ret == -1) { perror( "msgrcv failed"); } else { printf( "Read data: %s", mymsg.mtext); } usleep( 100000); } return EXIT_SUCCESS; } 

 On the receiver side, I always get a "Argument list too long" error. I changed my code to just use a #define so that I'm (hopefully) not making any errors when passing the size as an argument. But when I looked online for solutions to the E2BIG error, it says that the size of the message is too large. How can that be? 

 [E2BIG] Argument list too long. The size in bytes of the message is greater than msgsz and the MSG_NOERROR flag is not set in the msgflg parameter.