Ticket #5174: codeConverterTestcase.cpp

#include <iostream>
#include <cstring>

#include <boost/iostreams/filtering_stream.hpp>
#include <boost/iostreams/code_converter.hpp>

struct SinkDev: public boost::iostreams::device<boost::iostreams::output, char>
{
        std::streamsize write(const char* s, std::streamsize n)
        {
                std::cerr << "SinkDev::write(): Recieved " << n << " characters.\n";

                return n;
        }
};

struct SourceDev: public boost::iostreams::device<boost::iostreams::input, char>
{
        std::streamsize read(char* s, std::streamsize n)
        {
                std::cerr << "SourceDev::read(): Sending " << n << " characters.\n";

                char data[] = "wrlubriachlasluprlebriuq";

                std::memcpy(s, data, n);

                return n;
        }
};

int main()
{
        using namespace boost;

        // This our test output stream
        iostreams::filtering_stream<iostreams::output, wchar_t> out;
        // Add a code converter filter with a 16 character buffer
        out.push(iostreams::code_converter<SinkDev>(SinkDev(), 16), 0);

        // This our test output stream
        iostreams::filtering_stream<boost::iostreams::input, wchar_t> in;
        // Add a code converter filter with a 16 character buffer
        in.push(iostreams::code_converter<SourceDev>(SourceDev(), 16), 0);

        wchar_t data[] = L"wieriaciafrianoechlajoes";

        // Test the output stream
        std::cerr << "main(): Sending 24 characters of data to output stream\n";
        out.write(data, 24);
        std::cerr << "main(): Calling a sync on the output stream\n";
        out.strict_sync();
        std::cerr << "main(): Sending 21 characters of data to output stream\n";
        out.write(data, 21);

        std::cerr << '\n';

        // Test the input stream
        std::cerr << "main(): Asking for 24 characters of data from input stream\n";
        in.read(data, 24);
        std::cerr << "main(): Calling a sync on the input stream\n";
        in.strict_sync();
        std::cerr << "main(): Asking for 9 characters of data from input stream\n";
        in.read(data, 9);

        std::cerr << '\n';

        std::cerr << "main(): At end of test case\n";

        return 0;
}