QNX/UNIX: Анатомия параллелизма
Шрифт:
struct inheritance Inhproc;
setlocale(LC_CTYPE, "C-TRADITIONAL");
if ((PChanid = ChannelCreate(0)) == -1)
printf("Родитель: странно, но не удалось "
"создать канал\n");
else printf("Родитель: канал PChanid = %i создан\n", PChanid);
strcpy(BufName, "Bed-Test");
// Передаем порожденному процессу свой pid...
args[1] = itoa(procid = getpid, Bufpid, 10);
// ...
и дескриптор канала
args[2] = itoa(PChanid, Bufchanid, 10);
InhProc flags = SPAWN_SETND | SPAWN_NOZOMBIE;
if ((nid = netmgr_strtond(BufName, NULL)) == -1) {
printf("Родитель, отсутствует %s\n", BufName);
return(-1);
} else printf("Родитель: найден узел %s, его nid = %i\n", BufName, nid);
InhProc nd = nid;
sprintf(BufName, "/net/Bed-Test/");
chroot(BufName);
errno = 0;
childid = spawn(args[0], 0, NULL, &InhProc, args, NULL);
ErrCode = errno;
sprintf(BufName, "/net/904-3/");
chroot(BufName);
if (childid- = -1)
printf("Родитель: не удалось породить процесс,"
" errno = %i\n", ErrCode);
else
printf("Родитель, мой id = %i,"
"порожденный процесс имеет id = %i\n", procid, childid);
if ((rcvid = MsgReceive(PChanid, RecBuffer, 100, NULL)) == -1)
printf("Родитель: от дитятки не удалось"
" получить сообщение\n");
else {
printf("Родитель: от дитятки получено"
" сообщение:\"%s\"\n", RecBuffer);
CChanid = atoi(RecBuffer);
strcpy(RecBuffer, "спасибо, сынок");
if (MsgReply(rcvid, EOK, RecBuffer, 100) == -1)
printf("Родитель: почему-то не удалось "
"ответить сыночку: Ау, где ты?\n");
}
if ((coid =
ConnectAttach(nid, childid, CChanid, _NTO_SIDE_CHANNEL, 0)) == -1) {
printf("Родитель: странно, но не смог установить"
" канал связи с ребенком:"
"nid = %i childid = %i CChanid = %i\n", nid, childid, CChanid);
return(-1);
}
printf("Родитель:
установил связь coid = %i с"
" ребенком\n", coid);
errno = 0;
if (MsgSend(coid, SendBuf, 100, SendBuf, 100) == -1)
printf("Родитель: на MsgSend получил errno = %i\n", errno);
else
printf("Родитель, получен отклик на MsgSend"
", \"%s\"\n", SendBuf);
printf("Родитель: позвольте откланяться\n");
ChannelDestroy(Pchanid);
ConnectDetach(CChanid);
return(0);
}
Пример кода порожденного процесса
#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <string.h>
#include <process.h>
#include <sys/netmgr.h>
#include <sys/neutrino.h>
#include <errno.h>
#include <locale.h>
int main(int argc, char **argv) {
int nid; // Дескриптор текущего узла
int CChanid; // Идентификатор созданного канала
int coid; // Идентификатор связи с родителем
// по созданному им каналу
pid_t Parpid; // Идентификатор родительского процесса
int rcvid; // Идентификатор отправителя
// полученного сообщения
char BufName[100];
char SendBuf[100], RecBuf[100];
setlocale(LC_CTYPE, "C-TRADITIONAL");
if ((CChanid = ChannelCreate(0)) == -1)
printf("Ребенок: странно, но не удалось создать"
" канал\n");
else
printf("Ребенок: канал CChanid = %i создан\n", CChanid);
Parpid = atoi(argv[1]);
printf("Ребенок сообщает: он жив благодаря папане"
" Parpid = %i\n", Parpid);
strcpy(BufName, "904-3");
if ((nid = netmgr_strtond(BufName, NULL)) == -1)
Поделиться с друзьями: