From 718c35f5cfc72c1a1c07f2cd2c340087fa329fc1 Mon Sep 17 00:00:00 2001 From: jean-noel quintin Date: Thu, 4 Oct 2012 16:07:23 +0100 Subject: [PATCH] [smpi] remove a memory leak linked to the detached communication --- src/smpi/smpi_global.c | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/src/smpi/smpi_global.c b/src/smpi/smpi_global.c index c864c5c6fe..a4278264ff 100644 --- a/src/smpi/smpi_global.c +++ b/src/smpi/smpi_global.c @@ -213,13 +213,25 @@ void print_request(const char *message, MPI_Request request) { request->src, request->dst, request->tag, request->flags); } +void SMPI_comm_copy_buffer_callback(smx_action_t comm, void* buff, size_t buff_size) +{ + XBT_DEBUG("Copy the data over"); + memcpy(comm->comm.dst_buff, buff, buff_size); + if (comm->comm.detached) { // if this is a detached send, the source buffer was duplicated by SMPI sender to make the original buffer available to the application ASAP + xbt_free(buff); + xbt_free(comm->comm.src_data);// inside SMPI the request is keep + //inside the user data and should be free + comm->comm.src_buff = NULL; + } +} + void smpi_global_init(void) { int i; MPI_Group group; char name[MAILBOX_NAME_MAXLEN]; - SIMIX_comm_set_copy_data_callback(&SIMIX_comm_copy_buffer_callback); + SIMIX_comm_set_copy_data_callback(&SMPI_comm_copy_buffer_callback); process_count = SIMIX_process_count(); process_data = xbt_new(smpi_process_data_t, process_count); for (i = 0; i < process_count; i++) { -- 2.20.1