@@ -78,8 +78,9 @@ void opal_convertor_destroy_masters(void)
78
78
master -> next = NULL ;
79
79
/* Cleanup the conversion function if not one of the defaults */
80
80
if ((master -> pFunctions != opal_datatype_heterogeneous_copy_functions )
81
- && (master -> pFunctions != opal_datatype_copy_functions ))
81
+ && (master -> pFunctions != opal_datatype_copy_functions )) {
82
82
free (master -> pFunctions );
83
+ }
83
84
84
85
free (master );
85
86
master = opal_convertor_master_list ;
@@ -98,8 +99,9 @@ opal_convertor_master_t *opal_convertor_find_or_create_master(uint32_t remote_ar
98
99
size_t * remote_sizes ;
99
100
100
101
while (NULL != master ) {
101
- if (master -> remote_arch == remote_arch )
102
+ if (master -> remote_arch == remote_arch ) {
102
103
return master ;
104
+ }
103
105
master = master -> next ;
104
106
}
105
107
/**
@@ -148,16 +150,18 @@ opal_convertor_master_t *opal_convertor_find_or_create_master(uint32_t remote_ar
148
150
* over 2 bytes (with the exception of logicals) have to be byte-swapped.
149
151
*/
150
152
for (i = OPAL_DATATYPE_FIRST_TYPE ; i < OPAL_DATATYPE_MAX_PREDEFINED ; i ++ ) {
151
- if (remote_sizes [i ] != opal_datatype_local_sizes [i ])
153
+ if (remote_sizes [i ] != opal_datatype_local_sizes [i ]) {
152
154
master -> hetero_mask |= (((uint32_t ) 1 ) << i );
155
+ }
153
156
}
154
157
if (opal_arch_checkmask (& master -> remote_arch , OPAL_ARCH_ISBIGENDIAN )
155
158
!= opal_arch_checkmask (& opal_local_arch , OPAL_ARCH_ISBIGENDIAN )) {
156
159
uint32_t hetero_mask = 0 ;
157
160
158
161
for (i = OPAL_DATATYPE_FIRST_TYPE ; i < OPAL_DATATYPE_MAX_PREDEFINED ; i ++ ) {
159
- if (remote_sizes [i ] > 1 )
162
+ if (remote_sizes [i ] > 1 ) {
160
163
hetero_mask |= (((uint32_t ) 1 ) << i );
164
+ }
161
165
}
162
166
hetero_mask &= ~(((uint32_t ) 1 ) << OPAL_DATATYPE_BOOL );
163
167
master -> hetero_mask |= hetero_mask ;
@@ -169,10 +173,11 @@ opal_convertor_master_t *opal_convertor_find_or_create_master(uint32_t remote_ar
169
173
* try to minimize the usage of the heterogeneous versions.
170
174
*/
171
175
for (i = OPAL_DATATYPE_FIRST_TYPE ; i < OPAL_DATATYPE_MAX_PREDEFINED ; i ++ ) {
172
- if (master -> hetero_mask & (((uint32_t ) 1 ) << i ))
176
+ if (master -> hetero_mask & (((uint32_t ) 1 ) << i )) {
173
177
master -> pFunctions [i ] = opal_datatype_heterogeneous_copy_functions [i ];
174
- else
178
+ } else {
175
179
master -> pFunctions [i ] = opal_datatype_copy_functions [i ];
180
+ }
176
181
}
177
182
178
183
/* We're done so far, return the mater convertor */
@@ -237,14 +242,15 @@ int32_t opal_convertor_pack(opal_convertor_t *pConv, struct iovec *iov, uint32_t
237
242
if (iov [i ].iov_len >= pending_length ) {
238
243
goto complete_contiguous_data_pack ;
239
244
}
240
- if (OPAL_LIKELY (NULL == iov [i ].iov_base ))
245
+ if (OPAL_LIKELY (NULL == iov [i ].iov_base )) {
241
246
iov [i ].iov_base = (IOVBASE_TYPE * ) base_pointer ;
242
- else
247
+ } else {
243
248
#if OPAL_CUDA_SUPPORT
244
249
MEMCPY_CUDA (iov [i ].iov_base , base_pointer , iov [i ].iov_len , pConv );
245
250
#else
246
251
MEMCPY (iov [i ].iov_base , base_pointer , iov [i ].iov_len );
247
252
#endif
253
+ }
248
254
pending_length -= iov [i ].iov_len ;
249
255
base_pointer += iov [i ].iov_len ;
250
256
}
@@ -254,14 +260,15 @@ int32_t opal_convertor_pack(opal_convertor_t *pConv, struct iovec *iov, uint32_t
254
260
255
261
complete_contiguous_data_pack :
256
262
iov [i ].iov_len = pending_length ;
257
- if (OPAL_LIKELY (NULL == iov [i ].iov_base ))
263
+ if (OPAL_LIKELY (NULL == iov [i ].iov_base )) {
258
264
iov [i ].iov_base = (IOVBASE_TYPE * ) base_pointer ;
259
- else
265
+ } else {
260
266
#if OPAL_CUDA_SUPPORT
261
267
MEMCPY_CUDA (iov [i ].iov_base , base_pointer , iov [i ].iov_len , pConv );
262
268
#else
263
269
MEMCPY (iov [i ].iov_base , base_pointer , iov [i ].iov_len );
264
270
#endif
271
+ }
265
272
pConv -> bConverted = pConv -> local_size ;
266
273
* out_size = i + 1 ;
267
274
pConv -> flags |= CONVERTOR_COMPLETED ;
@@ -421,8 +428,9 @@ int32_t opal_convertor_set_position_nocheck(opal_convertor_t *convertor, size_t
421
428
} else {
422
429
if ((0 == (* position )) || ((* position ) < convertor -> bConverted )) {
423
430
rc = opal_convertor_create_stack_at_begining (convertor , opal_datatype_local_sizes );
424
- if (0 == (* position ))
431
+ if (0 == (* position )) {
425
432
return rc ;
433
+ }
426
434
}
427
435
rc = opal_convertor_generic_simple_position (convertor , position );
428
436
/**
@@ -584,17 +592,20 @@ int32_t opal_convertor_prepare_for_recv(opal_convertor_t *convertor,
584
592
convertor -> fAdvance = opal_generic_simple_unpack_checksum ;
585
593
}
586
594
}
587
- } else
595
+ } else {
588
596
#endif /* defined(CHECKSUM) */
589
597
if (OPAL_UNLIKELY (!(convertor -> flags & CONVERTOR_HOMOGENEOUS ))) {
590
- convertor -> fAdvance = opal_unpack_general ;
591
- } else {
592
- if (convertor -> pDesc -> flags & OPAL_DATATYPE_FLAG_CONTIGUOUS ) {
593
- convertor -> fAdvance = opal_unpack_homogeneous_contig ;
598
+ convertor -> fAdvance = opal_unpack_general ;
594
599
} else {
595
- convertor -> fAdvance = opal_generic_simple_unpack ;
600
+ if (convertor -> pDesc -> flags & OPAL_DATATYPE_FLAG_CONTIGUOUS ) {
601
+ convertor -> fAdvance = opal_unpack_homogeneous_contig ;
602
+ } else {
603
+ convertor -> fAdvance = opal_generic_simple_unpack ;
604
+ }
596
605
}
606
+ #if defined(CHECKSUM )
597
607
}
608
+ #endif
598
609
return OPAL_SUCCESS ;
599
610
}
600
611
@@ -619,30 +630,35 @@ int32_t opal_convertor_prepare_for_send(opal_convertor_t *convertor,
619
630
} else {
620
631
if (datatype -> flags & OPAL_DATATYPE_FLAG_CONTIGUOUS ) {
621
632
if (((datatype -> ub - datatype -> lb ) == (ptrdiff_t ) datatype -> size )
622
- || (1 >= convertor -> count ))
633
+ || (1 >= convertor -> count )) {
623
634
convertor -> fAdvance = opal_pack_homogeneous_contig_checksum ;
624
- else
635
+ } else {
625
636
convertor -> fAdvance = opal_pack_homogeneous_contig_with_gaps_checksum ;
637
+ }
626
638
} else {
627
639
convertor -> fAdvance = opal_generic_simple_pack_checksum ;
628
640
}
629
641
}
630
- } else
642
+ } else {
631
643
#endif /* defined(CHECKSUM) */
632
644
if (CONVERTOR_SEND_CONVERSION
633
645
== (convertor -> flags & (CONVERTOR_SEND_CONVERSION | CONVERTOR_HOMOGENEOUS ))) {
634
- convertor -> fAdvance = opal_pack_general ;
635
- } else {
636
- if (datatype -> flags & OPAL_DATATYPE_FLAG_CONTIGUOUS ) {
637
- if (((datatype -> ub - datatype -> lb ) == (ptrdiff_t ) datatype -> size )
638
- || (1 >= convertor -> count ))
639
- convertor -> fAdvance = opal_pack_homogeneous_contig ;
640
- else
641
- convertor -> fAdvance = opal_pack_homogeneous_contig_with_gaps ;
646
+ convertor -> fAdvance = opal_pack_general ;
642
647
} else {
643
- convertor -> fAdvance = opal_generic_simple_pack ;
648
+ if (datatype -> flags & OPAL_DATATYPE_FLAG_CONTIGUOUS ) {
649
+ if (((datatype -> ub - datatype -> lb ) == (ptrdiff_t ) datatype -> size )
650
+ || (1 >= convertor -> count )) {
651
+ convertor -> fAdvance = opal_pack_homogeneous_contig ;
652
+ } else {
653
+ convertor -> fAdvance = opal_pack_homogeneous_contig_with_gaps ;
654
+ }
655
+ } else {
656
+ convertor -> fAdvance = opal_generic_simple_pack ;
657
+ }
644
658
}
659
+ #if defined(CHECKSUM )
645
660
}
661
+ #endif
646
662
return OPAL_SUCCESS ;
647
663
}
648
664
@@ -703,26 +719,35 @@ void opal_convertor_dump(opal_convertor_t *convertor)
703
719
convertor -> local_size , convertor -> remote_size , convertor -> flags ,
704
720
convertor -> stack_size , convertor -> partial_length , convertor -> remoteArch ,
705
721
opal_local_arch );
706
- if (convertor -> flags & CONVERTOR_RECV )
722
+ if (convertor -> flags & CONVERTOR_RECV ) {
707
723
opal_output (0 , "unpack " );
708
- if (convertor -> flags & CONVERTOR_SEND )
724
+ }
725
+ if (convertor -> flags & CONVERTOR_SEND ) {
709
726
opal_output (0 , "pack " );
710
- if (convertor -> flags & CONVERTOR_SEND_CONVERSION )
727
+ }
728
+ if (convertor -> flags & CONVERTOR_SEND_CONVERSION ) {
711
729
opal_output (0 , "conversion " );
712
- if (convertor -> flags & CONVERTOR_HOMOGENEOUS )
730
+ }
731
+ if (convertor -> flags & CONVERTOR_HOMOGENEOUS ) {
713
732
opal_output (0 , "homogeneous " );
714
- else
733
+ } else {
715
734
opal_output (0 , "heterogeneous " );
716
- if (convertor -> flags & CONVERTOR_NO_OP )
735
+ }
736
+ if (convertor -> flags & CONVERTOR_NO_OP ) {
717
737
opal_output (0 , "no_op " );
718
- if (convertor -> flags & CONVERTOR_WITH_CHECKSUM )
738
+ }
739
+ if (convertor -> flags & CONVERTOR_WITH_CHECKSUM ) {
719
740
opal_output (0 , "checksum " );
720
- if (convertor -> flags & CONVERTOR_CUDA )
741
+ }
742
+ if (convertor -> flags & CONVERTOR_CUDA ) {
721
743
opal_output (0 , "CUDA " );
722
- if (convertor -> flags & CONVERTOR_CUDA_ASYNC )
744
+ }
745
+ if (convertor -> flags & CONVERTOR_CUDA_ASYNC ) {
723
746
opal_output (0 , "CUDA Async " );
724
- if (convertor -> flags & CONVERTOR_COMPLETED )
747
+ }
748
+ if (convertor -> flags & CONVERTOR_COMPLETED ) {
725
749
opal_output (0 , "COMPLETED " );
750
+ }
726
751
727
752
opal_datatype_dump (convertor -> pDesc );
728
753
if (!((0 == convertor -> stack_pos )
@@ -742,13 +767,14 @@ void opal_datatype_dump_stack(const dt_stack_t *pStack, int stack_pos,
742
767
for (; stack_pos >= 0 ; stack_pos -- ) {
743
768
opal_output (0 , "%d: pos %d count %" PRIsize_t " disp %ld " , stack_pos ,
744
769
pStack [stack_pos ].index , pStack [stack_pos ].count , pStack [stack_pos ].disp );
745
- if (pStack -> index != -1 )
770
+ if (pStack -> index != -1 ) {
746
771
opal_output (0 , "\t[desc count %lu disp %ld extent %ld]\n" ,
747
772
(unsigned long ) pDesc [pStack [stack_pos ].index ].elem .count ,
748
773
(long ) pDesc [pStack [stack_pos ].index ].elem .disp ,
749
774
(long ) pDesc [pStack [stack_pos ].index ].elem .extent );
750
- else
775
+ } else {
751
776
opal_output (0 , "\n" );
777
+ }
752
778
}
753
779
opal_output (0 , "\n" );
754
780
}
0 commit comments