static int
aggregator_same_val_list(const struct f_val *v1, const struct f_val *v2, uint len)
{
- for (u32 i = 0; i < len; i++)
+ for (uint i = 0; i < len; i++)
if (!val_same(&v1[i], &v2[i]))
return 0;
rta->eattrs = eal;
/* Seed the attributes from aggregator rule */
- for (u32 i = 0; i < p->aggr_on_count; i++)
+ for (uint i = 0; i < p->aggr_on_count; i++)
{
if (p->aggr_on[i].type == AGGR_ITEM_DYNAMIC_ATTR)
{
struct aggregator_bucket *tmp_bucket = allocz(sizeof(*tmp_bucket) + sizeof(tmp_bucket->aggr_data[0]) * p->aggr_on_count);
ASSERT_DIE(tmp_bucket->id == 0);
- for (u32 val_idx = 0; val_idx < p->aggr_on_count; val_idx++)
+ for (uint val_idx = 0; val_idx < p->aggr_on_count; val_idx++)
{
int type = p->aggr_on[val_idx].type;
struct f_val *pos = &tmp_bucket->aggr_data[val_idx];
u64 haux = 0;
mem_hash_init(&haux);
- for (u32 i = 0; i < p->aggr_on_count; i++)
+ for (uint i = 0; i < p->aggr_on_count; i++)
{
mem_hash_mix_num(&haux, tmp_bucket->aggr_data[i].type);
return 0;
/* Compare aggregator rule */
- for (u32 i = 0; i < p->aggr_on_count; i++)
+ for (uint i = 0; i < p->aggr_on_count; i++)
{
switch (cf->aggr_on[i].type)
{
struct proto_config c;
struct channel_config *src, *dst;
struct aggr_item *aggr_on;
- u32 aggr_on_count;
- u32 aggr_on_da_count;
+ uint aggr_on_count;
+ uint aggr_on_da_count;
const struct f_line *merge_by;
enum aggregation_mode aggr_mode;
bool logging;
/* Aggregator rule */
struct aggr_item *aggr_on;
- u32 aggr_on_count;
- u32 aggr_on_da_count;
+ uint aggr_on_count;
+ uint aggr_on_da_count;
/* Merge filter */
const struct f_line *merge_by;
/* Aggregation trie */
struct trie_node *root;
struct slab *trie_slab;
- u32 addr_type;
+ uint addr_type;
int bitmap_size;
bool initial_feed;
bool logging;