updaet cusom ghosts. simulation write parameters with freq

hysop/backend/host/python/operator/custom.py

@@ -57,7 +57,9 @@ class PythonCustomOperator(HostOperator):
                 if not it[1] is None:
                     is_input, (field, td, req) = it
                     min_ghosts = (max(g, self._ghosts) for g in req.min_ghosts.copy())
+                    max_ghosts = (min(g, self._ghosts) for g in req.max_ghosts.copy())
                     req.min_ghosts = min_ghosts
+                    req.max_ghosts = max_ghosts
         return requirements
 
     @debug

hysop/simulation.py

@@ -224,16 +224,17 @@ class Simulation(object):
         for (io_params, params, kwds) in self._parameters_to_write:
             if self.mpi_params.rank == io_params.io_leader:
                 if (io_params.fileformat is IO.ASCII):
-                    kwds = kwds.copy()
-                    f = kwds.pop('file')
-                    formatter = kwds.pop('formatter')
-                    values = npw.asarray(tuple(map(lambda x: x.item() if x.size == 1 else x,
-                                                   (p() for p in params))))
-                    values = npw.array2string(values, max_line_width=npw.inf,
-                                              formatter=formatter, legacy='1.13', **kwds)
-                    values = '\n'+values[1:-1]
-                    f.write(values)
-                    f.flush()
+                    if ((self.current_iteration % io_params.frequency) == 0):
+                        kwds = kwds.copy()
+                        f = kwds.pop('file')
+                        formatter = kwds.pop('formatter')
+                        values = npw.asarray(tuple(map(lambda x: x.item() if x.size == 1 else x,
+                                                       (p() for p in params))))
+                        values = npw.array2string(values, max_line_width=npw.inf,
+                                                  formatter=formatter, legacy='1.13', **kwds)
+                        values = '\n'+values[1:-1]
+                        f.write(values)
+                        f.flush()
                 else:
                     msg = 'Unknown format {}.'.format(fileformat)
                     raise ValueError(msg)