У меня проблемы с правильным чтением и записью между процессом с помощью fork () и ncurses.У меня есть процесс (позвольте мне называть его сыном), который контролирует вход в приложении, а также у меня есть процесс (родитель), который контролирует логику приложения.
Моя проблема в том, что я пишу внутриканал для передачи информации от сына к родителю, но родитель ничего не читает.
Из-за неблокирующей природы я добавил ожидания и сигналы для взаимного исключения процесса во время чтения и записи.
Позвольте мне показать вам некоторый код:)
//---- pipes, read i write no bloquejants ---------
int flags_f0 = fcntl(pip_fill[0],F_GETFL);
int flags_f1 = fcntl(pip_fill[1],F_GETFL);
int flags_p0 = fcntl(pip_pare[0],F_GETFL);
int flags_p1 = fcntl(pip_pare[1],F_GETFL);
int flags_read = fcntl(0,F_GETFL);
int flags_write = fcntl(1,F_GETFL);
fcntl(pip_fill[0],F_SETFL,flags_f0 | O_NONBLOCK);
fcntl(pip_fill[1],F_SETFL,flags_f1 | O_NONBLOCK);
fcntl(pip_pare[0],F_SETFL,flags_p0 | O_NONBLOCK);
fcntl(pip_pare[1],F_SETFL,flags_p1 | O_NONBLOCK);
fcntl(0,F_SETFL,flags_read | O_NONBLOCK);
fcntl(1,F_SETFL,flags_write | O_NONBLOCK);
//-------------------------------------------------
//---- semàfors ----
int id_Sem;
id_Sem = shmget (IPC_PRIVATE, sizeof(int), IPC_CREAT | 0600);
if (id_Sem == -1)
{
write(2,"Error!\n",7);
Sortir(&ll_a_r,&ll_res,&ll_mis,&ll_n_mis,&c,&c_write);
exit (0);
}
if(SEM_constructor(&sem1) < 0)
{
shmctl(id_Sem, IPC_RMID, NULL);
}
if(SEM_constructor(&sem2) < 0)
{
shmctl(id_Sem, IPC_RMID, NULL);
SEM_destructor (&sem1);
}
SEM_init (&sem1, 0);
SEM_init (&sem2, 0);
//------------------
//la primera vegada que entri en el fill posarem les següents dades a la var valor
Afegir_Cadena(&c,"M0:"); //on M0: menú principal
pantalla(w);
pinta_menu_principal(w,a_menus); //pinta el menú principal per pantalla
pid = fork();
switch (pid)
{
case -1: //ERROR
write(2,"Error!\n",7);
Sortir(&ll_a_r,&ll_res,&ll_mis,&ll_n_mis,&c,&c_write);
exit(-1);
break;
case 0: //FILL
close(pip_fill[0]); //tanquem l'extrem de la pipe que no usem (la de lectura)
close(pip_pare[1]); //tanquem l'extrem de la pipe que no usem (la d'escriptura)
while(1)
{
cc = getch();
if(cc != ERR)
{
if(cc == 0x0A)
{
printf("Enter [%s]\n", Retorna_Cad(&c_write));
SEM_wait (&sem1);
tmp = write(pip_fill[1],Retorna_Cad(&c_write),Retorna_Longitud(&c_write) + 1); //el fill escriu a la pipe la variable c
SEM_signal (&sem1); //longitud + 1: el +1 es per el \0
//printf("Ret: %d",tmp);
Esborra_Cadena(&c_write);
actualitza_pantalla(w);
}
else
{
Afegir_Caracter(&c_write,cc);
cc = ERR;
}
}
//***** READ PARE *********
SEM_wait (&sem2);
nbytes = read(pip_pare[0],valor,256); //el fill llegeix de la pipe la var un cop ha estat tractada per el pare
SEM_signal (&sem2);
if (nbytes > -1)
{
Inserir_Cad(&c,valor);
//tractar el missatge del pare
Tractar_Missatge_del_Pare(&ll_mis,&ll_res,&c,w,a_menus,&ll_a_r);
}
}
break;
default: //PARE
close(pip_fill[1]); //tanquem l'extrem de la pipe que no usem (la d'escriptura)
close(pip_pare[0]); //tanquem l'extrem de la pipe que no usem (la de lectura)
while(1)
{
temps_inici = (float)clock();
SEM_wait (&sem1);
nbytes = read(pip_fill[0],valor,256);//el pare llegeix de la pipe la var c
SEM_signal (&sem1);
if (nbytes > -1 || tmp > 0)
{ //vol dir que hem llegit algo per la pipe pip_fill
tmp++;
Inserir_Cad(&c,valor);
Tractar_Missatge_del_Fill (&ll_mis,&c,&ll_n_mis,w);
SEM_wait (&sem2);
write(pip_pare[1],Retorna_Cad(&c),Retorna_Longitud(&c) + 1); //el pare escriu a la pipe la var tractada
SEM_signal (&sem2);
actualitza_pantalla(w);
}
temps_final = (float)clock();
temps_per_bucle = (float)(temps_final - temps_inici) / (float)CLOCKS_PER_SEC;
Esborra_Cadena(&aux);
Afegir_Float (&aux, temps_per_bucle);
//mvwprintw(w[4],8,1,Retorna_Cad(&aux));
}
break;
}
}
else
{
exit(1); //login incorrecte --> sortim de l'aplicacio
}
Я не опубликовал весь код, только основную часть, где чтение + запись выполняются с ожиданиями и сигналами.
Может быть, япотерять то, что сейчас не вижу.Дело в том, что сын будет писать в 'pipe_fill', а родитель будет читать из этой трубы, также родитель будет писать в 'pipe_pare', а затем сын будет читать из нее для отправки информации.
Также я используюncurses, чтобы сделать все окна рисунка.
Спасибо за вашу помощь:)