1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
* Copyright 1998-1999, University of Notre Dame.
* Authors: Brian W. Barrett, Arun F. Rodrigues, Jeffrey M. Squyres,
* and Andrew Lumsdaine
*
* This file is part of XMPI
*
* You should have received a copy of the License Agreement for XMPI
* along with the software; see the file LICENSE. If not, contact
* Office of Research, University of Notre Dame, Notre Dame, IN 46556.
*
* Permission to modify the code and to distribute modified code is
* granted, provided the text of this NOTICE is retained, a notice that
* the code was modified is included with the above COPYRIGHT NOTICE and
* with the COPYRIGHT NOTICE in the LICENSE file, and that the LICENSE
* file is distributed with the modified code.
*
* LICENSOR MAKES NO REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED.
* By way of example, but not limitation, Licensor MAKES NO
* REPRESENTATIONS OR WARRANTIES OF MERCHANTABILITY OR FITNESS FOR ANY
* PARTICULAR PURPOSE OR THAT THE USE OF THE LICENSED SOFTWARE COMPONENTS
* OR DOCUMENTATION WILL NOT INFRINGE ANY PATENTS, COPYRIGHTS, TRADEMARKS
* OR OTHER RIGHTS.
*
* Additional copyrights may follow.
*
* $Id: trdrain_mpi.c,v 1.3 1999/11/08 06:20:37 bbarrett Exp $
*
* Function: - unloads trace data for one MPI world
* Accepts: - trace file desc. opened for append
* - GPS array of world
* - GPS array length
* - get/forget flag
* - delay period in secs after flush signal
*/
#include <unistd.h>
#include <lam_ksignal.h>
#include <app_mgmt.h>
#include <mpitrace.h>
#include <preq.h>
#include <trreq.h>
#include <typical.h>
int
trdrain_mpi(fd, world, nworld, keep, flush_delay)
int fd;
struct _gps *world;
int nworld;
int keep;
int flush_delay;
{
int i;
int (*drain)();
drain = keep ? lam_rtrfget : lam_rtrfforget;
/*
* Signal everybody to flush in-process trace buffers to the daemon.
*/
if (flush_delay >= 0) {
for (i = 0; i < nworld; i++) {
rpdoom(world[i].gps_node, SELECT_PID,
world[i].gps_pid, LAM_SIGTRACE);
}
if (flush_delay > 0) {
sleep((unsigned) flush_delay);
}
}
/*
* Drain the init/on/off traces.
*/
for (i = 0; i < nworld; i++) {
if ((*drain)(world[i].gps_node, TRONOFF, world[i].gps_pid,
fd) < 0) return(LAMERROR);
}
/*
* Drain the communicator traces.
*/
for (i = 0; i < nworld; i++) {
if ((*drain)(world[i].gps_node, TRCOMM, world[i].gps_pid,
fd) < 0) return(LAMERROR);
}
/*
* Drain the datatype traces.
*/
for (i = 0; i < nworld; i++) {
if ((*drain)(world[i].gps_node, TRDTYPE, world[i].gps_pid,
fd) < 0) return(LAMERROR);
}
/*
* Drain the runtime traces.
*/
for (i = 0; i < nworld; i++) {
if ((*drain)(world[i].gps_node, TRRUNTIME, world[i].gps_pid,
fd) < 0) return(LAMERROR);
}
return(0);
}
|
