#include <pthread.h>
#include <asmp/types.h>
#include <asmp/mptask.h>
#include <asmp/mpmq.h>
#include <mpcomm/mpcomm.h>
Go to the source code of this file.
◆ worker_info_t
◆ mpcomm_supervisor_context_t
◆ mpcomm_supervisor_init()
Initialize the MPCOMM framework.
- Parameters
-
[in] | ctx | Context with information about MPCOMM workers. |
[in] | filepath | Path to controller and helper binary file. |
[in] | helper_num | Number of helpers to be used. |
- Returns
- On success, 0 is returned. On failure, negative value is returned according to <errno.h>.
◆ mpcomm_supervisor_deinit()
Deinitialize the MPCOMM framework.
- Parameters
-
[in] | ctx | Context with information about MPCOMM workers. |
- Returns
- On success, 0 is returned. On failure, negative value is returned according to <errno.h>.
◆ mpcomm_supervisor_send_controller()
Send the user data to the controller for processing.
- Parameters
-
[in] | ctx | Context with information about MPCOMM workers. |
[in] | data | User data. |
- Returns
- On success, 0 is returned. On failure, negative value is returned according to <errno.h>.
◆ mpcomm_supervisor_wait_controller_done()
Wait until user data has been processed by controller.
- Parameters
-
[in] | ctx | Context with information about MPCOMM workers. |
[in] | abstime | The absolute time to wait until a timeout is declared. |
- Returns
- On success, 0 is returned. On failure, negative value is returned according to <errno.h>.