src/gras/Msg/gras_msg_mod.c

   1 /* $Id$ */
   2
   3 /* gras message types handling                                              */
   4
   5 /* Copyright (c) 2003, 2004, 2005, 2006, 2007 Martin Quinson.               */
   6 /* All rights reserved.                                                     */
   7
   8 /* This program is free software; you can redistribute it and/or modify it
   9  * under the terms of the license (GNU LGPL) which comes with this package. */
  10
  11 #include "xbt/ex.h"
  12 #include "gras/Msg/msg_private.h"
  13 #include "gras/Virtu/virtu_interface.h"
  14
  15 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(gras_msg);
  16
  17 extern xbt_set_t _gras_msgtype_set;
  18
  19 /*
  20  * Creating procdata for this module
  21  */
  22 static void *gras_msg_procdata_new(void) {
  23         gras_msg_procdata_t res = xbt_new(s_gras_msg_procdata_t,1);
  24
  25         res->name = xbt_strdup("gras_msg");
  26         res->name_len = 0;
  27         res->msg_queue     = xbt_dynar_new(sizeof(s_gras_msg_t),   NULL);
  28         res->msg_waitqueue = xbt_dynar_new(sizeof(s_gras_msg_t),   NULL);
  29         res->cbl_list      = xbt_dynar_new(sizeof(gras_cblist_t *),gras_cbl_free);
  30         res->timers        = xbt_dynar_new(sizeof(s_gras_timer_t), NULL);
  31         res->msg_to_receive_queue = xbt_fifo_new();
  32         res->msg_to_receive_queue_meas = xbt_fifo_new();
  33         res->msg_received = xbt_queue_new(0,sizeof(s_gras_msg_t));
  34
  35         return (void*)res;
  36 }
  37
  38 /*
  39  * Freeing procdata for this module
  40  */
  41 static void gras_msg_procdata_free(void *data) {
  42         gras_msg_procdata_t res = (gras_msg_procdata_t)data;
  43
  44         xbt_dynar_free(&( res->msg_queue ));
  45         xbt_dynar_free(&( res->msg_waitqueue ));
  46         xbt_dynar_free(&( res->cbl_list ));
  47         xbt_dynar_free(&( res->timers ));
  48         xbt_fifo_free( res->msg_to_receive_queue );
  49         xbt_fifo_free( res->msg_to_receive_queue_meas );
  50
  51         free(res->name);
  52         free(res);
  53 }
  54
  55 /*
  56  * Module registration
  57  */
  58 int gras_msg_libdata_id;
  59 void gras_msg_register() {
  60         gras_msg_libdata_id = gras_procdata_add("gras_msg",gras_msg_procdata_new, gras_msg_procdata_free);
  61 }
  62
  63 /*
  64  * Initialize this submodule.
  65  */
  66 void gras_msg_init(void) {
  67         /* only initialize once */
  68         if (_gras_msgtype_set != NULL)
  69                 return;
  70
  71         VERB0("Initializing Msg");
  72
  73         _gras_msgtype_set = xbt_set_new();
  74
  75         memcpy(_GRAS_header,"GRAS", 4);
  76         _GRAS_header[4]=GRAS_PROTOCOL_VERSION;
  77         _GRAS_header[5]=(char)GRAS_THISARCH;
  78
  79         gras_msg_ctx_mallocator =
  80                 xbt_mallocator_new(1000,
  81                                 gras_msg_ctx_mallocator_new_f,
  82                                 gras_msg_ctx_mallocator_free_f,
  83                                 gras_msg_ctx_mallocator_reset_f);
  84 }
  85
  86 /*
  87  * Finalize the msg module
  88  */
  89 void
  90 gras_msg_exit(void) {
  91         VERB0("Exiting Msg");
  92         xbt_set_free(&_gras_msgtype_set);
  93
  94         xbt_mallocator_free(gras_msg_ctx_mallocator);
  95 }
  96