LogWriter.cc

Go to the documentation of this file.

/*
 * LogWriter.cc
 *
 * Smalltalk like class library for C++
 * Logging facility with priorities and stream-like interface.
 *
 * Copyright (c) 2004 Milan Cermak
 */
/*
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
#include <stdio.h>
#include <string.h>

#include <stlib/tools/LogWriter.h>
#include <stlib/EncodedStream.h>
#include <stlib/SequenceableCollection.h>
#include <stlib/String.h>
#include <stlib/Timestamp.h>
#include <stlib/os/Semaphore.h>
#include <stlib/tools/Filename.h>
#include <stlib/tools/FileEncodedStreamFactory.h>

using namespace OS;
using namespace Tools;

LogWriter::LogWriter(Stream *writeStream)
  : StreamDecorator(writeStream)
{
    _level = LogError;
    mutex = Semaphore::forMutualExclusion();
}

LogWriter::~LogWriter(void)
{
        close();
    delete mutex;
}

/* Instance creation protocol */
LogWriter *LogWriter::on(String *filename)
{
    return LogWriter::on(new Filename(filename));
}

LogWriter *LogWriter::on(Filename *filename)
{
    return new LogWriter(filename->withEncoding("default")->appendStream());
}

/* Accessing protocol */
Object *LogWriter::next(void)
{
    return underlying_stream->next();
}

void LogWriter::nextPut(Object *object)
{
    underlying_stream->nextPut(object);
}

void LogWriter::nextPut(const char object)
{
    underlying_stream->nextPut(object);
}

void LogWriter::writeLog(LogVerbosityLevel level, Collection *collection)
{
    if (level <= _level) {
        mutex->wait();
        print(Timestamp::now());
        nextPutAll(": (");
        writeLevel(level);
        nextPutAll(") ");
        nextPutAll(collection);
        lf();
        commit();
    }
}

void LogWriter::writeLog(LogVerbosityLevel level, const char *collection)
{
    writeLog(level, new String(collection));
}

void LogWriter::logAll(void)
{
    logTraffic();
}

void LogWriter::logErrors(void)
{
    verbosity(LogError);
}

void LogWriter::logWarnings(void)
{
    verbosity(LogWarning);
}

void LogWriter::logInfos(void)
{
    verbosity(LogInfo);
}

void LogWriter::logNone(void)
{
    verbosity(LogNone);
}

void LogWriter::logTraffic(void)
{
    verbosity(LogTraffic);
}

void LogWriter::logDebug(void)
{
    verbosity(LogDebug);
}

LogVerbosityLevel LogWriter::verbosity(void)
{
    return _level;
}

void LogWriter::verbosity(LogVerbosityLevel level)
{
    _level = level;
}

/* Status protocol */
void LogWriter::close(void)
{
    mutex->wait();
    commit();
    underlying_stream->close();
}

void LogWriter::commit(void)
{
    flush();
    underlying_stream->commit();
    mutex->signal();
}

/* Testing protocol */
bool LogWriter::isBinary(void)
{
    return false;
}

/* Private protocol */
void LogWriter::writeLevel(LogVerbosityLevel level)
{
    switch (level) {
    case LogNone    : nextPutAll("--"); break;
    case LogError   : nextPutAll("EE"); break;
    case LogWarning : nextPutAll("WW"); break;
    case LogInfo    : nextPutAll("II"); break;
    case LogTraffic : nextPutAll("=="); break;
    case LogDebug   : nextPutAll("DD"); break;
    }
}

SequenceableCollection *LogWriter::contentSpeciesFor(long items)
{
    return new String(items);
}

---