MPMessagesFromFile.c

Go to the documentation of this file.

/*
 *  Copyright (C) 2023 Swansea University
 *
 *  This file is part of the SELKIELogger suite of tools.
 *
 *  SELKIELogger is free software: you can redistribute it and/or modify it
 *  under the terms of the GNU General Public License as published by the Free
 *  Software Foundation, either version 3 of the License, or (at your option)
 *  any later version.
 *
 *  SELKIELogger 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 SELKIELogger product.
 *  If not, see <http://www.gnu.org/licenses/>.
*/
 
#include <errno.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
 
#include "SELKIELoggerMP.h"
 
int main(int argc, char *argv[]) {
    //LCOV_EXCL_START
    if (argc < 2) {
        fprintf(stderr, "Usage: %s <file>\n", argv[0]);
        return -2;
    }
 
    errno = 0;
    FILE *testFile = fopen(argv[1], "r");
    if ((testFile == NULL) || errno) {
        fprintf(stderr, "Unable to open test file %s\n", argv[1]);
        perror("open");
        return -2;
    }
    //LCOV_EXCL_STOP
 
    int count = 0;
    int exit = 0;
    uint8_t sources[128] = {0};
    uint8_t types[128] = {0};
 
    while (!(feof(testFile) || exit == 1)) {
        msg_t tmp = {0};
        if (mp_readMessage(fileno(testFile), &tmp)) {
            // Successfully read message
            count++;
            sources[tmp.source]++;
            types[tmp.type]++;
            msg_destroy(&tmp);
        } else {
            switch ((uint8_t)tmp.data.value) {
                //LCOV_EXCL_START
                // Exclude error cases from test coverage
                case 0xAA:
                    fclose(testFile);
                    return -2;
                    break;
                case 0xEE:
                    fclose(testFile);
                    return -1;
                    break;
                //LCOV_EXCL_STOP
                case 0xFD:
                    exit = 1;
                    break;
                case 0xFF:
                default:
                    break;
            }
        }
    }
    fprintf(stdout, "%d messages read\n", count);
    for (int i = 0; i < 128; i++) {
        if (sources[i] > 0) {
            fprintf(stdout, "%d messages read from source 0x%02x\n", sources[i], i);
        }
    }
    for (int i = 0; i < 128; i++) {
        if (types[i] > 0) {
            fprintf(stdout, "%d messages read were of type 0x%02x\n", types[i], i);
        }
    }
    fclose(testFile);
    return 0;
}