@@ -1656,7 +1656,7 @@ static void era_decide(era_value_t *decided_value, era_agreement_info_t *ci)
1656
1656
OPAL_OUTPUT_VERBOSE (((ci -> comm -> c_my_rank == r )? 2 : 10 , ompi_ftmpi_output_handle ,
1657
1657
"%s ftagree:agreement (ERA) decide %08x.%d.%d.. on agreement (%d.%d).%d\n" ,
1658
1658
OMPI_NAME_PRINT (OMPI_PROC_MY_NAME ),
1659
- (0 != ERA_VALUE_BYTES_COUNT ( & decided_value -> header ) )? * (int * )decided_value -> bytes : 0 ,
1659
+ (NULL != decided_value -> bytes )? * (int * )decided_value -> bytes : 0 ,
1660
1660
decided_value -> header .ret ,
1661
1661
decided_value -> header .nb_new_dead ,
1662
1662
ci -> agreement_id .ERAID_FIELDS .contextid ,
@@ -1674,7 +1674,7 @@ static void era_decide(era_value_t *decided_value, era_agreement_info_t *ci)
1674
1674
OPAL_OUTPUT_VERBOSE ((30 , ompi_ftmpi_output_handle ,
1675
1675
"%s ftagree:agreement (ERA) decide %08x.%d.%d on agreement (%d.%d).%d: adding up to %d processes to the list of agreed deaths\n" ,
1676
1676
OMPI_NAME_PRINT (OMPI_PROC_MY_NAME ),
1677
- (0 != ERA_VALUE_BYTES_COUNT ( & decided_value -> header ) )? * (int * )decided_value -> bytes : 0 ,
1677
+ (NULL != decided_value -> bytes )? * (int * )decided_value -> bytes : 0 ,
1678
1678
decided_value -> header .ret ,
1679
1679
decided_value -> header .nb_new_dead ,
1680
1680
ci -> agreement_id .ERAID_FIELDS .contextid ,
@@ -1735,7 +1735,7 @@ static void era_decide(era_value_t *decided_value, era_agreement_info_t *ci)
1735
1735
OPAL_OUTPUT_VERBOSE ((10 , ompi_ftmpi_output_handle ,
1736
1736
"%s ftagree:agreement (ERA) decide %08x.%d.%d.. on agreement (%d.%d).%d: group of agreed deaths is of size %d\n" ,
1737
1737
OMPI_NAME_PRINT (OMPI_PROC_MY_NAME ),
1738
- (0 != ERA_VALUE_BYTES_COUNT ( & decided_value -> header ) )? * (int * )decided_value -> bytes : 0 ,
1738
+ (NULL != decided_value -> bytes )? * (int * )decided_value -> bytes : 0 ,
1739
1739
decided_value -> header .ret ,
1740
1740
decided_value -> header .nb_new_dead ,
1741
1741
ci -> agreement_id .ERAID_FIELDS .contextid ,
@@ -2120,7 +2120,7 @@ static void send_msg(ompi_communicator_t *comm,
2120
2120
agreement_id .ERAID_FIELDS .epoch ,
2121
2121
agreement_id .ERAID_FIELDS .agreementid ,
2122
2122
era_msg_type_to_string (type ),
2123
- (0 != ERA_VALUE_BYTES_COUNT ( & value -> header ) )? * (int * )value -> bytes : 0 ,
2123
+ (NULL != value -> bytes )? * (int * )value -> bytes : 0 ,
2124
2124
value -> header .ret ,
2125
2125
value -> header .nb_new_dead ,
2126
2126
dst ,
@@ -2137,7 +2137,7 @@ static void send_msg(ompi_communicator_t *comm,
2137
2137
agreement_id .ERAID_FIELDS .epoch ,
2138
2138
agreement_id .ERAID_FIELDS .agreementid ,
2139
2139
era_msg_type_to_string (type ),
2140
- (0 != ERA_VALUE_BYTES_COUNT ( & value -> header ) )? * (int * )value -> bytes : 0 ,
2140
+ (NULL != value -> bytes )? * (int * )value -> bytes : 0 ,
2141
2141
value -> header .ret ,
2142
2142
value -> header .nb_new_dead ,
2143
2143
nb_ack_failed ,
@@ -2151,7 +2151,7 @@ static void send_msg(ompi_communicator_t *comm,
2151
2151
agreement_id .ERAID_FIELDS .epoch ,
2152
2152
agreement_id .ERAID_FIELDS .agreementid ,
2153
2153
era_msg_type_to_string (type ),
2154
- (0 != ERA_VALUE_BYTES_COUNT ( & value -> header ) )? * (int * )value -> bytes : 0 ,
2154
+ (NULL != value -> bytes )? * (int * )value -> bytes : 0 ,
2155
2155
value -> header .ret ,
2156
2156
value -> header .nb_new_dead ,
2157
2157
dst ,
@@ -2231,7 +2231,7 @@ static void send_msg(ompi_communicator_t *comm,
2231
2231
agreement_id .ERAID_FIELDS .epoch ,
2232
2232
agreement_id .ERAID_FIELDS .agreementid ,
2233
2233
era_msg_type_to_string (type ),
2234
- (0 != ERA_VALUE_BYTES_COUNT ( & value -> header ) )? * (int * )value -> bytes : 0 ,
2234
+ (NULL != value -> bytes )? * (int * )value -> bytes : 0 ,
2235
2235
value -> header .ret ,
2236
2236
value -> header .nb_new_dead ,
2237
2237
msg_header .nb_ack ,
@@ -2275,7 +2275,7 @@ static void send_msg(ompi_communicator_t *comm,
2275
2275
agreement_id .ERAID_FIELDS .epoch ,
2276
2276
agreement_id .ERAID_FIELDS .agreementid ,
2277
2277
era_msg_type_to_string (type ),
2278
- (0 != ERA_VALUE_BYTES_COUNT ( & value -> header ) )? * (int * )value -> bytes : 0 ,
2278
+ (NULL != value -> bytes )? * (int * )value -> bytes : 0 ,
2279
2279
value -> header .ret ,
2280
2280
value -> header .nb_new_dead ,
2281
2281
msg_header .nb_ack ,
@@ -2422,7 +2422,7 @@ static void msg_up(era_msg_header_t *msg_header, uint8_t *bytes, int *new_dead,
2422
2422
msg_header -> agreement_id .ERAID_FIELDS .agreementid ,
2423
2423
msg_header -> src_comm_rank ,
2424
2424
OMPI_NAME_PRINT (& msg_header -> src_proc_name ),
2425
- (0 != ERA_VALUE_BYTES_COUNT ( & msg_header -> agreement_value_header ) )? * (int * )bytes : 0 ,
2425
+ (NULL != bytes )? * (int * )bytes : 0 ,
2426
2426
msg_header -> agreement_value_header .ret ,
2427
2427
msg_header -> agreement_value_header .nb_new_dead ,
2428
2428
msg_header -> nb_ack ));
@@ -2553,7 +2553,7 @@ static void msg_down(era_msg_header_t *msg_header, uint8_t *bytes, int *new_dead
2553
2553
msg_header -> agreement_id .ERAID_FIELDS .agreementid ,
2554
2554
msg_header -> src_comm_rank ,
2555
2555
OMPI_NAME_PRINT (& msg_header -> src_proc_name ),
2556
- (0 != ERA_VALUE_BYTES_COUNT ( & msg_header -> agreement_value_header ) )? * (int * )bytes : 0 ,
2556
+ (NULL != bytes )? * (int * )bytes : 0 ,
2557
2557
msg_header -> agreement_value_header .nb_new_dead ));
2558
2558
2559
2559
ci = era_lookup_agreement_info ( msg_header -> agreement_id );
@@ -2724,7 +2724,7 @@ static void era_cb_fn(struct mca_btl_base_module_t* btl,
2724
2724
msg_header -> agreement_id .ERAID_FIELDS .epoch ,
2725
2725
msg_header -> agreement_id .ERAID_FIELDS .agreementid ,
2726
2726
msg_header -> msg_type ,
2727
- (0 != ERA_VALUE_BYTES_COUNT ( & msg_header -> agreement_value_header ) )? * (int * )value_bytes : 0 ,
2727
+ (NULL != value_bytes )? * (int * )value_bytes : 0 ,
2728
2728
msg_header -> agreement_value_header .ret ,
2729
2729
msg_header -> agreement_value_header .nb_new_dead ,
2730
2730
msg_header -> src_comm_rank ,
@@ -3157,7 +3157,7 @@ static int mca_coll_ftagree_era_complete_agreement(era_identifier_t agreement_id
3157
3157
agreement_id .ERAID_FIELDS .epoch ,
3158
3158
agreement_id .ERAID_FIELDS .agreementid ,
3159
3159
ret ,
3160
- (0 != ERA_VALUE_BYTES_COUNT ( & av -> header ) )? * (int * )contrib : 0 ));
3160
+ (NULL != contrib )? * (int * )contrib : 0 ));
3161
3161
3162
3162
return ret ;
3163
3163
}
0 commit comments