ForkMaster/netgen
1
0
Fork 0
mirror of https://github.com/NGSolve/netgen.git synced 2025-01-28 05:40:34 +05:00
Code Issues Packages Projects Releases Wiki Activity

why was SubComm that complicated ?

Browse Source
This commit is contained in:
Joachim Schöberl 2019-02-08 17:15:02 +01:00
parent f661e4a30d
commit bab9d41b1b
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
libsrc/meshing/python_mesh.cpp
View File

@ -954,11 +954,21 @@ DLL_HEADER void ExportNetgenMeshing(py::module &m)
.def("Sum", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_SUM, c.comm); }) .def("Sum", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_SUM, c.comm); })
.def("Min", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_MIN, c.comm); }) .def("Min", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_MIN, c.comm); })
.def("Max", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_MAX, c.comm); }) .def("Max", [](PyMPI_Comm & c, size_t x) { return MyMPI_AllReduceNG(x, MPI_MAX, c.comm); })
.def("SubComm", [](PyMPI_Comm & c, py::list proc_list) -> shared_ptr<PyMPI_Comm> { .def("SubComm", [](PyMPI_Comm & c, py::list proc_list) {
Array<int> procs(py::len(proc_list));
for (int i = 0; i < procs.Size(); i++)
procs[i] = py::extract<int>(proc_list[i])();
if (!procs.Size())
return make_shared<PyMPI_Comm>(MPI_COMM_NULL);
MPI_Comm subcomm = MyMPI_SubCommunicator(c.comm, procs);
return make_shared<PyMPI_Comm>(subcomm, true);
/*
Array<int> procs; Array<int> procs;
if (py::extract<py::list> (proc_list).check()) { if (py::extract<py::list> (proc_list).check()) {
py::list pylist = py::extract<py::list> (proc_list)(); py::list pylist = py::extract<py::list> (proc_list)();
procs.SetSize(py::len(pylist)); procs.SetSize(py::len(pyplist));
for (int i = 0; i < py::len(pylist); i++) for (int i = 0; i < py::len(pylist); i++)
procs[i] = py::extract<int>(pylist[i])(); procs[i] = py::extract<int>(pylist[i])();
} }
@ -974,6 +984,7 @@ DLL_HEADER void ExportNetgenMeshing(py::module &m)
} }
MPI_Comm subcomm = MyMPI_SubCommunicator(c.comm, procs); MPI_Comm subcomm = MyMPI_SubCommunicator(c.comm, procs);
return make_shared<PyMPI_Comm>(subcomm, true); return make_shared<PyMPI_Comm>(subcomm, true);
*/
}, py::arg("procs")); }, py::arg("procs"));
; ;