+
+
+/* *
+ * *
+ * * Module management functions
+ * *
+ * */
+
+
+
+static void _amok_pm_init(void) {
+ /* no world-wide globals */
+ /* Datatype and message declarations */
+ gras_msgtype_declare("amok_pm_kill",NULL);
+ gras_msgtype_declare_rpc("amok_pm_killrpc",NULL,NULL);
+
+ gras_msgtype_declare_rpc("amok_pm_get",
+ gras_datadesc_by_name("string"),
+ gras_datadesc_by_name("xbt_dynar_t"));
+ gras_msgtype_declare_rpc("amok_pm_join",
+ gras_datadesc_by_name("string"),
+ NULL);
+ gras_msgtype_declare_rpc("amok_pm_leave",
+ gras_datadesc_by_name("string"),
+ NULL);
+
+ gras_msgtype_declare_rpc("amok_pm_shutdown",
+ gras_datadesc_by_name("string"),
+ NULL);
+}
+
+static void _amok_pm_join(void *p) {
+ /* moddata management */
+ amok_pm_moddata_t mod = (amok_pm_moddata_t)p;
+
+ mod->done = 0;
+ mod->groups = xbt_dict_new();
+ INFO1("groups=%p",mod->groups);
+
+ /* callbacks */
+ gras_cb_register(gras_msgtype_by_name("amok_pm_kill"),
+ &amok_pm_cb_kill);
+ gras_cb_register(gras_msgtype_by_name("amok_pm_killrpc"),
+ &amok_pm_cb_killrpc);
+
+ gras_cb_register(gras_msgtype_by_name("amok_pm_get"),
+ &amok_pm_cb_get);
+ gras_cb_register(gras_msgtype_by_name("amok_pm_join"),
+ &amok_pm_cb_join);
+ gras_cb_register(gras_msgtype_by_name("amok_pm_leave"),
+ &amok_pm_cb_leave);
+ gras_cb_register(gras_msgtype_by_name("amok_pm_shutdown"),
+ &amok_pm_cb_shutdown);
+}
+static void _amok_pm_exit(void) {
+ /* no world-wide globals */
+}
+static void _amok_pm_leave(void *p) {
+ /* moddata */
+ amok_pm_moddata_t mod = (amok_pm_moddata_t)p;
+
+ xbt_dict_free(&mod->groups);
+
+ /* callbacks */
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_kill"),
+ &amok_pm_cb_kill);
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_killrpc"),
+ &amok_pm_cb_killrpc);
+
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_get"),
+ &amok_pm_cb_get);
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_join"),
+ &amok_pm_cb_join);
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_leave"),
+ &amok_pm_cb_leave);
+
+ gras_cb_unregister(gras_msgtype_by_name("amok_pm_shutdown"),
+ &amok_pm_cb_shutdown);
+}
+
+void amok_pm_modulecreate() {
+ gras_module_add("amok_pm", sizeof(s_amok_pm_moddata_t), &amok_pm_moddata_id,
+ &_amok_pm_init,&_amok_pm_exit,&_amok_pm_join,&_amok_pm_leave);
+}
+
+
+
+/* *
+ * *
+ * * Old module functions (kept for compatibility)
+ * *
+ * */
+/** \brief Initialize the peer management module. Every process must run it before use */
+void amok_pm_init() {
+ gras_module_join("amok_pm");
+}
+
+/** \brief Finalize the peer management module. Every process should run it after use */
+void amok_pm_exit() {
+ gras_module_leave("amok_pm");
+}