@@ -3,6 +3,13 @@ module ParallelUtilities
3
3
using Reexport
4
4
@reexport using Distributed
5
5
6
+ export split_across_processors,split_product_across_processors,
7
+ get_processor_id_from_split_array,procid_allmodes,mode_index_in_file,
8
+ get_processor_range_from_split_array,workers_active,nworkers_active,worker_rank,
9
+ get_index_in_split_array,procid_and_mode_index,extrema_from_split_array,
10
+ pmapsum,sum_at_node,pmap_onebatch_per_worker,moderanges_common_lastarray,
11
+ get_nodes,get_hostnames,get_nprocs_node
12
+
6
13
function worker_rank ()
7
14
if nworkers ()== 1
8
15
return 1
@@ -274,14 +281,4 @@ function sum_at_node(futures::Vector{Future},hostnames)
274
281
sum (fetch (f) for f in futures_on_myhost)
275
282
end
276
283
277
- # ############################################################################
278
-
279
- export split_across_processors,split_product_across_processors,
280
- get_processor_id_from_split_array,
281
- procid_allmodes,mode_index_in_file,
282
- get_processor_range_from_split_array,workers_active,worker_rank,
283
- get_index_in_split_array,procid_and_mode_index,extrema_from_split_array,
284
- pmapsum,sum_at_node,pmap_onebatch_per_worker,moderanges_common_lastarray,
285
- get_nodes,get_hostnames,get_nprocs_node
286
-
287
284
end # module
0 commit comments