fcgistreambuf.hpp

Go to the documentation of this file.

/*******************************************************************************
* Copyright (C) 2017 Eddie Carle [eddie@isatec.ca]                             *
*                                                                              *
* This file is part of fastcgi++.                                              *
*                                                                              *
* fastcgi++ 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 3 of the License, or (at your option)    *
* any later version.                                                           *
*                                                                              *
* fastcgi++ 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 fastcgi++.  If not, see <http://www.gnu.org/licenses/>.           *
*******************************************************************************/

#ifndef FASTCGIPP_FCGISTREAMBUF_HPP
#define FASTCGIPP_FCGISTREAMBUF_HPP

#include "fastcgi++/protocol.hpp"
#include "fastcgi++/webstreambuf.hpp"
#include "fastcgi++/block.hpp"

#include <istream>
#include <functional>

namespace Fastcgipp
{

    template <class charT, class traits = std::char_traits<charT>>
    class FcgiStreambuf: public WebStreambuf<charT, traits>
    {
    public:
        FcgiStreambuf()
        {
            this->setp(m_buffer, m_buffer+s_buffSize);
        }


        void configure(
                const Protocol::RequestId& id,
                const Protocol::RecordType& type,
                const std::function<void(const Socket&, Block&&)>
                    send_)
        {
            m_id = id;
            m_type = type;
            send = send_;
        }

        virtual ~FcgiStreambuf()
        {
            sync();
        }


        void dump(const char* data, size_t size);


        void dump(std::basic_istream<char>& stream);

    private:
        typedef typename std::basic_streambuf<charT, traits>::int_type int_type;
        typedef typename std::basic_streambuf<charT, traits>::traits_type traits_type;
        typedef typename std::basic_streambuf<charT, traits>::char_type char_type;

        int_type overflow(int_type c = traits_type::eof());

        int sync()
        {
            return emptyBuffer()?0:-1;
        }

        bool emptyBuffer();

        static const int s_buffSize = 8192;

        char_type m_buffer[s_buffSize];

        Protocol::RequestId m_id;

        Protocol::RecordType m_type;

        std::function<void(const Socket&, Block&&)> send;
    };
}

#endif