148 static bool map_collect_record(int fd, __u32 key, struct record *rec)  in map_collect_record()  argument
165 	rec->timestamp = gettime();  in map_collect_record()
169 		rec->cpu[i].processed = values[i].processed;  in map_collect_record()
171 		rec->cpu[i].dropped = values[i].dropped;  in map_collect_record()
173 		rec->cpu[i].info = values[i].info;  in map_collect_record()
175 		rec->cpu[i].err = values[i].err;  in map_collect_record()
178 	rec->total.processed = sum_processed;  in map_collect_record()
179 	rec->total.dropped   = sum_dropped;  in map_collect_record()
180 	rec->total.info      = sum_info;  in map_collect_record()
181 	rec->total.err       = sum_err;  in map_collect_record()
185 static bool map_collect_record_u64(int fd, __u32 key, struct record_u64 *rec)  in map_collect_record_u64()  argument
199 	rec->timestamp = gettime();  in map_collect_record_u64()
203 		rec->cpu[i].processed = values[i].processed;  in map_collect_record_u64()
206 	rec->total.processed = sum_total;  in map_collect_record_u64()
311 		struct record_u64 *rec, *prev;  in stats_print()  local
315 		rec  =  &stats_rec->xdp_redirect[rec_i];  in stats_print()
317 		t = calc_period_u64(rec, prev);  in stats_print()
320 			struct u64rec *r = &rec->cpu[i];  in stats_print()
329 		pps = calc_pps_u64(&rec->total, &prev->total, t);  in stats_print()
336 		struct record_u64 *rec, *prev;  in stats_print()  local
340 		rec  =  &stats_rec->xdp_exception[rec_i];  in stats_print()
342 		t = calc_period_u64(rec, prev);  in stats_print()
345 			struct u64rec *r = &rec->cpu[i];  in stats_print()
353 		pps = calc_pps_u64(&rec->total, &prev->total, t);  in stats_print()
363 		struct record *rec, *prev;  in stats_print()  local
367 		rec  =  &stats_rec->xdp_cpumap_enqueue[to_cpu];  in stats_print()
369 		t = calc_period(rec, prev);  in stats_print()
371 			struct datarec *r = &rec->cpu[i];  in stats_print()
385 		pps = calc_pps(&rec->total, &prev->total, t);  in stats_print()
387 			drop = calc_drop(&rec->total, &prev->total, t);  in stats_print()
388 			info = calc_info(&rec->total, &prev->total, t);  in stats_print()
402 		struct record *rec, *prev;  in stats_print()  local
406 		rec  =  &stats_rec->xdp_cpumap_kthread;  in stats_print()
408 		t = calc_period(rec, prev);  in stats_print()
410 			struct datarec *r = &rec->cpu[i];  in stats_print()
422 		pps = calc_pps(&rec->total, &prev->total, t);  in stats_print()
423 		drop = calc_drop(&rec->total, &prev->total, t);  in stats_print()
424 		info = calc_info(&rec->total, &prev->total, t);  in stats_print()
434 		struct record *rec, *prev;  in stats_print()  local
439 		rec  =  &stats_rec->xdp_devmap_xmit;  in stats_print()
441 		t = calc_period(rec, prev);  in stats_print()
443 			struct datarec *r = &rec->cpu[i];  in stats_print()
460 		pps = calc_pps(&rec->total, &prev->total, t);  in stats_print()
461 		drop = calc_drop(&rec->total, &prev->total, t);  in stats_print()
462 		info = calc_info(&rec->total, &prev->total, t);  in stats_print()
463 		err  = calc_err(&rec->total, &prev->total, t);  in stats_print()
477 static bool stats_collect(struct stats_record *rec)  in stats_collect()  argument
488 		map_collect_record_u64(fd, i, &rec->xdp_redirect[i]);  in stats_collect()
492 		map_collect_record_u64(fd, i, &rec->xdp_exception[i]);  in stats_collect()
497 		map_collect_record(fd, i, &rec->xdp_cpumap_enqueue[i]);  in stats_collect()
500 	map_collect_record(fd, 0, &rec->xdp_cpumap_kthread);  in stats_collect()
503 	map_collect_record(fd, 0, &rec->xdp_devmap_xmit);  in stats_collect()
526 	struct stats_record *rec;  in alloc_stats_record()  local
531 	rec = malloc(sizeof(*rec));  in alloc_stats_record()
532 	memset(rec, 0, sizeof(*rec));  in alloc_stats_record()
533 	if (!rec) {  in alloc_stats_record()
541 		rec->xdp_redirect[i].cpu = alloc_rec_per_cpu(rec_sz);  in alloc_stats_record()
544 		rec->xdp_exception[i].cpu = alloc_rec_per_cpu(rec_sz);  in alloc_stats_record()
547 	rec->xdp_cpumap_kthread.cpu = alloc_rec_per_cpu(rec_sz);  in alloc_stats_record()
548 	rec->xdp_devmap_xmit.cpu    = alloc_rec_per_cpu(rec_sz);  in alloc_stats_record()
551 		rec->xdp_cpumap_enqueue[i].cpu = alloc_rec_per_cpu(rec_sz);  in alloc_stats_record()
553 	return rec;  in alloc_stats_record()
587 	struct stats_record *rec, *prev;  in stats_poll()  local
589 	rec  = alloc_stats_record();  in stats_poll()
591 	stats_collect(rec);  in stats_poll()
612 		swap(&prev, &rec);  in stats_poll()
613 		stats_collect(rec);  in stats_poll()
614 		stats_print(rec, prev, err_only);  in stats_poll()
619 	free_stats_record(rec);  in stats_poll()