diff --git a/unidist/core/backends/mpi/core/communication.py b/unidist/core/backends/mpi/core/communication.py index bbc51bb1..8dfd6134 100755 --- a/unidist/core/backends/mpi/core/communication.py +++ b/unidist/core/backends/mpi/core/communication.py @@ -31,6 +31,7 @@ # Logger configuration logger = common.get_logger("communication", "communication.log") +logger1 = common.get_logger("communication1", "communication1.log") is_logger_header_printed = False @@ -463,9 +464,19 @@ def mpi_send_buffer(comm, buffer, dest_rank, data_type=MPI.CHAR, buffer_size=Non """ if buffer_size: comm.send(buffer_size, dest=dest_rank, tag=common.MPITag.OBJECT) - comm.Send([buffer, data_type], dest=dest_rank, tag=common.MPITag.BUFFER) - - + else: + buffer_size = len(buffer) + PARTITION_SIZE = 100000 + partitions=list(range(0, buffer_size,PARTITION_SIZE)) + partitions.append(buffer_size) + #with pkl5._bigmpi() as bigmpi: + if True: + for i,_ in enumerate(partitions): + if i+1