X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ec16845133f5f1b5262d2d77d8ba22824fa8a446..e566c09daba9ad67b31f3992da9172eb04b807a8:/src/gras/DataDesc/ddt_exchange.c diff --git a/src/gras/DataDesc/ddt_exchange.c b/src/gras/DataDesc/ddt_exchange.c index 4e4e510593..60b19436e9 100644 --- a/src/gras/DataDesc/ddt_exchange.c +++ b/src/gras/DataDesc/ddt_exchange.c @@ -81,7 +81,7 @@ static XBT_INLINE void gras_dd_alloc_ref(xbt_dict_t refs, long int size, char ** { char *l_data = NULL; - xbt_assert1(size > 0, "Cannot allocate %ld bytes!", size); + xbt_assert(size > 0, "Cannot allocate %ld bytes!", size); l_data = xbt_malloc((size_t) size); *l_ref = l_data; @@ -136,7 +136,7 @@ gras_datadesc_memcpy_rec(gras_cbps_t state, char *field_dst; struct_data = type->category.struct_data; - xbt_assert1(struct_data.closed, + xbt_assert(struct_data.closed, "Please call gras_datadesc_declare_struct_close on %s before copying it", type->name); XBT_VERB(">> Copy all fields of the structure %s", type->name); @@ -194,17 +194,17 @@ gras_datadesc_memcpy_rec(gras_cbps_t state, union_data = type->category.union_data; - xbt_assert1(union_data.closed, + xbt_assert(union_data.closed, "Please call gras_datadesc_declare_union_close on %s before copying it", type->name); /* retrieve the field number */ field_num = union_data.selector(type, state, src); - xbt_assert1(field_num > 0, + xbt_assert(field_num > 0, "union field selector of %s gave a negative value", type->name); - xbt_assert3(field_num < xbt_dynar_length(union_data.fields), + xbt_assert(field_num < xbt_dynar_length(union_data.fields), "union field selector of %s returned %d but there is only %lu fields", type->name, field_num, xbt_dynar_length(union_data.fields)); @@ -325,7 +325,7 @@ gras_datadesc_memcpy_rec(gras_cbps_t state, array_count = subsize; if (array_count == -1) { array_count = array_data.dynamic_size(type, state, src); - xbt_assert1(array_count >= 0, + xbt_assert(array_count >= 0, "Invalid (negative) array size for type %s", type->name); } @@ -385,12 +385,11 @@ gras_datadesc_memcpy_rec(gras_cbps_t state, */ int gras_datadesc_memcpy(gras_datadesc_type_t type, void *src, void *dst) { - xbt_ex_t e; static gras_cbps_t state = NULL; static xbt_dict_t refs = NULL; /* all references already sent */ int size = 0; - xbt_assert0(type, "called with NULL type descriptor"); + xbt_assert(type, "called with NULL type descriptor"); XBT_DEBUG("Memcopy a %s from %p to %p", gras_datadesc_get_name(type), src, dst); @@ -403,10 +402,12 @@ int gras_datadesc_memcpy(gras_datadesc_type_t type, void *src, void *dst) size = gras_datadesc_memcpy_rec(state, refs, type, (char *) src, (char *) dst, 0, type->cycle); - } TRY_CLEANUP { + } + TRY_CLEANUP { xbt_dict_reset(refs); gras_cbps_reset(state); - } CATCH(e) { + } + CATCH_ANONYMOUS { RETHROW; } return size; @@ -449,7 +450,7 @@ gras_datadesc_send_rec(gras_socket_t sock, char *field_data; struct_data = type->category.struct_data; - xbt_assert1(struct_data.closed, + xbt_assert(struct_data.closed, "Please call gras_datadesc_declare_struct_close on %s before sending it", type->name); XBT_VERB(">> Send all fields of the structure %s", type->name); @@ -481,17 +482,17 @@ gras_datadesc_send_rec(gras_socket_t sock, union_data = type->category.union_data; - xbt_assert1(union_data.closed, + xbt_assert(union_data.closed, "Please call gras_datadesc_declare_union_close on %s before sending it", type->name); /* retrieve the field number */ field_num = union_data.selector(type, state, data); - xbt_assert1(field_num > 0, + xbt_assert(field_num > 0, "union field selector of %s gave a negative value", type->name); - xbt_assert3(field_num < xbt_dynar_length(union_data.fields), + xbt_assert(field_num < xbt_dynar_length(union_data.fields), "union field selector of %s returned %d but there is only %lu fields", type->name, field_num, xbt_dynar_length(union_data.fields)); @@ -579,7 +580,7 @@ gras_datadesc_send_rec(gras_socket_t sock, count = array_data.fixed_size; if (count == -1) { count = array_data.dynamic_size(type, state, data); - xbt_assert1(count >= 0, + xbt_assert(count >= 0, "Invalid (negative) array size for type %s", type->name); gras_dd_send_int(sock, &count, 0 /*non-stable */ ); @@ -630,12 +631,10 @@ gras_datadesc_send_rec(gras_socket_t sock, void gras_datadesc_send(gras_socket_t sock, gras_datadesc_type_t type, void *src) { - - xbt_ex_t e; static gras_cbps_t state = NULL; static xbt_dict_t refs = NULL; /* all references already sent */ - xbt_assert0(type, "called with NULL type descriptor"); + xbt_assert(type, "called with NULL type descriptor"); if (!state) { state = gras_cbps_new(); @@ -645,10 +644,12 @@ void gras_datadesc_send(gras_socket_t sock, TRY { gras_datadesc_send_rec(sock, state, refs, type, (char *) src, type->cycle); - } TRY_CLEANUP { + } + TRY_CLEANUP { xbt_dict_reset(refs); gras_cbps_reset(state); - } CATCH(e) { + } + CATCH_ANONYMOUS { RETHROW; } } @@ -704,7 +705,7 @@ gras_datadesc_recv_rec(gras_socket_t sock, struct_data = type->category.struct_data; - xbt_assert1(struct_data.closed, + xbt_assert(struct_data.closed, "Please call gras_datadesc_declare_struct_close on %s before receiving it", type->name); XBT_VERB(">> Receive all fields of the structure %s", type->name); @@ -736,7 +737,7 @@ gras_datadesc_recv_rec(gras_socket_t sock, union_data = type->category.union_data; - xbt_assert1(union_data.closed, + xbt_assert(union_data.closed, "Please call gras_datadesc_declare_union_close on %s before receiving it", type->name); /* retrieve the field number */ @@ -970,8 +971,6 @@ void gras_datadesc_recv(gras_socket_t sock, gras_datadesc_type_t type, int r_arch, void *dst) { - - xbt_ex_t e; static gras_cbps_t state = NULL; /* callback persistent state */ static xbt_dict_t refs = NULL; /* all references already sent */ @@ -980,14 +979,16 @@ gras_datadesc_recv(gras_socket_t sock, refs = xbt_dict_new(); } - xbt_assert0(type, "called with NULL type descriptor"); + xbt_assert(type, "called with NULL type descriptor"); TRY { gras_datadesc_recv_rec(sock, state, refs, type, r_arch, NULL, 0, (char *) dst, -1, type->cycle); - } TRY_CLEANUP { + } + TRY_CLEANUP { xbt_dict_reset(refs); gras_cbps_reset(state); - } CATCH(e) { + } + CATCH_ANONYMOUS { RETHROW; } }