Skip to content
Snippets Groups Projects
Verified Commit f9ec2437 authored by raphael.bach's avatar raphael.bach
Browse files

Add `fmpi_sync()`

parent 6ab78295
No related branches found
No related tags found
No related merge requests found
...@@ -130,6 +130,10 @@ int fmpi_world_barrier(const struct fmpi_ctx * ctx); ...@@ -130,6 +130,10 @@ int fmpi_world_barrier(const struct fmpi_ctx * ctx);
fmpi_run_task() fmpi_run_task()
------------------------------------------------------------------------------*/ ------------------------------------------------------------------------------*/
int fmpi_run_task(const struct fmpi_ctx * ctx, const struct fmpi_task * task); int fmpi_run_task(const struct fmpi_ctx * ctx, const struct fmpi_task * task);
/*------------------------------------------------------------------------------
fmpi_sync()
------------------------------------------------------------------------------*/
int fmpi_sync(const struct fmpi_ctx * ctx);
/*============================================================================== /*==============================================================================
MACRO MACRO
==============================================================================*/ ==============================================================================*/
......
...@@ -31,6 +31,7 @@ ...@@ -31,6 +31,7 @@
#include "fmpi_task.h" #include "fmpi_task.h"
#include "internal/fmpi_ctx.h" #include "internal/fmpi_ctx.h"
#include "internal/fmpi_error.h" #include "internal/fmpi_error.h"
#include "internal/fmpi_futhark.h"
#include "internal/fmpi_mpi.h" #include "internal/fmpi_mpi.h"
/*============================================================================== /*==============================================================================
PUBLIC FUNCTION DEFINITION PUBLIC FUNCTION DEFINITION
...@@ -108,3 +109,11 @@ int fmpi_run_task( ...@@ -108,3 +109,11 @@ int fmpi_run_task(
} }
return fmpi_task_run_async(ctx, task); return fmpi_task_run_async(ctx, task);
} }
/*------------------------------------------------------------------------------
fmpi_sync()
------------------------------------------------------------------------------*/
int fmpi_sync(const struct fmpi_ctx * const ctx)
{
assert(ctx != NULL);
return fmpi_futhark_sync(ctx->fut);
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment