diff --git a/d2o/distributor_factory.py b/d2o/distributor_factory.py index 38e4ba423eb7274d0bc75cd863c2763f8f6143f0..9d8b3b81bc206e246b8b056ad2db28a9f90bdafc 100644 --- a/d2o/distributor_factory.py +++ b/d2o/distributor_factory.py @@ -1718,16 +1718,16 @@ class _slicing_distributor(distributor): local_searched = np.searchsorted(a=a, v=v, side=side) global_searched = np.empty_like(local_searched) - if side is 'left': - op = MPI.MAX - elif side is 'right': - op = MPI.MIN - else: - raise ValueError +# if side is 'left': +# op = MPI.MAX +# elif side is 'right': +# op = MPI.MIN +# else: +# raise ValueError self.comm.Allreduce([local_searched, MPI.INT], [global_searched, MPI.INT], - op=op) + op=MPI.SUM) if global_searched.shape == (): global_searched = global_searched[()] return global_searched