1515 Transformer , ElementalCall , CommCallable )
1616from devito .mpi import MPI
1717from devito .symbolics import (Byref , CondNe , FieldFromPointer , FieldFromComposite ,
18- IndexedPointer , Macro , cast_mapper , subs_op_args )
18+ IndexedPointer , Macro , cast , subs_op_args )
1919from devito .tools import (as_mapper , dtype_to_mpitype , dtype_len , infer_datasize ,
2020 flatten , generator , is_integer , split )
2121from devito .types import (Array , Bag , Dimension , Eq , Symbol , LocalObject ,
@@ -306,7 +306,7 @@ def _make_bundles(self, hs):
306306 except ValueError :
307307 for i in candidates :
308308 name = "bag_%s" % i .name
309- bag = Bag (name = name , components = ( i ,) )
309+ bag = Bag (name = name , components = i )
310310 halo_scheme = halo_scheme .add (bag , hse )
311311
312312 hs = hs ._rebuild (halo_scheme = halo_scheme )
@@ -605,7 +605,7 @@ def _make_msg(self, f, hse, key):
605605 return MPIMsg ('msg%d' % key , f , halos )
606606
607607 def _make_sendrecv (self , f , hse , key , msg = None ):
608- cast = cast_mapper (( f .c0 .dtype , '*' ) )
608+ fcast = cast ( f .c0 .dtype , '*' )
609609 comm = f .grid .distributor ._obj_comm
610610
611611 bufg = FieldFromPointer (msg ._C_field_bufg , msg )
@@ -619,7 +619,7 @@ def _make_sendrecv(self, f, hse, key, msg=None):
619619 sizes = [FieldFromPointer ('%s[%d]' % (msg ._C_field_sizes , i ), msg )
620620 for i in range (len (f ._dist_dimensions ))]
621621
622- arguments = [cast (bufg )] + sizes + list (f .handles ) + ofsg
622+ arguments = [fcast (bufg )] + sizes + list (f .handles ) + ofsg
623623 gather = Gather ('gather%s' % key , arguments )
624624 # The `gather` is unnecessary if sending to MPI.PROC_NULL
625625 gather = Conditional (CondNe (torank , Macro ('MPI_PROC_NULL' )), gather )
@@ -671,7 +671,7 @@ def _call_compute(self, hs, compute, *args):
671671 return compute .make_call (dynamic_args_mapper = hs .omapper .core )
672672
673673 def _make_wait (self , f , hse , key , msg = None ):
674- cast = cast_mapper (( f .c0 .dtype , '*' ) )
674+ fcast = cast ( f .c0 .dtype , '*' )
675675
676676 bufs = FieldFromPointer (msg ._C_field_bufs , msg )
677677
@@ -681,7 +681,7 @@ def _make_wait(self, f, hse, key, msg=None):
681681
682682 sizes = [FieldFromPointer ('%s[%d]' % (msg ._C_field_sizes , i ), msg )
683683 for i in range (len (f ._dist_dimensions ))]
684- arguments = [cast (bufs )] + sizes + list (f .handles ) + ofss
684+ arguments = [fcast (bufs )] + sizes + list (f .handles ) + ofss
685685 scatter = Scatter ('scatter%s' % key , arguments )
686686
687687 # The `scatter` must be guarded as we must not alter the halo values along
@@ -772,7 +772,7 @@ def _call_sendrecv(self, *args):
772772 return
773773
774774 def _make_haloupdate (self , f , hse , key , * args , msg = None ):
775- cast = cast_mapper (( f .c0 .dtype , '*' ) )
775+ fcast = cast ( f .c0 .dtype , '*' )
776776 comm = f .grid .distributor ._obj_comm
777777
778778 fixed = {d : Symbol (name = "o%s" % d .root ) for d in hse .loc_indices }
@@ -794,7 +794,7 @@ def _make_haloupdate(self, f, hse, key, *args, msg=None):
794794 ofsg = [fixed .get (d ) or ofsg .pop (0 ) for d in f .dimensions ]
795795
796796 # The `gather` is unnecessary if sending to MPI.PROC_NULL
797- arguments = [cast (bufg )] + sizes + list (f .handles ) + ofsg
797+ arguments = [fcast (bufg )] + sizes + list (f .handles ) + ofsg
798798 gather = Gather ('gather%s' % key , arguments )
799799 gather = Conditional (CondNe (torank , Macro ('MPI_PROC_NULL' )), gather )
800800
@@ -819,7 +819,7 @@ def _call_haloupdate(self, name, f, hse, msg):
819819 return HaloUpdateCall (name , args )
820820
821821 def _make_halowait (self , f , hse , key , * args , msg = None ):
822- cast = cast_mapper (( f .c0 .dtype , '*' ) )
822+ fcast = cast ( f .c0 .dtype , '*' )
823823
824824 fixed = {d : Symbol (name = "o%s" % d .root ) for d in hse .loc_indices }
825825
@@ -839,7 +839,7 @@ def _make_halowait(self, f, hse, key, *args, msg=None):
839839
840840 # The `scatter` must be guarded as we must not alter the halo values along
841841 # the domain boundary, where the sender is actually MPI.PROC_NULL
842- arguments = [cast (bufs )] + sizes + list (f .handles ) + ofss
842+ arguments = [fcast (bufs )] + sizes + list (f .handles ) + ofss
843843 scatter = Scatter ('scatter%s' % key , arguments )
844844 scatter = Conditional (CondNe (fromrank , Macro ('MPI_PROC_NULL' )), scatter )
845845
0 commit comments