【发布时间】:2014-12-03 21:24:14
【问题描述】:
好的,我正在做一个大学项目,很抱歉这个愚蠢的问题。
我的任务是通过消息队列推送一个字符串,派生一个子进程并接收消息,然后通过同一个消息队列将响应发送回父进程,所有这些都在循环中完成。
我的代码是在家里编写的,它运行良好,但部分任务是让它在大学服务器上运行,这是我遇到的问题。
这是我的代码的相关部分:
父进程:
void fel2()
{
int messq, status;
key_t key = ftok("key", 1);
messq = msgget( key, 0600 | IPC_CREAT );
OpBike * ob_first = NULL;
ob_first = ob_read_in(ob_first);
char confirm_string[64];
while (exists_busy_bike(ob_first))
{
sleep(5);
ob_first = NULL;
ob_first = ob_read_in(ob_first);
int busy_bikes = count_busy_bikes(ob_first);
ob_first = NULL;
srand(time(NULL));
int bret = (rand() % busy_bikes);
ob_first = ob_read_in(ob_first);
ob_first = ob_read_in(ob_first);
int ret_bike_id = get_bikeid_by_jumps(ob_first, bret);
char ret_bike_id_char[64];
snprintf(ret_bike_id_char, 64, "%d", ret_bike_id);
send(messq, ret_bike_id_char);
fel2_child(messq, key);
ob_first = NULL;
wait(NULL);
strcpy(confirm_string, recv(messq));
ob_first = NULL;
ob_first = ob_read_in(ob_first);
wait(NULL);
}
status = msgctl( messq, IPC_RMID, NULL );
wait(NULL);
return;
}
子进程:
int fel2_child(int messq, key_t key)
{
pid_t child = fork();
if (child > 0) // parent process does nothing here
{
}
else { // child
char rbikeid[64];
strcpy(rbikeid, recv(messq));
OpBike * ob_first = NULL;
ob_first = ob_read_in(ob_first);
OpRent * or_first = NULL;
or_first = or_read_in(or_first);
OpBike * bike_ret = get_bike_by_bikeid(ob_first, rbikeid);
char check[64];
strcpy(check, bike_ret->bike_id);
ob_first = NULL;
ob_first = ob_read_in(ob_first);
or_add_return(or_first, ob_first, rbikeid);
ob_first = NULL;
ob_first = ob_read_in(ob_first);
OpBike * bike_check = get_bike_by_bikeid(ob_first, rbikeid);
strcpy(check, bike_check->bike_status);
send(messq, check);
exit(0);
}
return 0;
}
发送者和接收者函数:
int send( int messq, char * text )
{
struct message me = { 119, "asd" };
int status;
strcpy(me.mtext, text);
// THIS IS WHERE EVERYTHING GOES WRONG
status = msgsnd( messq, &me, strlen ( me.mtext ) + 1 , IPC_NOWAIT );
if ( status < 0 )
perror("msgsnd");
return 0;
}
char * recv( int messq)
{
struct message me;
int status;
status = msgrcv(messq, &me, 1024, 119, 0 );
if ( status < 0 )
perror("msgsnd");
char * ret;
ret = malloc(sizeof( char ) * strlen (me.mtext));
strcpy(ret, me.mtext);
return ret;
}
在我的家用电脑上运行上述代码可以完美运行。运行 Ubuntu 14.10,我的代码使用 gcc 4.9.1 编译。但是,它不能在运行 SLES 11 SP 1 的学校服务器上运行,使用 gcc 4.3.4 编译代码。
问题是我尝试发送的字符串没有正确发送。它到达函数,被复制到消息结构中,然后在过程中的某个地方消失,唯一读回的是未定义的数据。
我现在有点想不通了。我尝试将消息队列的声明放在其他地方(正如我的教授所建议的那样),但这并没有解决问题。我无法更新我学校服务器上的编译器,所以这正是我必须处理的。你们中是否有人通过不同的编译器版本经历过系统调用的奇怪行为?有人知道如何解决这个问题吗?
提前感谢您的回复!
编辑2: struct message 的定义。
struct message {
long mtype;
char mtext [ 1024 ];
};
【问题讨论】:
-
已修复。 AFAIK
msgsnd()是 SystemV 的东西。我之所以选择这个,是因为我听说它比 posix 消息队列实现更容易使用。 -
请给出“struct message”的定义。
-
好的...请说明它是如何定义的。另外,你应该检查返回码:ftok() 和 msgget()。
-
在函数“send()”中你有这个语句“struct message me”“struct message”的定义是什么......不是“struct msgbuf”??
-
@TonyB 我添加了一个编辑来向您展示定义的方式。
ftok()生成一个密钥来创建队列。msgget()返回与队列关联的 id。
标签: c gcc version system-calls