Split descriptors and symbolic formulation

1 files changed, 137 insertions, 0 deletions

diff --git a/simulation.py b/simulation.py
new file mode 100644
index 0000000..ef05e4f
--- /dev/null
+++ b/simulation.py
@@ -0,0 +1,137 @@
+import pyopencl as cl
+mf = cl.mem_flags
+
+import numpy
+import sympy
+
+from mako.template import Template
+from pathlib import Path
+
+class Geometry:
+    def __init__(self, size_x, size_y, size_z = 1):
+        self.size_x = size_x
+        self.size_y = size_y
+        self.size_z = size_z
+        self.volume = size_x * size_y * size_z
+
+    def inner_cells(self):
+        if self.size_z == 1:
+            for y in range(1,self.size_y-1):
+                for x in range(1,self.size_x-1):
+                    yield x, y
+        else:
+            for z in range(1,self.size_z-1):
+                for y in range(1,self.size_y-1):
+                    for x in range(1,self.size_x-1):
+                        yield x, y, z
+
+    def span(self):
+        if self.size_z == 1:
+            return (self.size_x, self.size_y)
+        else:
+            return (self.size_x, self.size_y, self.size_z)
+
+    def inner_span(self):
+        if self.size_z == 1:
+            return (self.size_x-2, self.size_y-2)
+        else:
+            return (self.size_x-2, self.size_y-2, self.size_z-2)
+
+
+class Lattice:
+    def __init__(self, descriptor, geometry, moments, collide, pop_eq_src = '', boundary_src = ''):
+        self.descriptor = descriptor
+        self.geometry   = geometry
+
+        self.moments = moments
+        self.collide = collide
+
+        self.pop_eq_src = pop_eq_src
+        self.boundary_src = boundary_src
+
+        self.platform = cl.get_platforms()[0]
+        self.context  = cl.Context(properties=[(cl.context_properties.PLATFORM, self.platform)])
+        self.queue = cl.CommandQueue(self.context)
+
+        self.np_material = numpy.ndarray(shape=(self.geometry.volume, 1), dtype=numpy.int32)
+
+        self.tick = True
+
+        self.pop_size     = descriptor.q     * self.geometry.volume * numpy.float32(0).nbytes
+        self.moments_size = (descriptor.d+1) * self.geometry.volume * numpy.float32(0).nbytes
+
+        self.cl_pop_a = cl.Buffer(self.context, mf.READ_WRITE, size=self.pop_size)
+        self.cl_pop_b = cl.Buffer(self.context, mf.READ_WRITE, size=self.pop_size)
+
+        self.cl_moments  = cl.Buffer(self.context, mf.WRITE_ONLY, size=self.moments_size)
+        self.cl_material = cl.Buffer(self.context, mf.READ_ONLY | mf.USE_HOST_PTR, hostbuf=self.np_material)
+
+        self.build_kernel()
+
+        if descriptor.d == 2:
+            self.layout = (32,1)
+        elif descriptor.d == 3:
+            self.layout = (32,1,1)
+
+        self.program.equilibrilize(
+            self.queue, self.geometry.span(), self.layout, self.cl_pop_a, self.cl_pop_b).wait()
+
+    def idx(self, x, y, z = 0):
+        return z * (self.geometry.size_x*self.geometry.size_y) + y * self.geometry.size_x + x;
+
+    def setup_geometry(self, material_at):
+        if self.descriptor.d == 2:
+            for x, y in self.geometry.inner_cells():
+                self.np_material[self.idx(x,y)] = material_at(self.geometry, x, y)
+        elif self.descriptor.d == 3:
+            for x, y, z in self.geometry.inner_cells():
+                self.np_material[self.idx(x,y,z)] = material_at(self.geometry, x, y, z)
+
+        cl.enqueue_copy(self.queue, self.cl_material, self.np_material).wait();
+
+    def build_kernel(self):
+        program_src = Template(filename = str(Path(__file__).parent/'template/kernel.mako')).render(
+            descriptor = self.descriptor,
+            geometry   = self.geometry,
+
+            moments_subexpr    = self.moments[0],
+            moments_assignment = self.moments[1],
+            collide_subexpr    = self.collide[0],
+            collide_assignment = self.collide[1],
+
+            pop_eq_src = Template(self.pop_eq_src).render(
+                descriptor = self.descriptor,
+                geometry   = self.geometry
+            ),
+            boundary_src = Template(self.boundary_src).render(
+                descriptor = self.descriptor,
+                geometry   = self.geometry
+            ),
+
+            ccode = sympy.ccode
+        )
+        self.program = cl.Program(self.context, program_src).build('-cl-single-precision-constant -cl-fast-relaxed-math')
+
+    def evolve(self):
+        if self.tick:
+            self.tick = False
+            self.program.collide_and_stream(
+                self.queue, self.geometry.span(), self.layout, self.cl_pop_a, self.cl_pop_b, self.cl_material)
+        else:
+            self.tick = True
+            self.program.collide_and_stream(
+                self.queue, self.geometry.span(), self.layout, self.cl_pop_b, self.cl_pop_a, self.cl_material)
+
+    def sync(self):
+        self.queue.finish()
+
+    def get_moments(self):
+        moments = numpy.ndarray(shape=(self.descriptor.d+1, self.geometry.volume), dtype=numpy.float32)
+        if self.tick:
+            self.program.collect_moments(
+                self.queue, self.geometry.span(), self.layout, self.cl_pop_b, self.cl_moments)
+        else:
+            self.program.collect_moments(
+                self.queue, self.geometry.span(), self.layout, self.cl_pop_a, self.cl_moments)
+        cl.enqueue_copy(self.queue, moments, self.cl_moments).wait();
+        return moments