@@ -120,10 +120,10 @@ pdcid_t
120
120
PDC_obj_create (pdcid_t cont_id , const char * obj_name , pdcid_t obj_prop_id , _pdc_obj_location_t location )
121
121
{
122
122
pdcid_t ret_value = 0 ;
123
- struct _pdc_obj_info * p = NULL ;
124
- struct _pdc_id_info * id_info = NULL ;
123
+ struct _pdc_obj_info * p = NULL ;
124
+ struct _pdc_id_info * id_info = NULL ;
125
125
struct _pdc_cont_info * cont_info = NULL ;
126
- struct _pdc_obj_prop * obj_prop ;
126
+ struct _pdc_obj_prop * obj_prop ;
127
127
uint64_t meta_id ;
128
128
uint32_t data_server_id , metadata_server_id ;
129
129
size_t i ;
@@ -281,7 +281,7 @@ perr_t
281
281
PDC_obj_close (struct _pdc_obj_info * op )
282
282
{
283
283
perr_t ret_value = SUCCEED ;
284
- pdcid_t * transfer_request_id ;
284
+ pdcid_t * transfer_request_id ;
285
285
pdc_local_transfer_request * temp , * previous ;
286
286
int i , n ;
287
287
@@ -409,12 +409,12 @@ PDCobj_open_common(const char *obj_name, pdcid_t pdc, int is_col)
409
409
pdcid_t ret_value = 0 ;
410
410
perr_t ret = SUCCEED ;
411
411
struct _pdc_obj_info * p = NULL ;
412
- pdc_metadata_t * out = NULL ;
412
+ pdc_metadata_t * out = NULL ;
413
413
pdcid_t obj_prop ;
414
414
size_t i ;
415
415
uint32_t metadata_server_id ;
416
- obj_handle * oh ;
417
- struct pdc_obj_info * info ;
416
+ obj_handle * oh ;
417
+ struct pdc_obj_info * info ;
418
418
int is_opened = 0 ;
419
419
420
420
FUNC_ENTER (NULL );
@@ -431,9 +431,8 @@ PDCobj_open_common(const char *obj_name, pdcid_t pdc, int is_col)
431
431
}
432
432
433
433
if (is_opened ) {
434
- ret_value = info -> local_id ;
435
434
PDC_inc_ref (info -> local_id );
436
- goto done ;
435
+ PGOTO_DONE ( info -> local_id ) ;
437
436
}
438
437
439
438
p = (struct _pdc_obj_info * )PDC_malloc (sizeof (struct _pdc_obj_info ));
@@ -557,8 +556,8 @@ PDCobj_open_col(const char *obj_name, pdcid_t pdc)
557
556
obj_handle *
558
557
PDCobj_iter_start (pdcid_t cont_id )
559
558
{
560
- obj_handle * ret_value = NULL ;
561
- obj_handle * objhl = NULL ;
559
+ obj_handle * ret_value = NULL ;
560
+ obj_handle * objhl = NULL ;
562
561
struct PDC_id_type * type_ptr ;
563
562
564
563
FUNC_ENTER (NULL );
@@ -618,7 +617,7 @@ PDCobj_iter_next(obj_handle *ohandle, pdcid_t cont_id)
618
617
struct pdc_obj_info *
619
618
PDCobj_iter_get_info (obj_handle * ohandle )
620
619
{
621
- struct pdc_obj_info * ret_value = NULL ;
620
+ struct pdc_obj_info * ret_value = NULL ;
622
621
struct _pdc_obj_info * info = NULL ;
623
622
unsigned i ;
624
623
@@ -748,7 +747,7 @@ perr_t
748
747
PDCprop_set_obj_dims (pdcid_t obj_prop , PDC_int_t ndim , uint64_t * dims )
749
748
{
750
749
perr_t ret_value = SUCCEED ;
751
- struct _pdc_id_info * info ;
750
+ struct _pdc_id_info * info ;
752
751
struct _pdc_obj_prop * prop ;
753
752
754
753
FUNC_ENTER (NULL );
@@ -776,7 +775,7 @@ perr_t
776
775
PDCprop_set_obj_type (pdcid_t obj_prop , pdc_var_type_t type )
777
776
{
778
777
perr_t ret_value = SUCCEED ;
779
- struct _pdc_id_info * info ;
778
+ struct _pdc_id_info * info ;
780
779
struct _pdc_obj_prop * prop ;
781
780
782
781
FUNC_ENTER (NULL );
@@ -795,7 +794,7 @@ perr_t
795
794
PDCprop_set_obj_transfer_region_type (pdcid_t obj_prop , pdc_region_partition_t region_partition )
796
795
{
797
796
perr_t ret_value = SUCCEED ;
798
- struct _pdc_id_info * info ;
797
+ struct _pdc_id_info * info ;
799
798
struct _pdc_obj_prop * prop ;
800
799
801
800
FUNC_ENTER (NULL );
@@ -814,7 +813,7 @@ perr_t
814
813
PDCprop_set_obj_consistency_semantics (pdcid_t obj_prop , pdc_consistency_t consistency )
815
814
{
816
815
perr_t ret_value = SUCCEED ;
817
- struct _pdc_id_info * info ;
816
+ struct _pdc_id_info * info ;
818
817
struct _pdc_obj_prop * prop ;
819
818
820
819
FUNC_ENTER (NULL );
@@ -833,7 +832,7 @@ perr_t
833
832
PDCprop_set_obj_buf (pdcid_t obj_prop , void * buf )
834
833
{
835
834
perr_t ret_value = SUCCEED ;
836
- struct _pdc_id_info * info ;
835
+ struct _pdc_id_info * info ;
837
836
struct _pdc_obj_prop * prop ;
838
837
839
838
FUNC_ENTER (NULL );
@@ -852,7 +851,7 @@ perr_t
852
851
PDCobj_set_dims (pdcid_t obj_id , int ndim , uint64_t * dims )
853
852
{
854
853
perr_t ret_value = SUCCEED ;
855
- struct _pdc_id_info * info ;
854
+ struct _pdc_id_info * info ;
856
855
struct _pdc_obj_info * object ;
857
856
int reset ;
858
857
@@ -864,8 +863,7 @@ PDCobj_set_dims(pdcid_t obj_id, int ndim, uint64_t *dims)
864
863
object = (struct _pdc_obj_info * )(info -> obj_ptr );
865
864
if (object -> local_transfer_request_size ) {
866
865
// We do not allow setting obj dims while the region transfer requests are taking places.
867
- ret_value = FAIL ;
868
- goto done ;
866
+ PGOTO_ERROR (FAIL , "Attempt to set obj dims while a region transfer request was taking place" );
869
867
}
870
868
871
869
if (ndim != (int )((pdc_metadata_t * )(object -> metadata ))-> ndim ) {
@@ -879,7 +877,7 @@ PDCobj_set_dims(pdcid_t obj_id, int ndim, uint64_t *dims)
879
877
880
878
if (!reset ) {
881
879
// Server rejects reset object dims for some reasons, so we close this operation.
882
- ret_value = FAIL ;
880
+ PGOTO_DONE ( FAIL ) ;
883
881
}
884
882
885
883
done :
@@ -890,7 +888,7 @@ perr_t
890
888
PDCobj_get_dims (pdcid_t obj_id , int * ndim , uint64_t * * dims )
891
889
{
892
890
perr_t ret_value = SUCCEED ;
893
- struct _pdc_id_info * info ;
891
+ struct _pdc_id_info * info ;
894
892
struct _pdc_obj_info * object ;
895
893
FUNC_ENTER (NULL );
896
894
@@ -909,10 +907,10 @@ PDCobj_get_dims(pdcid_t obj_id, int *ndim, uint64_t **dims)
909
907
void * *
910
908
PDCobj_buf_retrieve (pdcid_t obj_id )
911
909
{
912
- void * * ret_value = NULL ;
913
- struct _pdc_id_info * info ;
910
+ void * * ret_value = NULL ;
911
+ struct _pdc_id_info * info ;
914
912
struct _pdc_obj_info * object ;
915
- void * * buffer ;
913
+ void * * buffer ;
916
914
917
915
FUNC_ENTER (NULL );
918
916
info = PDC_find_id (obj_id );
@@ -931,7 +929,7 @@ PDC_obj_get_info(pdcid_t obj_id)
931
929
{
932
930
struct _pdc_obj_info * ret_value = NULL ;
933
931
struct _pdc_obj_info * info = NULL ;
934
- struct _pdc_id_info * obj ;
932
+ struct _pdc_id_info * obj ;
935
933
size_t i ;
936
934
937
935
FUNC_ENTER (NULL );
@@ -1112,7 +1110,7 @@ PDC_free_obj_info(struct _pdc_obj_info *obj)
1112
1110
struct pdc_obj_info *
1113
1111
PDCobj_get_info (pdcid_t obj_id )
1114
1112
{
1115
- struct pdc_obj_info * ret_value = NULL ;
1113
+ struct pdc_obj_info * ret_value = NULL ;
1116
1114
struct _pdc_obj_info * tmp = NULL ;
1117
1115
/* pdcid_t obj_id; */
1118
1116
0 commit comments