洗塵齋

# re: msgsnd與msgrcv函數(shù)出現(xiàn)invalid參數(shù)的問題 2008-07-18 23:45 jonny

我也碰到同樣的問題了，多虧了樓主，謝啦。  回復(fù)  更多評論   

# re: msgsnd與msgrcv函數(shù)出現(xiàn)invalid參數(shù)的問題 2008-10-07 10:03 xwy48563526

這個(gè)linux程序設(shè)計(jì)書上已經(jīng)寫的很清楚了  回復(fù)  更多評論   

# re: msgsnd與msgrcv函數(shù)出現(xiàn)invalid參數(shù)的問題 2009-03-14 21:05 鄧燕均

今天我也是 發(fā)現(xiàn)這個(gè)問題 ，琢磨了近一個(gè)小時(shí) ，最后我是亂改了下，把sizeof(msg) 用一個(gè)特定的 數(shù)字替換，結(jié)果可以接收和發(fā)送。  回復(fù)  更多評論   

# re: msgsnd與msgrcv函數(shù)出現(xiàn)invalid參數(shù)的問題 2009-03-14 21:06 鄧燕軍

今天我也是 發(fā)現(xiàn)這個(gè)問題 ，琢磨了近一個(gè)小時(shí) ，最后我是亂改了下，把sizeof(msg) 用一個(gè)特定的 數(shù)字替換，結(jié)果可以接收和發(fā)送。

/*客服端*/
#include <unistd.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>

struct msgbuf1
{
long msgto;
long msgfrom;
char buffer[100];
} ;

int main()
{
int rtrn, msqid ;
int pid;
struct msgbuf1 msg;


if ((msqid = msgget(0x888, IPC_CREAT|0600)) == -1)
{
perror("msgget");
exit(1);
}
switch(fork())
{
case -1:
perror("fork");
exit(1);
case 0:
execl("server3", "server3", NULL);
perror("execl");
exit(2);
}
pid =getpid();
while(1)
{
msg.msgto=1;
msg.msgfrom = pid;
write(fileno(stdout), "cmd>",5);
memset(msg.buffer, 0, sizeof(msg.buffer));
rtrn= read(fileno(stdin), msg.buffer, BUFSIZ);

if(rtrn == 0)
{
break;
}
else
{
msg.buffer[rtrn] = 0;
printf("client send: %s\n", msg.buffer);
rtrn=msgsnd(msqid, &msg, sizeof(msg), 0);
if (rtrn<0)
{
perror("msgsnd");
exit(2);
}
}
if((rtrn == msgrcv(msqid,&msg, sizeof(msg), pid, 0)) !=-1)
write(fileno(stdout), msg.buffer, strlen(msg.buffer));
}

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


/*******************************/
/*服務(wù)器端*/
#include <unistd.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>

struct msgbuf1
{
long msgto;
long msgfrom;
char buffer[BUFSIZ];
} ;
void process_msg(char *b,int len);

int main()
{
int rtrn;
int mid;
struct msgbuf1 msg;

if ((mid = msgget(0x888, IPC_CREAT|0600)) == -1)
{
perror("msgget");
exit(1);
}

while(1)
{
rtrn=msgrcv(mid, &msg, sizeof(msg), 1 , 0);
if(rtrn < -1)
{
perror("msgrcv");
exit(-1);
}
else if(rtrn ==0)
break;
else
{
process_msg(msg.buffer,strlen(msg.buffer));
printf("server received %s\n", msg.buffer);
msg.msgto = msg.msgfrom;
msg.msgfrom = 1;
if(msgsnd(mid,(struct msgbuf*)&msg, sizeof(msg), 0) ==-1)
{
perror("Server: msgsnd");
exit(3);
}
}
}
msgctl(mid, IPC_RMID,(struct msqid_ds*)0);

return 0;
}


void process_msg(char *b,int len)
{
int i = 0;
for(i = 0; i<len; i++)
if(isalpha(*(b+1)))
*(b+i) = toupper(*(b+i));

}
















  回復(fù)  更多評論