CConsoleRedirector.h

Go to the documentation of this file.

/* +---------------------------------------------------------------------------+
   |          The Mobile Robot Programming Toolkit (MRPT) C++ library          |
   |                                                                           |
   |                       http://www.mrpt.org/                                |
   |                                                                           |
   |   Copyright (C) 2005-2012  University of Malaga                           |
   |                                                                           |
   |    This software was written by the Machine Perception and Intelligent    |
   |      Robotics Lab, University of Malaga (Spain).                          |
   |    Contact: Jose-Luis Blanco  <jlblanco@ctima.uma.es>                     |
   |                                                                           |
   |  This file is part of the MRPT project.                                   |
   |                                                                           |
   |     MRPT 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.                                   |
   |                                                                           |
   |   MRPT 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 MRPT.  If not, see <http://www.gnu.org/licenses/>.         |
   |                                                                           |
   +---------------------------------------------------------------------------+ */
#ifndef CConsoleRedirector_H
#define CConsoleRedirector_H

#include <streambuf>
#include <iostream>


namespace mrpt
{
        namespace utils
        {
                /** By creating an object of this class, all the output to std::cout (and std::cerr) will be redirected to a text file, and optionally also shown on the console.
                  *  Based on code from http://www.devmaster.net/forums/showthread.php?t=7037
                 * \ingroup mrpt_base_grp
                  */
                class CConsoleRedirector : public std::streambuf
                {
                protected:
                        std::ofstream   m_of;           //!< The text output file stream.
                        std::streambuf  *sbOld;         //!< The "old" std::cout
                        std::streambuf  *sbOld_cerr;            //!< The "old" std::cout
                        bool                    m_also_to_console;
                        mrpt::synch::CCriticalSection   m_cs;

                public:
                        /** Constructor
                          * \param out_file The file to create / append
                          * \param also_to_console Whether to redirect data to file *and* also dump data to the console as usual.
                          * \param append_file If set to false the file will be truncated on open
                          * \param bufferSize It's recommended to buffer the data instead of writing characters one by one.
                          * \param also_cerr Whether to redirect the output to std::cerr in addition to std::cout.
                          * \exception std::exception If the file cannot be opened.
                          */
                        CConsoleRedirector(
                                const std::string &out_file,
                                bool also_to_console=true,
                                bool also_cerr = true,
                                bool append_file = false,
                                int bufferSize = 1000 ) : m_of(), sbOld(NULL),sbOld_cerr(NULL),m_also_to_console(also_to_console), m_cs()
                        {
                                // Open the file:
                                std::ios_base::openmode  openMode = std::ios_base::binary | std::ios_base::out;
                                if ( append_file ) openMode |= std::ios_base::app;
                                m_of.open(out_file.c_str(),  openMode );
                                if (!m_of.is_open()) THROW_EXCEPTION_CUSTOM_MSG1("Error opening file: %s",out_file.c_str())

                                if (bufferSize)
                                {
                                        char *ptr = new char[bufferSize];
                                        setp(ptr, ptr + bufferSize);
                                }
                                else
                                        setp(0, 0);

                                // Redirect:
                                sbOld = std::cout.rdbuf();
                                std::cout.rdbuf( this );

                                if (also_cerr)
                                {
                                        sbOld_cerr = std::cerr.rdbuf();
                                        std::cerr.rdbuf( this );
                                }
                        }

                        virtual ~CConsoleRedirector()
                        {
                                sync();
                                // Restore normal output:
                                std::cout.rdbuf(sbOld);
                                if (sbOld_cerr!=NULL) std::cerr.rdbuf( sbOld_cerr );
                                if (pbase()) delete[] pbase();
                        }

                        void flush()
                        {
                                sync();
                        }

                        virtual void writeString(const std::string &str)
                        {
                                if (m_also_to_console) sbOld->sputn(str.c_str(),str.size());
                                m_of << str;
                        }

                private:
                        int     overflow(int c)
                        {
                                sync();

                                m_cs.enter();
                                if (c != EOF)
                                {
                                        if (pbase() == epptr())
                                        {
                                                std::string temp;
                                                temp += char(c);
                                                writeString(temp);
                                        }
                                        else
                                                sputc(c);
                                }

                                m_cs.leave();
                                return 0;
                        }

                        int     sync()
                        {
                                m_cs.enter();
                                if (pbase() != pptr())
                                {
                                        int len = int(pptr() - pbase());
                                        std::string temp(pbase(), len);
                                        writeString(temp);
                                        setp(pbase(), epptr());
                                }
                                m_cs.leave();
                                return 0;
                        }
                };

        } // end namespace
} // end namespace

#endif