Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
loads all of gras.h, not only parts
[simgrid.git] / src / amok / base.c
1 /* $Id$ */
2
3 /* base - several addons to do specific stuff not in GRAS itself            */
4
5 /* Copyright (c) 2003, 2004 Martin Quinson. All rights reserved.            */
6
7 /* This program is free software; you can redistribute it and/or modify it
8  * under the terms of the license (GNU LGPL) which comes with this package. */
9
10 #include "gras.h"
11 #include "amok/base.h"
12
13 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(amok,XBT_LOG_ROOT_CAT,"All AMOK categories");
14
15 amok_remoterr_t amok_remoterr_new(xbt_error_t param_errcode, 
16                                   const char* format,...) {
17    
18   amok_remoterr_t res;
19    
20   va_list ap;
21   va_start(ap,format);
22   res = amok_remoterr_new_va(param_errcode,format,ap);
23   va_end(ap);
24   return res;
25 }
26
27 amok_remoterr_t amok_remoterr_new_va(xbt_error_t param_errcode, 
28                                      const char* format,va_list ap) {
29   amok_remoterr_t res=xbt_new(s_amok_remoterr_t,1);
30   res->code=param_errcode;
31   if (format) {
32      res->msg=(char*)xbt_malloc(1024);
33      vsnprintf(res->msg,1024,format,ap);
34   } else {
35      res->msg = NULL;
36   }
37    
38   return res;   
39 }
40
41 void amok_remoterr_free(amok_remoterr_t *err) {
42    if (err && *err) {
43       if ((*err)->msg) free((*err)->msg);
44       free(*err);
45       err=NULL;
46    }
47 }
48
49
50 void
51 amok_repport_error (gras_socket_t sock, gras_msgtype_t msgtype,
52                     xbt_error_t param_errcode, const char* format,...) {
53   amok_remoterr_t error;
54   xbt_error_t errcode;
55   va_list ap;
56
57   error=xbt_new(s_amok_remoterr_t,1);
58   error->code=param_errcode;
59   error->msg=(char*)xbt_malloc(1024); /* FIXME */
60   va_start(ap,format);
61   vsnprintf(error->msg,1024,format,ap);
62   va_end(ap);
63
64   errcode = gras_msg_send(sock,msgtype,error);
65   if (errcode != no_error) {
66      CRITICAL4("Error '%s' while reporting error '%s' to %s:%d",
67                xbt_error_name(errcode),error->msg,
68                gras_socket_peer_name(sock),gras_socket_peer_port(sock) );
69   }
70 }
71
72 void amok_base_init(void) {
73   gras_datadesc_type_t host_desc, remoterr_desc;
74      
75   /* Build the datatype descriptions */
76   host_desc = gras_datadesc_struct("xbt_host_t");
77   gras_datadesc_struct_append(host_desc,"name",gras_datadesc_by_name("string"));
78   gras_datadesc_struct_append(host_desc,"exp_size",gras_datadesc_by_name("int"));
79   gras_datadesc_struct_close(host_desc);
80   host_desc = gras_datadesc_ref("xbt_host_t*",host_desc);
81    
82   remoterr_desc = gras_datadesc_struct("s_amok_remoterr_t");
83   gras_datadesc_struct_append(remoterr_desc,"msg",gras_datadesc_by_name("string"));
84   gras_datadesc_struct_append(remoterr_desc,"code",gras_datadesc_by_name("unsigned int"));
85   gras_datadesc_struct_close(remoterr_desc);
86   remoterr_desc = gras_datadesc_ref("amok_remoterr_t",remoterr_desc);
87 }
88
89 void amok_base_exit(void) {
90    /* No real module mechanism in GRAS so far, nothing to do. */
91 }
92