(text, values)
| 33 | size = c.GetNumberOfProcesses() |
| 34 | |
| 35 | def PRINT(text, values): |
| 36 | if values is dsa.NoneArray: |
| 37 | values = numpy.array(0, dtype=numpy.float64) |
| 38 | else: |
| 39 | values = numpy.array(numpy.sum(values)).astype(numpy.float64) |
| 40 | res = numpy.array(values) |
| 41 | MPI.COMM_WORLD.Allreduce([values, MPI.DOUBLE], [res, MPI.DOUBLE], MPI.SUM) |
| 42 | assert numpy.abs(res) < 1E-5 |
| 43 | if rank == 0: |
| 44 | print(text, res) |
| 45 | |
| 46 | def testArrays(rtData, rtData2, grad, grad2, total_npts): |
| 47 | " Test various parallel algorithms." |
no test coverage detected