Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
C
codes-dev
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Xin Wang
codes-dev
Commits
c9cdbeeb
Commit
c9cdbeeb
authored
Jul 07, 2017
by
Misbah Mubarak
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
adding example config files for background traffic, adding stats for background traffic in code
parent
7c1cfd90
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
13 additions
and
3 deletions
+13
-3
src/network-workloads/conf/allocation-synthetic.conf
src/network-workloads/conf/allocation-synthetic.conf
+2
-0
src/network-workloads/conf/workloads-synthetic.conf
src/network-workloads/conf/workloads-synthetic.conf
+2
-0
src/network-workloads/model-net-mpi-replay.c
src/network-workloads/model-net-mpi-replay.c
+9
-3
No files found.
src/network-workloads/conf/allocation-synthetic.conf
0 → 100644
View file @
c9cdbeeb
0
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
src/network-workloads/conf/workloads-synthetic.conf
0 → 100644
View file @
c9cdbeeb
216
synthetic
125
/
path
/
to
/
Multigrid
/
Multigrid_125
/
dumpi
-
2014
.
03
.
06
.
23
.
48
.
13
-
src/network-workloads/model-net-mpi-replay.c
View file @
c9cdbeeb
...
...
@@ -39,6 +39,7 @@ int enable_msg_tracking = 0;
int
is_synthetic
=
0
;
tw_lpid
TRACK_LP
=
-
1
;
static
double
total_syn_data
=
0
;
int
unmatched
=
0
;
char
workload_type
[
128
];
char
workload_file
[
8192
];
...
...
@@ -496,7 +497,7 @@ static void notify_neighbor(
&&
ns
->
is_finished
==
1
&&
ns
->
neighbor_completed
==
1
)
{
printf
(
"
\n
All workloads completed, notifying background traffic "
);
//
printf("\n All workloads completed, notifying background traffic ");
bf
->
c0
=
1
;
notify_background_traffic
(
ns
,
lp
,
bf
,
m
);
return
;
...
...
@@ -510,7 +511,7 @@ static void notify_neighbor(
{
bf
->
c1
=
1
;
printf
(
"
\n
Local rank %d notifying neighbor %d "
,
ns
->
local_rank
,
ns
->
local_rank
+
1
);
//
printf("\n Local rank %d notifying neighbor %d ", ns->local_rank, ns->local_rank+1);
tw_stime
ts
=
(
1
.
1
*
g_tw_lookahead
)
+
tw_rand_exponential
(
lp
->
rng
,
mean_interval
/
10000
);
nbr_jid
.
rank
=
ns
->
local_rank
+
1
;
...
...
@@ -1722,7 +1723,6 @@ void nw_test_init(nw_state* s, tw_lp* lp)
#endif
}
wrkld_id
=
codes_workload_load
(
"dumpi-trace-workload"
,
params
,
s
->
app_id
,
s
->
local_rank
);
double
overhead
;
int
rc
=
configuration_get_value_double
(
&
config
,
"PARAMS"
,
"self_msg_overhead"
,
NULL
,
&
overhead
);
...
...
@@ -2127,6 +2127,8 @@ static void get_next_mpi_operation(nw_state* s, tw_bf * bf, nw_message * m, tw_l
void
nw_test_finalize
(
nw_state
*
s
,
tw_lp
*
lp
)
{
total_syn_data
+=
s
->
syn_data
;
int
written
=
0
;
if
(
!
s
->
nw_id
)
written
=
sprintf
(
s
->
output_buf
,
"# Format <LP ID> <Terminal ID> <Total sends> <Total Recvs> <Bytes sent> <Bytes recvd> <Send time> <Comm. time> <Compute time> <Job ID>"
);
...
...
@@ -2556,6 +2558,7 @@ int modelnet_mpi_replay(MPI_Comm comm, int* argc, char*** argv )
double
total_avg_send_time
,
total_max_send_time
;
double
total_avg_wait_time
,
total_max_wait_time
;
double
total_avg_recv_time
,
total_max_recv_time
;
double
g_total_syn_data
;
MPI_Reduce
(
&
num_bytes_sent
,
&
total_bytes_sent
,
1
,
MPI_LONG_LONG
,
MPI_SUM
,
0
,
MPI_COMM_CODES
);
MPI_Reduce
(
&
num_bytes_recvd
,
&
total_bytes_recvd
,
1
,
MPI_LONG_LONG
,
MPI_SUM
,
0
,
MPI_COMM_CODES
);
...
...
@@ -2570,6 +2573,7 @@ int modelnet_mpi_replay(MPI_Comm comm, int* argc, char*** argv )
MPI_Reduce
(
&
max_recv_time
,
&
total_max_recv_time
,
1
,
MPI_DOUBLE
,
MPI_MAX
,
0
,
MPI_COMM_CODES
);
MPI_Reduce
(
&
avg_wait_time
,
&
total_avg_wait_time
,
1
,
MPI_DOUBLE
,
MPI_SUM
,
0
,
MPI_COMM_CODES
);
MPI_Reduce
(
&
avg_send_time
,
&
total_avg_send_time
,
1
,
MPI_DOUBLE
,
MPI_SUM
,
0
,
MPI_COMM_CODES
);
MPI_Reduce
(
&
total_syn_data
,
&
g_total_syn_data
,
1
,
MPI_DOUBLE
,
MPI_SUM
,
0
,
MPI_COMM_WORLD
);
assert
(
num_net_traces
);
...
...
@@ -2586,6 +2590,8 @@ int modelnet_mpi_replay(MPI_Comm comm, int* argc, char*** argv )
int
ret
=
lp_io_flush
(
io_handle
,
MPI_COMM_CODES
);
assert
(
ret
==
0
||
!
"lp_io_flush failure"
);
}
printf
(
"
\n
Synthetic traffic stats: data received per proc %lf bytes
\n
"
,
g_total_syn_data
/
num_syn_clients
);
model_net_report_stats
(
net_id
);
if
(
unmatched
&&
g_tw_mynode
==
0
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment