X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f86ca5afc802e2e09db99c517ef30f507fdebc58..ea2e2f84bb9c4d52951666f7f7136213483523a2:/src/smpi/smpi_global.cpp diff --git a/src/smpi/smpi_global.cpp b/src/smpi/smpi_global.cpp index bcc611cae3..34065aacaf 100644 --- a/src/smpi/smpi_global.cpp +++ b/src/smpi/smpi_global.cpp @@ -1,5 +1,4 @@ -/* Copyright (c) 2007-2015. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -9,14 +8,13 @@ #include "private.hpp" #include "simgrid/s4u/Mailbox.hpp" #include "simgrid/sg_config.h" -#include "smpi_mpi_dt_private.h" #include "src/kernel/activity/SynchroComm.hpp" #include "src/mc/mc_record.h" #include "src/mc/mc_replay.h" #include "src/msg/msg_private.h" #include "src/simix/smx_private.h" #include "surf/surf.h" -#include "xbt/replay.h" +#include "xbt/replay.hpp" #include /* DBL_MAX */ #include @@ -75,7 +73,6 @@ int process_count = 0; int smpi_universe_size = 0; int* index_to_process_data = nullptr; extern double smpi_total_benched_time; -extern xbt_dict_t smpi_type_keyvals; extern xbt_dict_t smpi_comm_keyvals; xbt_os_timer_t global_timer; MPI_Comm MPI_COMM_WORLD = MPI_COMM_UNINITIALIZED; @@ -215,7 +212,8 @@ bool smpi_process_get_replaying(){ int index = smpi_process_index(); if (index != MPI_UNDEFINED) return process_data[index_to_process_data[index]]->replaying; - else return (_xbt_replay_is_active() != 0); + else + return !simgrid::xbt::replay_is_active(); } int smpi_global_size() @@ -352,9 +350,9 @@ MPI_Comm smpi_process_comm_self() { smpi_process_data_t data = smpi_process_data(); if(data->comm_self==MPI_COMM_NULL){ - MPI_Group group = smpi_group_new(1); - data->comm_self = smpi_comm_new(group, nullptr); - smpi_group_set_mapping(group, smpi_process_index(), 0); + MPI_Group group = new Group(1); + data->comm_self = new Comm(group, nullptr); + group->set_mapping(smpi_process_index(), 0); } return data->comm_self; @@ -384,12 +382,6 @@ int smpi_process_get_sampling() return data->sampling; } -void print_request(const char *message, MPI_Request request) -{ - XBT_VERB("%s request %p [buf = %p, size = %zu, src = %d, dst = %d, tag = %d, flags = %x]", - message, request, request->buf, request->size, request->src, request->dst, request->tag, request->flags); -} - void smpi_comm_set_copy_data_callback(void (*callback) (smx_activity_t, void*, size_t)) { smpi_comm_copy_data_callback = callback; @@ -604,13 +596,13 @@ void smpi_global_init() //if the process was launched through smpirun script we generate a global mpi_comm_world //if not, we let MPI_COMM_NULL, and the comm world will be private to each mpi instance if(smpirun){ - group = smpi_group_new(process_count); - MPI_COMM_WORLD = smpi_comm_new(group, nullptr); + group = new Group(process_count); + MPI_COMM_WORLD = new Comm(group, nullptr); MPI_Attr_put(MPI_COMM_WORLD, MPI_UNIVERSE_SIZE, reinterpret_cast(process_count)); msg_bar_t bar = MSG_barrier_init(process_count); for (i = 0; i < process_count; i++) { - smpi_group_set_mapping(group, i, i); + group->set_mapping(i, i); process_data[i]->finalization_barrier = bar; } } @@ -622,17 +614,17 @@ void smpi_global_destroy() smpi_bench_destroy(); if (MPI_COMM_WORLD != MPI_COMM_UNINITIALIZED){ - while (smpi_group_unuse(smpi_comm_group(MPI_COMM_WORLD)) > 0); + delete MPI_COMM_WORLD->group(); MSG_barrier_destroy(process_data[0]->finalization_barrier); }else{ smpi_deployment_cleanup_instances(); } for (int i = 0; i < count; i++) { if(process_data[i]->comm_self!=MPI_COMM_NULL){ - smpi_comm_destroy(process_data[i]->comm_self); + Comm::destroy(process_data[i]->comm_self); } if(process_data[i]->comm_intra!=MPI_COMM_NULL){ - smpi_comm_destroy(process_data[i]->comm_intra); + Comm::destroy(process_data[i]->comm_intra); } xbt_os_timer_free(process_data[i]->timer); xbt_mutex_destroy(process_data[i]->mailboxes_mutex); @@ -642,11 +634,11 @@ void smpi_global_destroy() process_data = nullptr; if (MPI_COMM_WORLD != MPI_COMM_UNINITIALIZED){ - smpi_comm_cleanup_smp(MPI_COMM_WORLD); - smpi_comm_cleanup_attributes(MPI_COMM_WORLD); + MPI_COMM_WORLD->cleanup_smp(); + MPI_COMM_WORLD->cleanup_attributes(); if(smpi_coll_cleanup_callback!=nullptr) smpi_coll_cleanup_callback(); - xbt_free(MPI_COMM_WORLD); + delete MPI_COMM_WORLD; } MPI_COMM_WORLD = MPI_COMM_NULL; @@ -656,8 +648,6 @@ void smpi_global_destroy() } xbt_free(index_to_process_data); - if(smpi_type_keyvals!=nullptr) - xbt_dict_free(&smpi_type_keyvals); if(smpi_comm_keyvals!=nullptr) xbt_dict_free(&smpi_comm_keyvals); if(smpi_privatize_global_variables) @@ -665,6 +655,8 @@ void smpi_global_destroy() smpi_free_static(); } +extern "C" { + #ifndef WIN32 void __attribute__ ((weak)) user_main_() @@ -695,7 +687,6 @@ int __attribute__ ((weak)) main(int argc, char **argv) #endif -extern "C" { static void smpi_init_logs(){ /* Connect log categories. See xbt/log.c */ @@ -708,14 +699,18 @@ static void smpi_init_logs(){ XBT_LOG_CONNECT(smpi_coll); XBT_LOG_CONNECT(smpi_colls); XBT_LOG_CONNECT(smpi_comm); + XBT_LOG_CONNECT(smpi_datatype); XBT_LOG_CONNECT(smpi_dvfs); XBT_LOG_CONNECT(smpi_group); XBT_LOG_CONNECT(smpi_kernel); XBT_LOG_CONNECT(smpi_mpi); - XBT_LOG_CONNECT(smpi_mpi_dt); + XBT_LOG_CONNECT(smpi_memory); + XBT_LOG_CONNECT(smpi_op); XBT_LOG_CONNECT(smpi_pmpi); + XBT_LOG_CONNECT(smpi_request); XBT_LOG_CONNECT(smpi_replay); XBT_LOG_CONNECT(smpi_rma); + XBT_LOG_CONNECT(smpi_utils); } }