| $input_694108 > 1016 | 1411 | | | | pvm_setopt(what, val) | | | 1412 | | | | int what; | | | 1413 | | | | int val; | | | 1414 | | | | { | | $input_694116 > 1016 | 1415 | | | | int rc = 0; | | $input_694124 > 1016 | 1416 | | | | int err = 0; | | | 1417 | | | | int sbf, rbf; | | | 1418 | | | | char buf[16]; | | $input_694132 > 1016 | 1419 | | | | TEV_DECLS
| | | 1420 | | | | | | $input_694140 > 1016 | 1421 | | | | if (TEV_EXCLUSIVE) {
| | | 1422 | | | | if (pvmmytid != -1 | | | 1423 | | | | && TEV_DO_TRACE(TEV_SETOPT,TEV_EVENT_ENTRY)) {
| | | 1424 | | | | TEV_PACK_INT( TEV_DID_OPT, TEV_DATA_SCALAR, &what, 1, 1 );
| | | 1425 | | | | TEV_PACK_INT( TEV_DID_OPV, TEV_DATA_SCALAR, &val, 1, 1 );
| | | 1426 | | | | TEV_FIN;
| | | 1427 | | | | } | | | 1428 | | | | } | | | 1429 | | | | | | $input_694156 > 1016 | 1430 | | | | switch (what) { | | | 1431 | | | | case PvmRoute:
| | | 1432 | | | | switch (val) { | | | 1433 | | | | case PvmDontRoute:
| | | 1434 | | | | case PvmAllowDirect:
| | | 1435 | | | | case PvmRouteDirect:
| | | 1436 | | | | rc = pvmrouteopt; | | | 1437 | | | | #if (!defined(IMA_PGON)) && (!defined(IMA_SP2MPI)) \ | | | 1438 | | | | && (!defined(IMA_AIX4SP2)) && (!defined(IMA_AIX5SP2)) | | | 1439 | | | | pvmrouteopt = val; | | | 1440 | | | | #endif | | | | | | | ... | | | 1579 | | | | | | | 1580 | | | | } else { | | | 1581 | | | | rc = pvmfrgsiz; | | | 1582 | | | | pvmfrgsiz = val; | | | 1583 | | | | } | | | 1584 | | | | | | | 1585 | | | | #endif | | | 1586 | | | | | | | 1587 | | | | break; | | | 1588 | | | | | | $input_694164 > 1016 | 1589 | | | | case PvmResvTids:
| | $input_694172 > 1016 | 1590 | | | | rc = pvmrescode; | | $input_694180 > 1016 | 1591 | | | | pvmrescode = val; | | $input_694188 > 1016 | 1592 | | | | break; | | | 1593 | | | | | | | 1594 | | | | case PvmSelfOutputTid:
| | | 1595 | | | | if (pvmtrc.outtid > 0 || val > 0) { | | | 1596 | | | | if (rc = BEATASK)
| | | 1597 | | | | err = 1; | | | 1598 | | | | else { | | | 1599 | | | | sbf = pvm_setsbuf(pvm_mkbuf(PvmDataFoo));
| | | 1600 | | | | rbf = pvm_setrbuf(0); | | | 1601 | | | | what = TS_OUTTID;
| | | 1602 | | | | pvm_pkint(&what, 1, 1); | | | | | | | ... | | | 1817 | | | | break; | | | 1818 | | | | | | | 1819 | | | | #endif | | | 1820 | | | | | | | 1821 | | | | default: | | | 1822 | | | | rc = PvmBadParam;
| | | 1823 | | | | err = 1; | | | 1824 | | | | break; | | | 1825 | | | | } | | | 1826 | | | | | | $input_694196 > 1016 | 1827 | | | | if (TEV_AMEXCL) {
| | | 1828 | | | | if (pvmmytid != -1 | | | 1829 | | | | && TEV_DO_TRACE(TEV_SETOPT,TEV_EVENT_EXIT)) {
| | | 1830 | | | | TEV_PACK_INT( TEV_DID_OPV, TEV_DATA_SCALAR, &rc, 1, 1 );
| | | 1831 | | | | TEV_FIN;
| | | 1832 | | | | } | | | 1833 | | | | TEV_ENDEXCL;
| | | 1834 | | | | } | | | 1835 | | | | | | $input_694204 > 1016 | 1836 | | | | if (err) | | | 1837 | | | | return lpvmerr("pvm_setopt", rc); | | $input_694212 > 1016 | 1838 | | | | return rc; | | $input_694228 > 1016 | 1839 | | | | } |
| | 373 | | | | | 374 | | pvm_setopt(PvmRoute, PvmDontRoute);
| | | 375 | | | | | 376 | | pvm_setopt(PvmSelfTraceTid, -1);
| | | 377 | | pvm_setopt(PvmSelfOutputTid, -1);
| | | 378 | | | | | 379 | | i = pvm_setopt(PvmAutoErr, 0);
| | | 380 | | cc = pvm_start_pvmd(argc - 1, argv + 1, 1); | | | 381 | | if (cc < 0) { | | | 382 | | if (cc != PvmDupHost) {
| | | 383 | | pvm_perror("Console"); | | | 384 | | exit(1); | | | 385 | | } | | | 386 | | printf("pvmd already running.\n"); | | | 387 | | } | | | 388 | | pvm_setopt(PvmAutoErr, i);
| | | 389 | | | | | 390 | | if ((mytid = pvm_mytid()) < 0) | | | 391 | | exit(1); | | | 392 | | | | | 393 | | (void)signal(SIGINT, SIG_IGN);
| | | 394 | | | | | 395 | | | | | 396 | | #ifndef WIN32 | | | 397 | | pvm_setopt( PvmNoReset, 1 );
| | | 398 | | pvm_setopt( PvmTraceOptions, PvmTraceFull );
| | | 399 | | pvm_setopt( PvmTraceBuffer, 0 );
| | | 400 | | #endif | | | 401 | | job_init(); | | | 402 | | | | | 403 | | | | | 404 | | sprintf(cmd, "trace xpvm"); | | | 405 | | ac = sizeof(av)/sizeof(av[0]) - 1; | | | 406 | | if (!acav(cmd, &ac, av) && ac) | | | 407 | | trace_cmd(ac, av); | | | 408 | | | | | 409 | | pvm_notify(PvmHostAdd, HostsAddedTag, -1, (int*)0);
| | | 410 | | | | | 411 | | BZERO(&minfo, sizeof(minfo));
| | | 412 | | minfo.src = -1; | | | 413 | | minfo.ctx = -1; | | | 414 | | minfo.tag = MyExitTag;
| | | 415 | | | | | 416 | | #ifndef WIN32 | | | 417 | | pvm_addmhf(minfo.src, minfo.tag, minfo.ctx, exit_handler); | | $input_12 > 1016 | 418 | | pvm_notify(PvmTaskExit, MyExitTag, 1, &mytid);
| | | 419 | | #endif | | | 420 | | | | | 421 | | if (!(p = getenv("HOME"))) | | | 422 | | p = "."; | | strlen(p) > 1016 | 423 | | sprintf(cmd, "%s/.pvmrc", p); |
|