Skip to content
Snippets Groups Projects
Commit 612cbbff authored by Thomas Jahns's avatar Thomas Jahns :cartwheel: Committed by Sergey Kosukhin
Browse files

Add callback for server-side actions following a write batch.

parent 7a85f31a
No related branches found
No related tags found
2 merge requests!34Version 2.2.0,!13Consolidation with CDI-PIO (develop)
......@@ -158,6 +158,10 @@ void (*cdiPioConfGetPostCommSetupActions(int confResH))(void);
* BIND(C) on Fortran side
*/
#define CDIPIO_CALLBACK_POSTSTREAMCLOSE 1
/* CDIPIO_CALLBACK_POSTWRITEBATCH: trigger number for callback called
* on server side after the processing for all operations initiated by
* a client-side pioWriteTimestep have completed */
#define CDIPIO_CALLBACK_POSTWRITEBATCH 2
/* cdiPioConfSetCallBack: set function to be called at
* indicated trigger of configuration object, action will be cast to
......
......@@ -16,7 +16,7 @@ typedef Xt_xmap (*xmap_new_func_ptr)(Xt_idxlist src_idxlist, Xt_idxlist dst_idxl
enum
{
CDIPIO_NUM_CALLBACKS = 2,
CDIPIO_NUM_CALLBACKS = 3,
};
/*
......
......@@ -1634,6 +1634,7 @@ cdiPioCollectorMessageLoop()
xmpi(MPI_Recv(streamActivity, (int) openStreams.size, MPI_INT, source, tag, pioInterComm, &status));
xdebug("RECEIVED MESSAGE WITH TAG \"WRITETS\": source=%d", source);
getTimeStepData(streamActivity, conf);
conf->callbacks[CDIPIO_CALLBACK_POSTWRITEBATCH]();
}
break;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment