cwpearson/astaroth
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added missing synchronization to the end of the new integration function

Browse Source
This commit is contained in:
jpekkila
2020-06-10 12:32:56 +03:00
parent fa422cf457
commit 1cdb9e2ce7
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/core/device.cc
View File

@@ -12,6 +12,11 @@
#define ARRAY_SIZE(arr) (sizeof(arr) / sizeof(arr[0])) #define ARRAY_SIZE(arr) (sizeof(arr) / sizeof(arr[0]))
#define MPI_GPUDIRECT_DISABLED (0) #define MPI_GPUDIRECT_DISABLED (0)
#define DECOMPOSITION_AXES (3)
#define MPI_COMPUTE_ENABLED (1)
#define MPI_COMM_ENABLED (1)
#define MPI_INCL_CORNERS (0)
AcResult AcResult
acDevicePrintInfo(const Device device) acDevicePrintInfo(const Device device)
{ {
@@ -518,8 +523,6 @@ mod(const int a, const int b)
return r < 0 ? r + b : r; return r < 0 ? r + b : r;
} }
#define DECOMPOSITION_AXES (3)
static uint3_64 static uint3_64
morton3D(const uint64_t pid) morton3D(const uint64_t pid)
{ {
@@ -1371,10 +1374,6 @@ acGridStoreMesh(const Stream stream, AcMesh* host_mesh)
return AC_SUCCESS; return AC_SUCCESS;
} }
#define MPI_COMPUTE_ENABLED (1)
#define MPI_COMM_ENABLED (1)
#define MPI_INCL_CORNERS (0)
AcResult AcResult
acGridIntegrate(const Stream stream, const AcReal dt) acGridIntegrate(const Stream stream, const AcReal dt)
{ {
@@ -1582,6 +1581,9 @@ acGridIntegrate(const Stream stream, const AcReal dt)
acDeviceSwapBuffers(device); acDeviceSwapBuffers(device);
} }
// Does not have to be STREAM_ALL, only the streams used with
// acDeviceIntegrateSubstep (less likely to break this way though)
acDeviceSynchronizeStream(device, STREAM_ALL); // Wait until inner and outer done
return AC_SUCCESS; return AC_SUCCESS;
} }