MDI_Library/html/mdi__lib_8h_source.html

#ifndef MDI_LIBRARY_IMPL

#define MDI_LIBRARY_IMPL


#include "mdi.h"

#include "mdi_global.h"


typedef int (*MDI_Plugin_init_t)( void* shared_state );


/*

!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

!!!!!!!!!!!!!!!!! ABI WARNING !!!!!!!!!!!!!!!!!!!!

!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!


Changing this structure will affect the plugin ABI


*/

typedef struct plugin_shared_state_struct {

  char command[MDI_COMMAND_LENGTH_];

  void** ext;

  int driver_version[3];

  int engine_version[3];

  void* buf;

  char** plugin_argv;

  char* plugin_options;

  char* plugin_unedited_options;

  void* mpi_comm_ptr;

  void* driver_callback_obj;

  void* execute_command_obj;

  void* python_interpreter_dict;

  void* driver_codes_ptr;

  void* engine_codes_ptr;

  void* engine_nodes;

  int (*driver_activate_code)(void*, int);

  int (*engine_activate_code)(void*, int);

  int (*lib_execute_command)(MDI_Comm);

  int (*execute_command_wrapper)(const char*, MDI_Comm_Type, void*);

  int (*execute_builtin)(const char*, MDI_Comm_Type, int*);

  int (*delete_engine)(size_t);

  size_t engine_code_id;

  size_t driver_code_id;

  MDI_execute_command_type execute_command;

  MDI_Driver_node_callback_t driver_node_callback;

  MDI_Comm driver_mdi_comm;

  MDI_Comm engine_mdi_comm;

  int buf_allocated;

  int plugin_argc;

  int plugin_argv_allocated;

  int intra_rank;

  int engine_language;

  int python_interpreter_initialized;

} plugin_shared_state;


typedef struct library_data_struct {

  plugin_shared_state* shared_state;

  int connected_code;

  int execute_on_send;

  MPI_Comm mpi_comm;

  void* driver_callback_obj;

  MDI_Driver_node_callback_t driver_node_callback;

#ifdef _WIN32


  HINSTANCE plugin_handle;

#else


  void* plugin_handle;

#endif


  MDI_Plugin_init_t plugin_init;

  int is_python;

} library_data;


int enable_plug_support(int code_id);

int plug_on_selection();

int plug_on_accept_communicator();

int plug_on_send_command(const char* command, MDI_Comm comm, int* skip_flag);

int plug_after_send_command(const char* command, MDI_Comm comm);

int plug_on_recv_command(MDI_Comm comm);


int library_load_init(const char* plugin_name, void* mpi_comm_ptr,

                      library_data* libd, int mode);

int library_parse_options(const char* options, library_data* libd);

int library_launch_plugin(const char* plugin_name, const char* options, void* mpi_comm_ptr,

                          MDI_Driver_node_callback_t driver_node_callback,

                          void* driver_callback_object);

int library_open_plugin(const char* plugin_name, const char* options, void* mpi_comm_ptr,

                          MDI_Comm* mdi_comm_ptr);

int library_close_plugin(MDI_Comm mdi_comm);

int library_initialize();

int library_set_driver_current(MDI_Comm comm);

int library_set_command(const char* command, MDI_Comm comm);

int library_execute_command(MDI_Comm comm);

int library_send(const void* buf, int count, MDI_Datatype datatype, MDI_Comm comm, int msg_flag);

int library_recv(void* buf, int count, MDI_Datatype datatype, MDI_Comm comm, int msg_flag);

int library_send_msg(const void* buf, int count, MDI_Datatype datatype, MDI_Comm comm);

int library_recv_msg(void* buf, int count, MDI_Datatype datatype, MDI_Comm comm);


int library_set_state(void* state);

int library_activate_code(void* codes_in, int code_id);

int library_activate_driver(library_data* libd);

int library_activate_engine(library_data* libd);


int communicator_delete_lib(void* comm);

int library_delete_engine(size_t code_id);


#endif