// Part of dump1090, a Mode S message decoder for RTLSDR devices. // // stats.c: statistics helpers. // // Copyright (c) 2015 Oliver Jowett // // This file is free software: you may copy, redistribute and/or modify it // under the terms of the GNU General Public License as published by the // Free Software Foundation, either version 2 of the License, or (at your // option) any later version. // // This file is distributed in the hope that it will be useful, but // WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU // General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . // This file incorporates work covered by the following copyright and // permission notice: // // Copyright (C) 2012 by Salvatore Sanfilippo // // All rights reserved. // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // // * Redistributions in binary form must reproduce the above copyright // notice, this list of conditions and the following disclaimer in the // documentation and/or other materials provided with the distribution. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. #include "dump1090.h" void display_stats(struct stats *st) { int j; struct tm tm_start, tm_end; char tb_start[30], tb_end[30]; printf("\n\n"); if (Modes.interactive) interactiveShowData(); localtime_r(&st->start, &tm_start); strftime(tb_start, sizeof(tb_start), "%c", &tm_start); localtime_r(&st->end, &tm_end); strftime(tb_end, sizeof(tb_end), "%c", &tm_end); printf("Statistics: %s - %s\n", tb_start, tb_end); if (!Modes.net_only) { printf("Local receiver:\n"); printf(" %u sample blocks processed\n", st->blocks_processed); printf(" %u sample blocks dropped\n", st->blocks_dropped); if (st->blocks_processed > 0) { long cpu_millis = (long)st->cputime.tv_sec*1000L + st->cputime.tv_nsec/1000000L; long sample_millis = (long) ((uint64_t)st->blocks_processed * MODES_ASYNC_BUF_SAMPLES / (Modes.oversample ? 2400 : 2000)); printf(" %ld ms CPU time used to process %ld ms samples, %.1f%% load\n", cpu_millis, sample_millis, 100.0 * cpu_millis / sample_millis); } printf(" %u Mode A/C messages received\n", st->demod_modeac); printf(" %u Mode-S message preambles received\n", st->demod_preambles); printf(" %u with bad message format or invalid CRC\n", st->demod_rejected_bad); printf(" %u with unrecognized ICAO address\n", st->demod_rejected_unknown_icao); printf(" %u accepted with correct CRC\n", st->demod_accepted[0]); for (j = 1; j <= Modes.nfix_crc; ++j) printf(" %u accepted with %d-bit error repaired\n", st->demod_accepted[j], j); if (st->noise_power_count) { printf(" %.1f dBFS noise floor\n", 10 * log10(st->noise_power_sum / st->noise_power_count)); } if (st->signal_power_count) { printf(" %.1f dBFS mean signal power\n", 10 * log10(st->signal_power_sum / st->signal_power_count)); } printf(" %.1f dBFS peak signal power\n", 10 * log10(st->peak_signal_power)); printf(" %u messages with signal power above -3dBFS\n", st->strong_signal_count); } if (Modes.net) { printf("Messages from network clients:\n"); printf(" %u Mode A/C messages received\n", st->remote_received_modeac); printf(" %u Mode S messages received\n", st->remote_received_modes); printf(" %u with bad message format or invalid CRC\n", st->remote_rejected_bad); printf(" %u with unrecognized ICAO address\n", st->remote_rejected_unknown_icao); printf(" %u accepted with correct CRC\n", st->remote_accepted[0]); for (j = 1; j <= Modes.nfix_crc; ++j) printf(" %u accepted with %d-bit error repaired\n", st->remote_accepted[j], j); } printf("%u total usable messages\n", st->messages_total); printf("%u global CPR attempts with valid positions\n" "%u global CPR attempts with bad data\n" "%u global CPR attempts with insufficient data\n" "%u local CPR attempts with valid positions\n" "%u local CPR attempts with insufficient data\n" "%u CPR messages that look like transponder failures filtered\n", st->cpr_global_ok, st->cpr_global_bad, st->cpr_global_skipped, st->cpr_local_ok, st->cpr_local_skipped, st->cpr_filtered); if (Modes.net && Modes.net_http_port) printf("%d HTTP requests\n", st->http_requests); fflush(stdout); } void reset_stats(struct stats *st) { static struct stats st_zero; *st = st_zero; } void add_stats(const struct stats *st1, const struct stats *st2, struct stats *target) { int i; if (st1->start == 0) target->start = st2->start; else if (st2->start == 0) target->start = st1->start; else if (st1->start < st2->start) target->start = st1->start; else target->start = st2->start; target->end = st1->end > st2->end ? st1->end : st2->end; target->demod_preambles = st1->demod_preambles + st2->demod_preambles; target->demod_rejected_bad = st1->demod_rejected_bad + st2->demod_rejected_bad; target->demod_rejected_unknown_icao = st1->demod_rejected_unknown_icao + st2->demod_rejected_unknown_icao; for (i = 0; i < MODES_MAX_BITERRORS+1; ++i) target->demod_accepted[i] = st1->demod_accepted[i] + st2->demod_accepted[i]; target->demod_modeac = st1->demod_modeac + st2->demod_modeac; target->blocks_processed = st1->blocks_processed + st2->blocks_processed; target->blocks_dropped = st1->blocks_dropped + st2->blocks_dropped; target->cputime.tv_sec = st1->cputime.tv_sec + st2->cputime.tv_sec; target->cputime.tv_nsec = st1->cputime.tv_nsec + st2->cputime.tv_nsec; target->cputime.tv_sec += target->cputime.tv_nsec / 1000000000L; target->cputime.tv_nsec %= 1000000000L; // noise floor: target->noise_power_sum = st1->noise_power_sum + st2->noise_power_sum; target->noise_power_count = st1->noise_power_count + st2->noise_power_count; // mean signal power: target->signal_power_sum = st1->signal_power_sum + st2->signal_power_sum; target->signal_power_count = st1->signal_power_count + st2->signal_power_count; // peak signal power seen if (st1->peak_signal_power > st2->peak_signal_power) target->peak_signal_power = st1->peak_signal_power; else target->peak_signal_power = st2->peak_signal_power; // strong signals target->strong_signal_count = st1->strong_signal_count + st2->strong_signal_count; // remote messages: target->remote_received_modeac = st1->remote_received_modeac + st2->remote_received_modeac; target->remote_received_modes = st1->remote_received_modes + st2->remote_received_modes; target->remote_rejected_bad = st1->remote_rejected_bad + st2->remote_rejected_bad; target->remote_rejected_unknown_icao = st1->remote_rejected_unknown_icao + st2->remote_rejected_unknown_icao; for (i = 0; i < MODES_MAX_BITERRORS+1; ++i) target->remote_accepted[i] = st1->remote_accepted[i] + st2->remote_accepted[i]; // total messages: target->messages_total = st1->messages_total + st2->messages_total; // network: target->http_requests = st1->http_requests + st2->http_requests; // CPR decoding: target->cpr_global_ok = st1->cpr_global_ok + st2->cpr_global_ok; target->cpr_global_bad = st1->cpr_global_bad + st2->cpr_global_bad; target->cpr_global_skipped = st1->cpr_global_skipped + st2->cpr_global_skipped; target->cpr_local_ok = st1->cpr_local_ok + st2->cpr_local_ok; target->cpr_local_skipped = st1->cpr_local_skipped + st2->cpr_local_skipped; target->cpr_filtered = st1->cpr_filtered + st2->cpr_filtered; }