- sg_cfg_get_string("smpi/scatter"));
- mpi_coll_scatter_fun = (int (*)(void *sendbuf, int sendcount, MPI_Datatype sendtype,\
- void *recvbuf, int recvcount, MPI_Datatype recvtype,\
- int root, MPI_Comm comm))
- mpi_coll_scatter_description[scatter_id].coll;
+ sg_cfg_get_string("smpi/scatter"));
+ mpi_coll_scatter_fun = (int (*)(void *sendbuf, int sendcount,
+ MPI_Datatype sendtype, void *recvbuf,
+ int recvcount, MPI_Datatype recvtype,
+ int root, MPI_Comm comm))
+ mpi_coll_scatter_description[scatter_id].coll;
+
+ int barrier_id = find_coll_description(mpi_coll_barrier_description,
+ sg_cfg_get_string("smpi/barrier"));
+ mpi_coll_barrier_fun = (int (*)(MPI_Comm comm))
+ mpi_coll_barrier_description[barrier_id].coll;
+
+ smpi_cpu_threshold = sg_cfg_get_double("smpi/cpu_threshold");
+ smpi_running_power = sg_cfg_get_double("smpi/running_power");
+ if (smpi_cpu_threshold < 0)
+ smpi_cpu_threshold = DBL_MAX;
+