aboutsummaryrefslogtreecommitdiff
path: root/lbm.py
diff options
context:
space:
mode:
authorAdrian Kummerlaender2019-06-15 21:39:42 +0200
committerAdrian Kummerlaender2019-06-15 21:39:42 +0200
commit63163ebbbced363fde788c560b479569470705bd (patch)
tree62589f9a8049f92066d421e1681a9af54f1ff947 /lbm.py
parentd71faec93ec0a55c46810e0d178b2803ee89130c (diff)
downloadsymlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar.gz
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar.bz2
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar.lz
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar.xz
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.tar.zst
symlbm_playground-63163ebbbced363fde788c560b479569470705bd.zip
Split descriptors and symbolic formulation
Diffstat (limited to 'lbm.py')
-rw-r--r--lbm.py137
1 files changed, 0 insertions, 137 deletions
diff --git a/lbm.py b/lbm.py
deleted file mode 100644
index ef05e4f..0000000
--- a/lbm.py
+++ /dev/null
@@ -1,137 +0,0 @@
-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