portelli/Grid
1
0
Fork 0
mirror of https://github.com/paboyle/Grid.git synced 2025-04-10 22:20:45 +01:00
Code Releases Activity

Compile on OpenMPI shmem

Browse Source
This commit is contained in:
paboyle 2016-02-11 23:45:51 +00:00
parent 9548c8b91f
commit 294dbf1bf0
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/communicator/Communicator_shmem.cc
View File

@ -41,7 +41,8 @@ CartesianCommunicator::CartesianCommunicator(const std::vector<int> &processors)
_processors = processors; _processors = processors;
_processor_coor.resize(_ndimension); _processor_coor.resize(_ndimension);
shmem_init_thread(SHMEM_THREAD_FUNNELED); // shmem_init_thread(SHMEM_THREAD_FUNNELED);
start_pes(0);
_processor = shmem_my_pe(); _processor = shmem_my_pe();
Lexicographic::CoorFromIndex(_processor_coor,_processor,_processors); Lexicographic::CoorFromIndex(_processor_coor,_processor,_processors);
@ -170,11 +171,11 @@ void CartesianCommunicator::SendToRecvFromBegin(std::vector<CommsRequest_t> &lis
int from, int from,
int bytes) int bytes)
{ {
shmem_putmem_nb(recv,xmit,bytes,dest,NULL); shmem_putmem(recv,xmit,bytes,dest);
} }
void CartesianCommunicator::SendToRecvFromComplete(std::vector<CommsRequest_t> &list) void CartesianCommunicator::SendToRecvFromComplete(std::vector<CommsRequest_t> &list)
{ {
shmem_quiet(); // I'm done // shmem_quiet(); // I'm done
shmem_barrier_all();// He's done too shmem_barrier_all();// He's done too
} }
void CartesianCommunicator::Barrier(void) void CartesianCommunicator::Barrier(void)