2828#include <getopt.h>
2929#include <time.h>
3030#include "pdc.h"
31+ #include "pdc_client_connect.h"
32+ #include "dart_core.h"
33+ #include "string_utils.h"
3134#include "test_helper.h"
3235
3336int
@@ -99,7 +102,7 @@ main(int argc, char *argv[])
99102 if (argc < 5 ) {
100103 if (rank == 0 )
101104 print_usage (argv [0 ]);
102- PGOTO_DONE (ret_value );
105+ TGOTO_DONE (ret_value );
103106 }
104107 n_obj = atoi (argv [1 ]);
105108 round = atoi (argv [2 ]);
@@ -155,9 +158,9 @@ main(int argc, char *argv[])
155158 if (is_using_dart &&
156159 PDC_Client_insert_obj_ref_into_dart (hash_algo , kvtag .name , value , strlen (value ), PDC_STRING ,
157160 ref_type , (uint64_t )obj_ids [i ]) < 0 )
158- PGOTO_ERROR (FAIL , "Failed to add a kvtag to o%d\n" , i + my_obj_s );
161+ TGOTO_ERROR (FAIL , "Failed to add a kvtag to o%d\n" , i + my_obj_s );
159162 else if (PDCobj_put_tag (obj_ids [i ], kvtag .name , kvtag .value , kvtag .type , kvtag .size ) < 0 )
160- PGOTO_ERROR (FAIL , "Failed to add a kvtag to o%d\n" , i + my_obj_s );
163+ TGOTO_ERROR (FAIL , "Failed to add a kvtag to o%d\n" , i + my_obj_s );
161164 }
162165 if (rank == 0 )
163166 LOG_JUST_PRINT ("Rank %d: Added %d kvtag to the %d th object\n" , rank , round , i );
@@ -189,7 +192,7 @@ main(int argc, char *argv[])
189192 if (PDC_Client_search_obj_ref_through_dart (hash_algo , exact_query , ref_type , & nres , & pdc_ids ) <
190193 0 ) {
191194#endif
192- PGOTO_ERROR (TFAIL , "Failed to PDC_Client_search_obj_ref_through_dart_mpi\n" , kvtag .name ,
195+ TGOTO_ERROR (TFAIL , "Failed to PDC_Client_search_obj_ref_through_dart_mpi\n" , kvtag .name ,
193196 rank );
194197 }
195198 }
@@ -199,7 +202,7 @@ main(int argc, char *argv[])
199202#else
200203 if (PDC_Client_query_kvtag (& kvtag , & nres , & pdc_ids ) < 0 ) {
201204#endif
202- PGOTO_ERROR (TFAIL , "Failed to query kvtag [%s] with rank %d\n" , kvtag .name , rank );
205+ TGOTO_ERROR (TFAIL , "Failed to query kvtag [%s] with rank %d\n" , kvtag .name , rank );
203206 }
204207 }
205208 }
0 commit comments