| true | 654 | | checkmsgs() | | | 655 | | { | | | 656 | | int cc; | | | 657 | | int len, cod, src; | | | 658 | | int n; | | | 659 | | struct job *jp; | | | 660 | | int *dtids; | | | 661 | | int i, j; | | | 662 | | int more, tmp; | | | 663 | | struct job *jpnext; | | | 664 | | | | | 665 | | | | | 666 | | | | | 667 | | | | | 668 | | | | | 669 | | | | | 670 | | while ((cc = pvm_nrecv(-1, HostsAddedTag)) > 0) {
| | | 671 | | pvm_upkint(&n, 1, 1); | | | 672 | | dtids = TALLOC(n, int, "");
| | | 673 | | pvm_upkint(dtids, n, 1); | | | 674 | | printf("\nConsole: %d new host%s added\n", n, (n == 1 ? "" : "s")); | | | 675 | | pvm_freebuf(cc); | | | 676 | | if (!pvm_config(&nhosts, &narchs, &hostlist)) { | | | 677 | | fputs(" HOST DTID ARCH SPEED\n", | | | 678 | | stdout); | | | 679 | | for (j = n; j-- > 0; ) | | | 680 | | for (i = nhosts; i-- > 0; ) { | | | 681 | | if (dtids[j] == hostlist[i].hi_tid) { | | | 682 | | printf("%24s %8x %8s%8d\n", | | | 683 | | hostlist[i].hi_name, | | | 684 | | hostlist[i].hi_tid, | | | 685 | | hostlist[i].hi_arch, | | | 686 | | hostlist[i].hi_speed); | | | 687 | | break; | | | 688 | | } | | | 689 | | } | | | 690 | | } | | | 691 | | MY_FREE(dtids);
| | | 692 | | } | | | 693 | | | | | 694 | | | | | 695 | | | | | 696 | | jp = joblist->j_link; | | | 697 | | | | | 698 | | more = 0; | | | 699 | | | | | 700 | | while (jp != joblist) { | | | 701 | | | | | 702 | | jpnext = jp->j_link; | | | 703 | | | | | 704 | | | | | 705 | | if (jp->j_flag & JOB_TRACE) {
|
|