/*
Пример "раздваивание-присоединение"
Демонстрируется, как порождать процессы и обмениваться сообщениями
*/
/* определения и прототипы библиотеки ПВМ */
#include <pvm3.h>
/* максимальное число потомков, которые будут
порождаться этой программой */
#define MAXNCHILD 20
/* тег для использования в сообщениях, связанных с присоединением */
#define JOINTAG 11
int main(int argc, char* argv[])
{
/* количество задач для порождения, 3 используются по умолчанию */
int ntask = 3;
/* код возврата для вызовов ПВМ */
int info;
/* свой идентификатор задачи */
int mytid;
/* свой идентификатор задачи-предка*/
int myparent;
/* массив идентификаторов задач-потомков*/
int child[MAXNCHILD];
int i, mydata, buf, len, tag, tid;
/* поиск своего идентификатора задачи */
mytid = pvm_mytid();
/* проверка на ошибки*/
if (mytid < 0) {
/* вывод на экран сообщения об ошибке*/
pvm_perror(argv[0]);
/* выход из программы */
return -1;
}
/* нахождение числа-идентификатора задачи-предка */
myparent = pvm_parent();
/* выход, если есть ошибки, но не PvmNoParent */
if ((myparent < 0 ) && (myparent != PvmNoParent() {
pvm_perror(argv[0]);
pvm_exit();
return -1;
}
/* если предка не найдено, то это и есть предок */
if (myparent == PvmNoParent) {
/* определение числа задач для порождения */
if (argc == 2) ntask = atoi(argv[1]);
/* удостоверение, что ntask - допустимо */
if ((ntask < 1) || (ntask > MAXNCHILD)) {pvm_exit(); return 0;}
/* порождение задач-потомков*/
info = pvm_spawn(argv[0], (char**)0, PvmTaskDefault,
(char*)0, ntask, child);
/* вывод на экран идентификаторов задач */
for (i = 0; i < ntask; i++)
if (child[i] < 0) /* вывод на экран десятичного кода ошибки*/
printf(" %d", child[i]);
else /* вывод на экран шестнадцатиричного идентификатора
задачи */
printf("t%x\t", child[i]);
putchar('\n');
/* удостоверение, что порождение произошло успешно */
if (info == 0) {pvm_exit(); return -1;}
/* ожидание ответов только от тех потомков, которые порождены
успешно */
ntask = info;
for (i = 0; i < ntask; i++) {
/* прием сообщения от любого процесса-потомка */
buf = pvm_recv(-1, JOINTAG);
if (buf < 0) pvm_perror("calling recv");
info = pvm_bufinfo(buf, &len, &tag, &tid);
if (info < 0) pvm_perror("calling pvm_bufinfo");
info = pvm_upkint(&mydata, 1, 1);
if (info < 0) pvm_perror("calling pvm_upkint");
if (mydata != tid) printf("Этого не может быть!\n");
printf("Длина %d, Tag %d, Tid t%x\n", len, tag, tid);
}
pvm_exit();
return 0;
}
/* это потомок */
info = pvm_initsend(PvmDataDefault);
if (info < 0) {
pvm_perror("calling pvm_initsend"); pvm_exit(); return -1;
}
info = pvm_pkint(&mytid, 1, 1);
if (info < 0) {
pvm_perror("calling pvm_pkint"); pvm_exit(); return -1;
}
info = pvm_send(myparent, JOINTAG);
if (info < 0) {
pvm_perror("calling pvm_initsend"); pvm_exit(); return -1;
}
pvm_exit();
return 0;
}
% forkjoin
t10001c t40149 tc0037
Длина 4, Tag 11, Tid t40149
Длина 4, Tag 11, Tid tc0037
Длина 4, Tag 11, Tid t10001c
% forkjoin 4
t10001e t10001d t4014b tc0038
Длина 4, Tag 11, Tid t4014b
Длина 4, Tag 11, Tid tc0038
Длина 4, Tag 11, Tid t10001d
Длина 4, Tag 11, Tid t10001e
