fix some more leaks

smpi_datatype_free does not update refcount, use unuse instead.

diff --git a/src/smpi/colls/allgatherv-ompi-bruck.c b/src/smpi/colls/allgatherv-ompi-bruck.c
index dc5d2fb..c9491fa 100644 (file)
--- a/src/smpi/colls/allgatherv-ompi-bruck.c
+++ b/src/smpi/colls/allgatherv-ompi-bruck.c
@@ -162,8 +162,8 @@ int smpi_coll_tuned_allgatherv_ompi_bruck(void *sbuf, int scount,
                                      rbuf, 1, new_rdtype, recvfrom,
                                      COLL_TAG_ALLGATHERV,
                                      comm, MPI_STATUS_IGNORE);
                                      rbuf, 1, new_rdtype, recvfrom,
                                      COLL_TAG_ALLGATHERV,
                                      comm, MPI_STATUS_IGNORE);

-      smpi_datatype_free(&new_sdtype);
-      smpi_datatype_free(&new_rdtype);
+      smpi_datatype_unuse(new_sdtype);
+      smpi_datatype_unuse(new_rdtype);

 
    }
 
 
    }
 

diff --git a/src/smpi/colls/allgatherv-ompi-neighborexchange.c b/src/smpi/colls/allgatherv-ompi-neighborexchange.c
index f6fc137..edf93c3 100644 (file)
--- a/src/smpi/colls/allgatherv-ompi-neighborexchange.c
+++ b/src/smpi/colls/allgatherv-ompi-neighborexchange.c
@@ -205,8 +205,8 @@ smpi_coll_tuned_allgatherv_ompi_neighborexchange(void *sbuf, int scount,
 
         send_data_from = recv_data_from[i_parity];
       
 
         send_data_from = recv_data_from[i_parity];
       

-        smpi_datatype_free(&new_sdtype);
-        smpi_datatype_free(&new_rdtype);
+        smpi_datatype_unuse(new_sdtype);
+        smpi_datatype_unuse(new_rdtype);

     }
 
     return MPI_SUCCESS;
     }
 
     return MPI_SUCCESS;

diff --git a/src/smpi/colls/alltoall-bruck.c b/src/smpi/colls/alltoall-bruck.c
index 99a93b5..10b4d9c 100644 (file)
--- a/src/smpi/colls/alltoall-bruck.c
+++ b/src/smpi/colls/alltoall-bruck.c
@@ -86,7 +86,7 @@ smpi_coll_tuned_alltoall_bruck(void *send_buff, int send_count,
 
     smpi_mpi_sendrecv(tmp_buff, position, MPI_PACKED, dst, tag, recv_buff, 1,
                  new_type, src, tag, comm, &status);
 
     smpi_mpi_sendrecv(tmp_buff, position, MPI_PACKED, dst, tag, recv_buff, 1,
                  new_type, src, tag, comm, &status);

-    smpi_datatype_free(&new_type);
+    smpi_datatype_unuse(new_type);

 
     pof2 *= 2;
   }
 
     pof2 *= 2;
   }