BufferLogger.cpp

Go to the documentation of this file.

/*******************************************************************************
 *
 * Copyright (c) 2010-2015   Edans Sandes
 *
 * This file is part of MASA-Core.
 * 
 * MASA-Core 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.
 * 
 * MASA-Core 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 MASA-Core.  If not, see <http://www.gnu.org/licenses/>.
 *
 ******************************************************************************/

#include "BufferLogger.hpp"

#include <stdlib.h>
#include "../Timer.hpp"
#include "../../libmasa/libmasa.hpp"

BufferLogger::BufferLogger(string file)
{
        prev_stats.time = 0;
        prev_stats.bufferUsage = 0;
        prev_stats.blockingTime = 0;
        prev_stats.totalBytes = 0;

        this->file = fopen(file.c_str(), "wt");
        if (this->file == NULL) {
                fprintf(stderr, "Could not create buffer statistics file.\n");
                exit(1);
        }
}

BufferLogger::~BufferLogger()
{
        if (this->file != NULL) {
                fclose(this->file);
        }
}

void BufferLogger::logHeader(int bufferMax) {
        fprintf(file, "#buffer_max=%d\n", bufferMax/sizeof(cell_t));
        fflush(file);
}

void BufferLogger::logBuffer(buffer_statistics_t &curr_stats) {
        buffer_statistics_t delta_stats = curr_stats - prev_stats;
        prev_stats = curr_stats;

        float delta = 0;
        float psi = 0;

        int size = sizeof(cell_t);
        if (delta_stats.time >= 0.001) {
                delta = ((float)delta_stats.bufferUsage/size)/delta_stats.time;
        }
        if (delta_stats.time - delta_stats.blockingTime > 0.000001 || delta_stats.time - delta_stats.blockingTime < -0.000001) {
                psi = ((float)delta_stats.totalBytes/size)/delta_stats.time*delta_stats.blockingTime/(delta_stats.time-delta_stats.blockingTime);
        }

        fprintf(file, "%.2f\t%d\t%d\t%.2f\t%.2f\t%d\t%d\t%.2f\t%.3f\t%.3f\t%.3f\t%.3f\n",
                        curr_stats.time,  // 1
                        curr_stats.bufferUsage/size, curr_stats.totalBytes/size, curr_stats.blockingTime,    // 2 3 4
                        delta_stats.time, // 5
                        delta_stats.bufferUsage/size, delta_stats.totalBytes/size, delta_stats.blockingTime, // 6 7 8
                        delta,  psi, // 9 10
                        (delta_stats.totalBytes/size)/delta_stats.time, delta+psi); // 11 12

        fflush(file);
}