X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/320c1fe541f529573238ebba0bee1ec0293f1af4..fa2e5b6995eb1572c4534259eea4197b3b618db9:/testsuite/gras/datadesc_usage.c diff --git a/testsuite/gras/datadesc_usage.c b/testsuite/gras/datadesc_usage.c index 50dcf4084d..bf5d90ddd3 100644 --- a/testsuite/gras/datadesc_usage.c +++ b/testsuite/gras/datadesc_usage.c @@ -2,17 +2,16 @@ /* datadesc: test of data description (using file transport). */ -/* Authors: Martin Quinson */ -/* Copyright (C) 2004 the OURAGAN project. */ +/* Copyright (c) 2004 Martin Quinson. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it - under the terms of the license (GNU LGPL) which comes with this package. */ + * under the terms of the license (GNU LGPL) which comes with this package. */ #include -#include +#include "gras.h" #include "gras/DataDesc/datadesc_interface.h" -GRAS_LOG_NEW_DEFAULT_CATEGORY(test); +XBT_LOG_NEW_DEFAULT_CATEGORY(test,"Logging specific to this test"); #define READ 0 #define WRITE 1 @@ -21,20 +20,21 @@ GRAS_LOG_NEW_DEFAULT_CATEGORY(test); int r_arch; const char *filename = "datadesc_usage.out"; -gras_error_t -write_read(gras_datadesc_type_t *type,void *src, void *dst, - gras_socket_t *sock, int direction); +xbt_error_t +write_read(gras_datadesc_type_t type,void *src, void *dst, + gras_socket_t sock, int direction); -gras_error_t -write_read(gras_datadesc_type_t *type,void *src, void *dst, - gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t +write_read(gras_datadesc_type_t type,void *src, void *dst, + gras_socket_t sock, int direction) { + xbt_error_t errcode; /* write */ if (direction == RW) TRY(gras_socket_client_from_file(filename,&sock)); if (direction == WRITE || direction == RW) TRY(gras_datadesc_send(sock, type, src)); +/* TRY(gras_datadesc_gen_send(sock, type, src));*/ if (direction == RW) gras_socket_close(sock); @@ -51,66 +51,68 @@ write_read(gras_datadesc_type_t *type,void *src, void *dst, return no_error; } -gras_error_t test_int(gras_socket_t *sock, int direction); -gras_error_t test_float(gras_socket_t *sock, int direction); -gras_error_t test_double(gras_socket_t *sock, int direction); -gras_error_t test_array(gras_socket_t *sock, int direction); -gras_error_t test_intref(gras_socket_t *sock, int direction); -gras_error_t test_string(gras_socket_t *sock, int direction); +xbt_error_t test_int(gras_socket_t sock, int direction); +xbt_error_t test_float(gras_socket_t sock, int direction); +xbt_error_t test_double(gras_socket_t sock, int direction); +xbt_error_t test_array(gras_socket_t sock, int direction); +xbt_error_t test_dynar_scal(gras_socket_t sock, int direction); +xbt_error_t test_intref(gras_socket_t sock, int direction); +xbt_error_t test_string(gras_socket_t sock, int direction); -gras_error_t test_homostruct(gras_socket_t *sock, int direction); -gras_error_t test_hetestruct(gras_socket_t *sock, int direction); -gras_error_t test_nestedstruct(gras_socket_t *sock, int direction); -gras_error_t test_chain_list(gras_socket_t *sock, int direction); -gras_error_t test_graph(gras_socket_t *sock, int direction); +xbt_error_t test_homostruct(gras_socket_t sock, int direction); +xbt_error_t test_hetestruct(gras_socket_t sock, int direction); +xbt_error_t test_nestedstruct(gras_socket_t sock, int direction); +xbt_error_t test_chain_list(gras_socket_t sock, int direction); +xbt_error_t test_graph(gras_socket_t sock, int direction); +xbt_error_t test_dynar_ref(gras_socket_t sock, int direction); -gras_error_t test_pbio(gras_socket_t *sock, int direction); -gras_error_t test_clause(gras_socket_t *sock, int direction); +xbt_error_t test_pbio(gras_socket_t sock, int direction); +xbt_error_t test_clause(gras_socket_t sock, int direction); /* defined in datadesc_structures.c, which in perl generated */ -gras_error_t test_structures(gras_socket_t *sock, int direction); +xbt_error_t test_structures(gras_socket_t sock, int direction); -gras_error_t test_int(gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t test_int(gras_socket_t sock, int direction) { + xbt_error_t errcode; int i=5,j; INFO0("---- Test on integer ----"); TRY(write_read(gras_datadesc_by_name("int"), &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(i == j); + xbt_assert(i == j); } return no_error; } -gras_error_t test_float(gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t test_float(gras_socket_t sock, int direction) { + xbt_error_t errcode; float i=5.0,j; INFO0("---- Test on float ----"); TRY(write_read(gras_datadesc_by_name("float"), &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert2(i == j,"%f != %f",i,j); + xbt_assert2(i == j,"%f != %f",i,j); } return no_error; } -gras_error_t test_double(gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t test_double(gras_socket_t sock, int direction) { + xbt_error_t errcode; double i=-3252355.1234,j; INFO0("---- Test on double ----"); TRY(write_read(gras_datadesc_by_name("double"), &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert2(i == j,"%f != %f",i,j); + xbt_assert2(i == j,"%f != %f",i,j); } return no_error; } #define SIZE 5 typedef int array[SIZE]; -gras_error_t test_array(gras_socket_t *sock, int direction) { - gras_error_t errcode; - gras_datadesc_type_t *my_type; +xbt_error_t test_array(gras_socket_t sock, int direction) { + xbt_error_t errcode; + gras_datadesc_type_t my_type; array i = { 35212,-6226,74337,11414,7733}; array j; @@ -118,36 +120,68 @@ gras_error_t test_array(gras_socket_t *sock, int direction) { INFO0("---- Test on fixed array ----"); - TRY(gras_datadesc_array_fixed("fixed int array", - gras_datadesc_by_name("int"), - SIZE, &my_type)); + my_type=gras_datadesc_array_fixed("fixed int array", + gras_datadesc_by_name("int"), + SIZE); TRY(write_read(my_type, &i,&j, sock,direction)); if (direction == READ || direction == RW) { for (cpt=0; cpta = 2235; i->b = 433425; i->c = -23423; i->d = -235235; TRY(write_read(my_type, &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(i->a == j->a); - gras_assert(i->b == j->b); - gras_assert(i->c == j->c); - gras_assert(i->d == j->d); + xbt_assert2(i->a == j->a,"i->a=%d != j->a=%d",i->a,j->a); + xbt_assert(i->b == j->b); + xbt_assert(i->c == j->c); + xbt_assert(i->d == j->d); free(j); } free(i); @@ -231,38 +263,37 @@ typedef struct { unsigned char c2; unsigned long int l2; } hetestruct; -gras_error_t test_hetestruct(gras_socket_t *sock, int direction) { - gras_error_t errcode; - gras_datadesc_type_t *my_type; +xbt_error_t test_hetestruct(gras_socket_t sock, int direction) { + xbt_error_t errcode; + gras_datadesc_type_t my_type; hetestruct *i, *j; INFO0("---- Test on heterogeneous structure ----"); /* create descriptor */ - TRY(gras_datadesc_struct("hetestruct",&my_type)); - TRY(gras_datadesc_struct_append(my_type,"c1", - gras_datadesc_by_name("unsigned char"))); - TRY(gras_datadesc_struct_append(my_type,"l1", - gras_datadesc_by_name("unsigned long int"))); - TRY(gras_datadesc_struct_append(my_type,"c2", - gras_datadesc_by_name("unsigned char"))); - TRY(gras_datadesc_struct_append(my_type,"l2", - gras_datadesc_by_name("unsigned long int"))); + my_type=gras_datadesc_struct("hetestruct"); + gras_datadesc_struct_append(my_type,"c1", + gras_datadesc_by_name("unsigned char")); + gras_datadesc_struct_append(my_type,"l1", + gras_datadesc_by_name("unsigned long int")); + gras_datadesc_struct_append(my_type,"c2", + gras_datadesc_by_name("unsigned char")); + gras_datadesc_struct_append(my_type,"l2", + gras_datadesc_by_name("unsigned long int")); gras_datadesc_struct_close(my_type); - TRY(gras_datadesc_ref("hetestruct*", gras_datadesc_by_name("hetestruct"), - &my_type)); + my_type=gras_datadesc_ref("hetestruct*", gras_datadesc_by_name("hetestruct")); + /* init a value, exchange it and check its validity*/ - if (! (i=malloc(sizeof(hetestruct))) ) - RAISE_MALLOC; + i=xbt_new(hetestruct,1); i->c1 = 's'; i->l1 = 123455; i->c2 = 'e'; i->l2 = 774531; TRY(write_read(my_type, &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(i->c1 == j->c1); - gras_assert(i->c2 == j->c2); - gras_assert2(i->l1 == j->l1,"i->l1(=%ld) != j->l1(=%ld)",i->l1,j->l1); - gras_assert(i->l2 == j->l2); + xbt_assert(i->c1 == j->c1); + xbt_assert(i->c2 == j->c2); + xbt_assert2(i->l1 == j->l1,"i->l1(=%ld) != j->l1(=%ld)",i->l1,j->l1); + xbt_assert(i->l2 == j->l2); free(j); } free(i); @@ -276,26 +307,24 @@ typedef struct { hetestruct hete; homostruct homo; } nestedstruct; -gras_error_t test_nestedstruct(gras_socket_t *sock, int direction) { - gras_error_t errcode; - gras_datadesc_type_t *my_type; +xbt_error_t test_nestedstruct(gras_socket_t sock, int direction) { + xbt_error_t errcode; + gras_datadesc_type_t my_type; nestedstruct *i, *j; INFO0("---- Test on nested structures ----"); /* create descriptor */ - TRY(gras_datadesc_struct("nestedstruct",&my_type)); + my_type=gras_datadesc_struct("nestedstruct"); - TRY(gras_datadesc_struct_append(my_type,"hete", - gras_datadesc_by_name("hetestruct"))); - TRY(gras_datadesc_struct_append(my_type,"homo", - gras_datadesc_by_name("homostruct"))); + gras_datadesc_struct_append(my_type,"hete", + gras_datadesc_by_name("hetestruct")); + gras_datadesc_struct_append(my_type,"homo", + gras_datadesc_by_name("homostruct")); gras_datadesc_struct_close(my_type); - TRY(gras_datadesc_ref("nestedstruct*", gras_datadesc_by_name("nestedstruct"), - &my_type)); + my_type=gras_datadesc_ref("nestedstruct*", gras_datadesc_by_name("nestedstruct")); /* init a value, exchange it and check its validity*/ - if (! (i=malloc(sizeof(nestedstruct))) ) - RAISE_MALLOC; + i=xbt_new(nestedstruct,1); i->homo.a = 235231; i->homo.b = -124151; i->homo.c = 211551; i->homo.d = -664222; i->hete.c1 = 's'; i->hete.l1 = 123455; @@ -303,14 +332,14 @@ gras_error_t test_nestedstruct(gras_socket_t *sock, int direction) { TRY(write_read(my_type, &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(i->homo.a == j->homo.a); - gras_assert(i->homo.b == j->homo.b); - gras_assert(i->homo.c == j->homo.c); - gras_assert(i->homo.d == j->homo.d); - gras_assert(i->hete.c1 == j->hete.c1); - gras_assert(i->hete.c2 == j->hete.c2); - gras_assert(i->hete.l1 == j->hete.l1); - gras_assert(i->hete.l2 == j->hete.l2); + xbt_assert(i->homo.a == j->homo.a); + xbt_assert(i->homo.b == j->homo.b); + xbt_assert(i->homo.c == j->homo.c); + xbt_assert(i->homo.d == j->homo.d); + xbt_assert(i->hete.c1 == j->hete.c1); + xbt_assert(i->hete.c2 == j->hete.c2); + xbt_assert(i->hete.l1 == j->hete.l1); + xbt_assert(i->hete.l2 == j->hete.l2); free(j); } free(i); @@ -325,27 +354,27 @@ struct s_chained_list { int v; chained_list_t *l; }; -gras_error_t declare_chained_list_type(void); +xbt_error_t declare_chained_list_type(void); chained_list_t *cons(int v, chained_list_t *l); void list_free(chained_list_t *l); int list_eq(chained_list_t*i,chained_list_t*j); -gras_error_t declare_chained_list_type(void) { - gras_error_t errcode; - gras_datadesc_type_t *my_type,*ref_my_type; +xbt_error_t declare_chained_list_type(void) { + xbt_error_t errcode; + gras_datadesc_type_t my_type,ref_my_type; - TRY(gras_datadesc_struct("chained_list_t",&my_type)); - TRY(gras_datadesc_ref("chained_list_t*",my_type,&ref_my_type)); + my_type=gras_datadesc_struct("chained_list_t"); + ref_my_type=gras_datadesc_ref("chained_list_t*",my_type); - TRY(gras_datadesc_struct_append(my_type,"v", gras_datadesc_by_name("int"))); - TRY(gras_datadesc_struct_append(my_type,"l", ref_my_type)); + gras_datadesc_struct_append(my_type,"v", gras_datadesc_by_name("int")); + gras_datadesc_struct_append(my_type,"l", ref_my_type); gras_datadesc_struct_close(my_type); return no_error; } chained_list_t * cons(int v, chained_list_t *l) { - chained_list_t *nl = malloc(sizeof (chained_list_t)); + chained_list_t *nl = xbt_new(chained_list_t,1); nl->v = v; nl->l = l; @@ -364,8 +393,8 @@ int list_eq(chained_list_t*i,chained_list_t*j) { return 0; return list_eq(i->l, j->l); } -gras_error_t test_chain_list(gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t test_chain_list(gras_socket_t sock, int direction) { + xbt_error_t errcode; chained_list_t *i, *j; INFO0("---- Test on chained list ----"); @@ -378,7 +407,7 @@ gras_error_t test_chain_list(gras_socket_t *sock, int direction) { &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(list_eq(i,j)); + xbt_assert(list_eq(i,j)); list_free(j); } @@ -388,8 +417,8 @@ gras_error_t test_chain_list(gras_socket_t *sock, int direction) { /*** *** graph ***/ -gras_error_t test_graph(gras_socket_t *sock, int direction) { - gras_error_t errcode; +xbt_error_t test_graph(gras_socket_t sock, int direction) { + xbt_error_t errcode; chained_list_t *i, *j; INFO0("---- Test on graph (cyclique chained list) ----"); @@ -398,6 +427,7 @@ gras_error_t test_graph(gras_socket_t *sock, int direction) { i->l->l->l = i; j = NULL; + gras_datadesc_cycle_set(gras_datadesc_by_name("chained_list_t*")); TRY(write_read(gras_datadesc_by_name("chained_list_t*"), &i,&j, sock,direction)); if (direction == READ || direction == RW) { @@ -410,14 +440,14 @@ gras_error_t test_graph(gras_socket_t *sock, int direction) { DEBUG1("j->l=%p" ,j->l); DEBUG1("j->l->l=%p" ,j->l->l); DEBUG1("j->l->l->l=%p",j->l->l->l); - gras_assert4(j->l->l->l == j, + xbt_assert4(j->l->l->l == j, "Received list is not cyclic. j=%p != j->l->l->l=%p\n" "j=%p; &j=%p", j,j->l->l->l, j ,&j); j->l->l->l = NULL; i->l->l->l = NULL; - gras_assert(list_eq(i,j)); + xbt_assert(list_eq(i,j)); list_free(j); } @@ -426,6 +456,47 @@ gras_error_t test_graph(gras_socket_t *sock, int direction) { return no_error; } + +/*** Dynar of references ***/ +static void free_string(void *d){ /* used to free the data in dynar */ + free(*(void**)d); +} +xbt_error_t test_dynar_ref(gras_socket_t sock, int direction){ + xbt_error_t errcode; + gras_datadesc_type_t my_type; + xbt_dynar_t i,j; + char buf[1024]; + char *s1,*s2; + int cpt; + + INFO0("---- Test on dynar containing integers ----"); + my_type = gras_datadesc_dynar(gras_datadesc_by_name("string"),&free_string); + + i=xbt_dynar_new(sizeof(char*),&free_string); + for (cpt=0; cpt< 64; cpt++) { + sprintf(buf,"%d",cpt); + s1=strdup(buf); + xbt_dynar_push(i,&s1); + } + + TRY(write_read(my_type, &i,&j, sock, direction)); + if (direction == READ || direction == RW) { + for (cpt=0; cpt< 64; cpt++) { + sprintf(buf,"%d",cpt); + xbt_dynar_shift(j,&s2); + xbt_assert2 (!strcmp(buf,s2), + "The retrieved value is not the same than the injected one (%s!=%s)", + buf,s2); + free(s2); + } + xbt_dynar_free(&j); + } + xbt_dynar_free(&i); + + return no_error; +} + + /**** PBIO *****/ GRAS_DEFINE_TYPE(s_pbio, struct s_pbio{ /* structure presented in the IEEE article */ @@ -447,12 +518,12 @@ struct s_pbio{ /* structure presented in the IEEE article */ ) typedef struct s_pbio pbio_t; -gras_error_t test_pbio(gras_socket_t *sock, int direction) { - gras_error_t errcode; - pbio_t i,j; +xbt_error_t test_pbio(gras_socket_t sock, int direction) { + xbt_error_t errcode; int cpt; int cpt2; - gras_datadesc_type_t *pbio_type; + gras_datadesc_type_t pbio_type; + pbio_t i, j; INFO0("---- Test on the PBIO IEEE struct (also tests GRAS DEFINE TYPE) ----"); pbio_type = gras_datadesc_by_symbol(s_pbio); @@ -488,30 +559,32 @@ gras_error_t test_pbio(gras_socket_t *sock, int direction) { &i,&j, sock,direction)); if (direction == READ || direction == RW) { /* Check that the data match */ - gras_assert(i.Cnstatv == j.Cnstatv); + xbt_assert(i.Cnstatv == j.Cnstatv); for (cpt=0; cpt<12; cpt++) - gras_assert(i.Cstatev[cpt] == j.Cstatev[cpt]); - gras_assert(i.Cnprops == j.Cnprops); + xbt_assert4(i.Cstatev[cpt] == j.Cstatev[cpt], + "i.Cstatev[%d] (=%f) != j.Cstatev[%d] (=%f)", + cpt,i.Cstatev[cpt],cpt,j.Cstatev[cpt]); + xbt_assert(i.Cnprops == j.Cnprops); for (cpt=0; cpt<110; cpt++) - gras_assert(i.Cprops[cpt] == j.Cprops[cpt]); + xbt_assert(i.Cprops[cpt] == j.Cprops[cpt]); for (cpt=0; cpt<4; cpt++) - gras_assert(i.Cndi[cpt] == j.Cndi[cpt]); - gras_assert(i.Cnshr == j.Cnshr); - gras_assert(i.Cnpt == j.Cnpt); - gras_assert(i.Cdtime == j.Cdtime); - gras_assert(i.Ctime[0] == j.Ctime[0]); - gras_assert(i.Ctime[1] == j.Ctime[1]); - gras_assert(i.Cntens == j.Cntens); + xbt_assert(i.Cndi[cpt] == j.Cndi[cpt]); + xbt_assert(i.Cnshr == j.Cnshr); + xbt_assert(i.Cnpt == j.Cnpt); + xbt_assert(i.Cdtime == j.Cdtime); + xbt_assert(i.Ctime[0] == j.Ctime[0]); + xbt_assert(i.Ctime[1] == j.Ctime[1]); + xbt_assert(i.Cntens == j.Cntens); for (cpt=0; cpt<3; cpt++) { for (cpt2=0; cpt2<373; cpt2++) - gras_assert(i.Cdfgrd0[cpt2][cpt] == j.Cdfgrd0[cpt2][cpt]); + xbt_assert(i.Cdfgrd0[cpt2][cpt] == j.Cdfgrd0[cpt2][cpt]); for (cpt2=0; cpt2<3; cpt2++) - gras_assert(i.Cdfgrd1[cpt][cpt2] == j.Cdfgrd1[cpt][cpt2]); + xbt_assert(i.Cdfgrd1[cpt][cpt2] == j.Cdfgrd1[cpt][cpt2]); } for (cpt=0; cpt<106; cpt++) { - gras_assert(i.Cstress[cpt] == j.Cstress[cpt]); + xbt_assert(i.Cstress[cpt] == j.Cstress[cpt]); for (cpt2=0; cpt2<106; cpt2++) - gras_assert4(i.Cddsdde[cpt][cpt2] == j.Cddsdde[cpt][cpt2], + xbt_assert4(i.Cddsdde[cpt][cpt2] == j.Cddsdde[cpt][cpt2], "%f=i.Cddsdde[%d][%d] != j.Cddsdde[cpt][cpt2]=%f", i.Cddsdde[cpt][cpt2],cpt,cpt2,j.Cddsdde[cpt][cpt2]); } @@ -527,21 +600,19 @@ struct s_clause { };) typedef struct s_clause Clause; -gras_error_t test_clause(gras_socket_t *sock, int direction) { - gras_error_t errcode; - gras_datadesc_type_t *ddt,*array_t; +xbt_error_t test_clause(gras_socket_t sock, int direction) { + xbt_error_t errcode; + gras_datadesc_type_t ddt,array_t; Clause *i,*j; int cpt; INFO0("---- Test on struct containing dynamic array and its size (cbps test) ----"); /* create and fill the struct */ - if (! (i=malloc(sizeof(Clause))) ) - RAISE_MALLOC; + i=xbt_new(Clause,1); i->num_lits = 5432; - if (! (i->literals = malloc(sizeof(int) * i->num_lits)) ) - RAISE_MALLOC; + i->literals = xbt_new(int, i->num_lits); for (cpt=0; cptnum_lits; cpt++) i->literals[cpt] = cpt * cpt - ((cpt * cpt) / 2); DEBUG3("created data=%p (within %p @%p)",&(i->num_lits),i,&i); @@ -549,15 +620,15 @@ gras_error_t test_clause(gras_socket_t *sock, int direction) { /* create the damn type descriptor */ ddt = gras_datadesc_by_symbol(s_clause); -// gras_datadesc_type_dump(ddt); +/* gras_datadesc_type_dump(ddt); */ - TRYFAIL(gras_datadesc_ref("Clause*",ddt,&ddt)); + ddt=gras_datadesc_ref("Clause*",ddt); TRY(write_read(ddt, &i,&j, sock,direction)); if (direction == READ || direction == RW) { - gras_assert(i->num_lits == j->num_lits); + xbt_assert(i->num_lits == j->num_lits); for (cpt=0; cptnum_lits; cpt++) - gras_assert(i->literals[cpt] == j->literals[cpt]); + xbt_assert(i->literals[cpt] == j->literals[cpt]); free(j->literals); free(j); @@ -568,13 +639,13 @@ gras_error_t test_clause(gras_socket_t *sock, int direction) { } int main(int argc,char *argv[]) { - gras_error_t errcode; - gras_socket_t *sock; + xbt_error_t errcode; + gras_socket_t sock; int direction = RW; int cpt; char r_arch_char = gras_arch_selfid(); - gras_init_defaultlog(&argc,argv,NULL); + gras_init(&argc,argv,NULL); for (cpt=1; cpt