ostream_appender.cpp

Go to the documentation of this file.

/**************************************************************************

   begin                : Sat Oct 13 2007
   copyright            : (C) 2007 by Ewald Arnold
   email                : log4sendpp at ewald-arnold dot de

   This program 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 of the License,
   or (at your option) any later version.

   This program 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 Lesser General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

 **/

#define LOG4SENDPP_NEED_EXPORTS
#include <log4sendpp/log4sendpp.h> // always first

#include <iosfwd>

#include <log4sendpp/ostream_appender.h>
#include <log4sendpp/formatter.h>


LOG4SENDPP_NS_START


class ostream_Appender::StreamBuffer
  : public LOG4SENDPP_STD_NS::basic_streambuf<char>
{
  public:

    StreamBuffer(ostream_Appender *in_appender)
      : appender(in_appender)
    {}

    virtual LOG4SENDPP_STD_NS::streamsize xsputn(const char *s, LOG4SENDPP_STD_NS::streamsize n)
    {
      buffer.append(s, n);
      return n;
    }

    virtual int_type overflow(int_type c = 0)
    {
      buffer += c;
      return c;
    }

    int sync( )
    {
      try
      {
        appender->writeString(buffer);
      }
      catch(...)
      {
        appender->setstate(LOG4SENDPP_STD_NS::ios_base::failbit);
      }
      buffer.clear();
      return 0;
    }

  private:

    ostream_Appender           *appender;
    LOG4SENDPP_STD_NS::string   buffer;
};


LOG4SENDPP_API_IMPL0
  ostream_Appender::ostream_Appender(Appender *in_appender)
  : Appender(0)
  , LOG4SENDPP_STD_NS::basic_ostream<char>((sbuffer = new StreamBuffer(this)))
  , appender(in_appender)
{
}


LOG4SENDPP_API_IMPL0
  ostream_Appender::~ostream_Appender()
{
  delete appender;
  delete sbuffer;
}


LOG4SENDPP_API_IMPL(void)
  ostream_Appender::append (Logger::Level level,
                            LOG4SENDPP_STD_NS::string msg,
                            LOG4SENDPP_STD_NS::string category,
                            LOG4SENDPP_INT64 stamp,
                            const LocationInformation *loginfo,
                            const Logger::DiagnosticInformation *diaginfo)
{
  appender->append(level, msg, category, stamp, loginfo, diaginfo);
}


LOG4SENDPP_API_IMPL(void)
  ostream_Appender::writeString(const LOG4SENDPP_STD_NS::string &data)
{
  appender->writeString(data);
}


LOG4SENDPP_API_IMPL(bool)
  ostream_Appender::isWorking() const
{
  return appender->isWorking();
}


LOG4SENDPP_NS_END

---