@@ -69,8 +69,8 @@ static AnonAggState *sum_create_state(MemoryContext memory_context, ArgsDescript
6969 SumState * state = palloc0 (sizeof (SumState ));
7070 state -> trackers_count = trackers_count ;
7171 state -> summand_type = args_desc -> args [SUM_VALUE_INDEX ].type_oid ;
72- state -> positive = palloc0 (trackers_count * sizeof (ContributionTrackerState * ));
73- state -> negative = palloc0 (trackers_count * sizeof (ContributionTrackerState * ));
72+ state -> positive = palloc0 (trackers_count * sizeof (SumLeg ));
73+ state -> negative = palloc0 (trackers_count * sizeof (SumLeg ));
7474 ContributionDescriptor typed_sum_descriptor = {0 };
7575 switch (state -> summand_type )
7676 {
@@ -100,14 +100,14 @@ static AnonAggState *sum_create_state(MemoryContext memory_context, ArgsDescript
100100 return & state -> base ;
101101}
102102
103- typedef struct SumResultAccumulators
103+ typedef struct SumResult
104104{
105105 bool not_enough_aid_values ;
106106 SummableResultAccumulator positive ;
107107 SummableResultAccumulator negative ;
108- } SumResultAccumulators ;
108+ } SumResult ;
109109
110- static SumResultAccumulators sum_calculate_final (AnonAggState * base_state , Bucket * bucket , BucketDescriptor * bucket_desc )
110+ static SumResult sum_calculate_final (AnonAggState * base_state , Bucket * bucket , BucketDescriptor * bucket_desc )
111111{
112112 SumState * state = (SumState * )base_state ;
113113 SummableResultAccumulator positive_result_accumulator = {0 };
@@ -121,7 +121,7 @@ static SumResultAccumulators sum_calculate_final(AnonAggState *base_state, Bucke
121121
122122 if (positive_result .not_enough_aid_values && negative_result .not_enough_aid_values )
123123 {
124- return (SumResultAccumulators ){.not_enough_aid_values = true};
124+ return (SumResult ){.not_enough_aid_values = true};
125125 }
126126 else
127127 {
@@ -130,16 +130,16 @@ static SumResultAccumulators sum_calculate_final(AnonAggState *base_state, Bucke
130130 accumulate_result (& negative_result_accumulator , & negative_result );
131131 }
132132 }
133- return (SumResultAccumulators ){.positive = positive_result_accumulator , .negative = negative_result_accumulator };
133+ return (SumResult ){.positive = positive_result_accumulator , .negative = negative_result_accumulator };
134134}
135135
136136static Datum sum_finalize (AnonAggState * base_state , Bucket * bucket , BucketDescriptor * bucket_desc , bool * is_null )
137137{
138138 SumState * state = (SumState * )base_state ;
139- SumResultAccumulators results = sum_calculate_final (base_state , bucket , bucket_desc );
139+ SumResult result = sum_calculate_final (base_state , bucket , bucket_desc );
140140
141- /* We deliberately ignore the `not_enough_aid_values` fields in the `results .positive` and `negative`. */
142- if (results .not_enough_aid_values )
141+ /* We deliberately ignore the `not_enough_aid_values` fields in the `result .positive` and `negative`. */
142+ if (result .not_enough_aid_values )
143143 {
144144 * is_null = true;
145145 switch (state -> summand_type )
@@ -161,7 +161,7 @@ static Datum sum_finalize(AnonAggState *base_state, Bucket *bucket, BucketDescri
161161 }
162162 else
163163 {
164- double combined_result = finalize_sum_result (& results .positive ) - finalize_sum_result (& results .negative );
164+ double combined_result = finalize_sum_result (& result .positive ) - finalize_sum_result (& result .negative );
165165 switch (state -> summand_type )
166166 {
167167 case INT2OID :
@@ -275,17 +275,17 @@ static void sum_noise_final_type(const ArgsDescriptor *args_desc, Oid *type, int
275275
276276static Datum sum_noise_finalize (AnonAggState * base_state , Bucket * bucket , BucketDescriptor * bucket_desc , bool * is_null )
277277{
278- SumResultAccumulators results = sum_calculate_final (base_state , bucket , bucket_desc );
278+ SumResult result = sum_calculate_final (base_state , bucket , bucket_desc );
279279
280- /* We deliberately ignore the `not_enough_aid_values` fields in the `results .positive` and `negative`. */
281- if (results .not_enough_aid_values )
280+ /* We deliberately ignore the `not_enough_aid_values` fields in the `result .positive` and `negative`. */
281+ if (result .not_enough_aid_values )
282282 {
283283 * is_null = true;
284284 return Float8GetDatum (0.0 );
285285 }
286286 else
287287 {
288- return Float8GetDatum (sqrt (pow (finalize_noise_result (& results .positive ), 2 ) + pow (finalize_noise_result (& results .negative ), 2 )));
288+ return Float8GetDatum (sqrt (pow (finalize_noise_result (& result .positive ), 2 ) + pow (finalize_noise_result (& result .negative ), 2 )));
289289 }
290290}
291291
0 commit comments