mirror of
https://github.com/smyalygames/FiniteVolumeGPU_HIP.git
synced 2025-05-18 06:24:11 +02:00
264 lines
11 KiB
Python
264 lines
11 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
This python module implements SHMEM simulator group class
|
|
|
|
Copyright (C) 2020 Norwegian Meteorological Institute
|
|
|
|
This program is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
"""
|
|
|
|
|
|
import logging
|
|
from GPUSimulators import Simulator, CudaContext
|
|
import numpy as np
|
|
|
|
import pycuda.driver as cuda
|
|
|
|
import time
|
|
|
|
class SHMEMSimulator(Simulator.BaseSimulator):
|
|
"""
|
|
Class which handles communication and synchronization between simulators in different
|
|
contexts (presumably on different GPUs)
|
|
"""
|
|
def __init__(self, sims, grid):
|
|
self.logger = logging.getLogger(__name__)
|
|
|
|
assert(len(sims) > 1)
|
|
|
|
self.sims = sims
|
|
|
|
# XXX: This is not what was intended. Do we need extra wrapper class SHMEMSimulator?
|
|
# See also getOutput() and check().
|
|
#
|
|
# SHMEMSimulatorGroup would then not have any superclass, but manage a collection of
|
|
# SHMEMSimulators that have BaseSimulator as a superclass.
|
|
#
|
|
# This would also eliminate the need for all the array bookkeeping in this class.
|
|
autotuner = sims[0].context.autotuner
|
|
sims[0].context.autotuner = None
|
|
boundary_conditions = sims[0].getBoundaryConditions()
|
|
super().__init__(sims[0].context,
|
|
sims[0].nx, sims[0].ny,
|
|
sims[0].dx, sims[0].dy,
|
|
boundary_conditions,
|
|
sims[0].cfl_scale,
|
|
sims[0].num_substeps,
|
|
sims[0].block_size[0], sims[0].block_size[1])
|
|
sims[0].context.autotuner = autotuner
|
|
|
|
self.sims = sims
|
|
self.grid = grid
|
|
|
|
self.east = [None] * len(self.sims)
|
|
self.west = [None] * len(self.sims)
|
|
self.north = [None] * len(self.sims)
|
|
self.south = [None] * len(self.sims)
|
|
|
|
self.nvars = [None] * len(self.sims)
|
|
|
|
self.read_e = [None] * len(self.sims)
|
|
self.read_w = [None] * len(self.sims)
|
|
self.read_n = [None] * len(self.sims)
|
|
self.read_s = [None] * len(self.sims)
|
|
|
|
self.write_e = [None] * len(self.sims)
|
|
self.write_w = [None] * len(self.sims)
|
|
self.write_n = [None] * len(self.sims)
|
|
self.write_s = [None] * len(self.sims)
|
|
|
|
self.e = [None] * len(self.sims)
|
|
self.w = [None] * len(self.sims)
|
|
self.n = [None] * len(self.sims)
|
|
self.s = [None] * len(self.sims)
|
|
|
|
for i, sim in enumerate(self.sims):
|
|
#Get neighbor subdomain ids
|
|
self.east[i] = grid.getEast(i)
|
|
self.west[i] = grid.getWest(i)
|
|
self.north[i] = grid.getNorth(i)
|
|
self.south[i] = grid.getSouth(i)
|
|
|
|
#Get coordinate of this subdomain
|
|
#and handle global boundary conditions
|
|
new_boundary_conditions = Simulator.BoundaryCondition({
|
|
'north': Simulator.BoundaryCondition.Type.Dirichlet,
|
|
'south': Simulator.BoundaryCondition.Type.Dirichlet,
|
|
'east': Simulator.BoundaryCondition.Type.Dirichlet,
|
|
'west': Simulator.BoundaryCondition.Type.Dirichlet
|
|
})
|
|
gi, gj = grid.getCoordinate(i)
|
|
if (gi == 0 and boundary_conditions.west != Simulator.BoundaryCondition.Type.Periodic):
|
|
self.west = None
|
|
new_boundary_conditions.west = boundary_conditions.west;
|
|
if (gj == 0 and boundary_conditions.south != Simulator.BoundaryCondition.Type.Periodic):
|
|
self.south = None
|
|
new_boundary_conditions.south = boundary_conditions.south;
|
|
if (gi == grid.grid[0]-1 and boundary_conditions.east != Simulator.BoundaryCondition.Type.Periodic):
|
|
self.east = None
|
|
new_boundary_conditions.east = boundary_conditions.east;
|
|
if (gj == grid.grid[1]-1 and boundary_conditions.north != Simulator.BoundaryCondition.Type.Periodic):
|
|
self.north = None
|
|
new_boundary_conditions.north = boundary_conditions.north;
|
|
sim.setBoundaryConditions(new_boundary_conditions)
|
|
|
|
#Get number of variables
|
|
self.nvars[i] = len(sim.getOutput().gpu_variables)
|
|
|
|
#Shorthands for computing extents and sizes
|
|
gc_x = int(sim.getOutput()[0].x_halo)
|
|
gc_y = int(sim.getOutput()[0].y_halo)
|
|
nx = int(sim.nx)
|
|
ny = int(sim.ny)
|
|
|
|
#Set regions for ghost cells to read from
|
|
#These have the format [x0, y0, width, height]
|
|
self.read_e[i] = np.array([ nx, 0, gc_x, ny + 2*gc_y])
|
|
self.read_w[i] = np.array([gc_x, 0, gc_x, ny + 2*gc_y])
|
|
self.read_n[i] = np.array([gc_x, ny, nx, gc_y])
|
|
self.read_s[i] = np.array([gc_x, gc_y, nx, gc_y])
|
|
|
|
#Set regions for ghost cells to write to
|
|
self.write_e[i] = self.read_e[i] + np.array([gc_x, 0, 0, 0])
|
|
self.write_w[i] = self.read_w[i] - np.array([gc_x, 0, 0, 0])
|
|
self.write_n[i] = self.read_n[i] + np.array([0, gc_y, 0, 0])
|
|
self.write_s[i] = self.read_s[i] - np.array([0, gc_y, 0, 0])
|
|
|
|
#Allocate host data
|
|
#Note that east and west also transfer ghost cells
|
|
#whilst north/south only transfer internal cells
|
|
#Reuses the width/height defined in the read-extets above
|
|
self.e[i] = np.empty((self.nvars[i], self.read_e[i][3], self.read_e[i][2]), dtype=np.float32)
|
|
self.w[i] = np.empty((self.nvars[i], self.read_w[i][3], self.read_w[i][2]), dtype=np.float32)
|
|
self.n[i] = np.empty((self.nvars[i], self.read_n[i][3], self.read_n[i][2]), dtype=np.float32)
|
|
self.s[i] = np.empty((self.nvars[i], self.read_s[i][3], self.read_s[i][2]), dtype=np.float32)
|
|
|
|
self.logger.debug("Initialized {:d} subdomains".format(len(self.sims)))
|
|
|
|
|
|
def substep(self, dt, step_number):
|
|
self.exchange()
|
|
|
|
for i, sim in enumerate(self.sims):
|
|
sim.substep(dt, step_number)
|
|
|
|
def getOutput(self):
|
|
# XXX: Does not return what we would expect.
|
|
# Returns first subdomain, but we want the whole domain.
|
|
return self.sims[0].getOutput()
|
|
|
|
def synchronize(self):
|
|
for sim in self.sims:
|
|
sim.synchronize()
|
|
|
|
def check(self):
|
|
# XXX: Does not return what we would expect.
|
|
# Checks only first subdomain, but we want to check the whole domain.
|
|
return self.sims[0].check()
|
|
|
|
def computeDt(self):
|
|
global_dt = float("inf")
|
|
|
|
for sim in self.sims:
|
|
sim.context.synchronize()
|
|
|
|
for sim in self.sims:
|
|
local_dt = sim.computeDt()
|
|
if local_dt < global_dt:
|
|
global_dt = local_dt
|
|
self.logger.debug("Local dt: {:f}".format(local_dt))
|
|
|
|
self.logger.debug("Global dt: {:f}".format(global_dt))
|
|
return global_dt
|
|
|
|
def getExtent(self, index=0):
|
|
"""
|
|
Function which returns the extent of the subdomain with index
|
|
index in the grid
|
|
"""
|
|
width = self.sims[index].nx*self.sims[index].dx
|
|
height = self.sims[index].ny*self.sims[index].dy
|
|
i, j = self.grid.getCoordinate(index)
|
|
x0 = i * width
|
|
y0 = j * height
|
|
x1 = x0 + width
|
|
y1 = y0 + height
|
|
return [x0, x1, y0, y1]
|
|
|
|
def exchange(self):
|
|
####
|
|
# First transfer internal cells north-south
|
|
####
|
|
for i in range(len(self.sims)):
|
|
self.ns_download(i)
|
|
|
|
for i in range(len(self.sims)):
|
|
self.ns_upload(i)
|
|
|
|
####
|
|
# Then transfer east-west including ghost cells that have been filled in by north-south transfer above
|
|
####
|
|
for i in range(len(self.sims)):
|
|
self.ew_download(i)
|
|
|
|
for i in range(len(self.sims)):
|
|
self.ew_upload(i)
|
|
|
|
def ns_download(self, i):
|
|
#Download from the GPU
|
|
if self.north[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
# XXX: Unnecessary global sync (only need to sync with neighboring subdomain to the north)
|
|
self.sims[i].u0[k].download(self.sims[i].stream, cpu_data=self.n[i][k,:,:], extent=self.read_n[i])
|
|
if self.south[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
# XXX: Unnecessary global sync (only need to sync with neighboring subdomain to the south)
|
|
self.sims[i].u0[k].download(self.sims[i].stream, cpu_data=self.s[i][k,:,:], extent=self.read_s[i])
|
|
self.sims[i].stream.synchronize()
|
|
|
|
def ns_upload(self, i):
|
|
#Upload to the GPU
|
|
if self.north[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
self.sims[i].u0[k].upload(self.sims[i].stream, self.s[self.north[i]][k,:,:], extent=self.write_n[i])
|
|
if self.south[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
self.sims[i].u0[k].upload(self.sims[i].stream, self.n[self.south[i]][k,:,:], extent=self.write_s[i])
|
|
|
|
def ew_download(self, i):
|
|
#Download from the GPU
|
|
if self.east[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
# XXX: Unnecessary global sync (only need to sync with neighboring subdomain to the east)
|
|
self.sims[i].u0[k].download(self.sims[i].stream, cpu_data=self.e[i][k,:,:], extent=self.read_e[i])
|
|
if self.west[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
# XXX: Unnecessary global sync (only need to sync with neighboring subdomain to the west)
|
|
self.sims[i].u0[k].download(self.sims[i].stream, cpu_data=self.w[i][k,:,:], extent=self.read_w[i])
|
|
self.sims[i].stream.synchronize()
|
|
|
|
def ew_upload(self, i):
|
|
#Upload to the GPU
|
|
if self.east[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
self.sims[i].u0[k].upload(self.sims[i].stream, self.w[self.east[i]][k,:,:], extent=self.write_e[i])
|
|
#test_east = np.ones_like(self.e[self.east[i]][k,:,:])
|
|
#self.sims[i].u0[k].upload(self.sims[i].stream, test_east, extent=self.write_e[i])
|
|
if self.west[i] is not None:
|
|
for k in range(self.nvars[i]):
|
|
self.sims[i].u0[k].upload(self.sims[i].stream, self.e[self.west[i]][k,:,:], extent=self.write_w[i])
|
|
#test_west = np.ones_like(self.e[self.west[i]][k,:,:])
|
|
#self.sims[i].u0[k].upload(self.sims[i].stream, test_west, extent=self.write_w[i])
|