From 294dbf1bf0532df536eda8023f11b0b552c62892 Mon Sep 17 00:00:00 2001 From: paboyle Date: Thu, 11 Feb 2016 23:45:51 +0000 Subject: [PATCH] Compile on OpenMPI shmem --- lib/communicator/Communicator_shmem.cc | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/lib/communicator/Communicator_shmem.cc b/lib/communicator/Communicator_shmem.cc index cbd088b7..62003932 100644 --- a/lib/communicator/Communicator_shmem.cc +++ b/lib/communicator/Communicator_shmem.cc @@ -41,7 +41,8 @@ CartesianCommunicator::CartesianCommunicator(const std::vector &processors) _processors = processors; _processor_coor.resize(_ndimension); - shmem_init_thread(SHMEM_THREAD_FUNNELED); + // shmem_init_thread(SHMEM_THREAD_FUNNELED); + start_pes(0); _processor = shmem_my_pe(); Lexicographic::CoorFromIndex(_processor_coor,_processor,_processors); @@ -170,11 +171,11 @@ void CartesianCommunicator::SendToRecvFromBegin(std::vector &lis int from, int bytes) { - shmem_putmem_nb(recv,xmit,bytes,dest,NULL); + shmem_putmem(recv,xmit,bytes,dest); } void CartesianCommunicator::SendToRecvFromComplete(std::vector &list) { - shmem_quiet(); // I'm done + // shmem_quiet(); // I'm done shmem_barrier_all();// He's done too } void CartesianCommunicator::Barrier(void)