Chris@16: // (C) Copyright 2008 CodeRage, LLC (turkanis at coderage dot com) Chris@16: // (C) Copyright 2005-2007 Jonathan Turkanis Chris@16: // Distributed under the Boost Software License, Version 1.0. (See accompanying Chris@16: // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt.) Chris@16: Chris@16: // See http://www.boost.org/libs/iostreams for documentation. Chris@16: Chris@16: // Note: bidirectional streams are not supported. Chris@16: Chris@16: #ifndef BOOST_IOSTREAMS_COMPOSE_HPP_INCLUDED Chris@16: #define BOOST_IOSTREAMS_COMPOSE_HPP_INCLUDED Chris@16: Chris@16: #if defined(_MSC_VER) && (_MSC_VER >= 1020) Chris@16: # pragma once Chris@16: #endif Chris@16: Chris@16: #include // min. Chris@16: #include // pair. Chris@16: #include // DEDUCED_TYPENAME. Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include // mode_of, is_direct. Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: #include Chris@16: Chris@16: // Must come last. Chris@16: #include // MSVC. Chris@16: Chris@16: namespace boost { namespace iostreams { Chris@16: Chris@16: namespace detail { Chris@16: Chris@16: template< typename First, Chris@16: typename Second, Chris@16: typename FirstMode = Chris@16: BOOST_DEDUCED_TYPENAME mode_of::type, Chris@16: typename SecondMode = Chris@16: BOOST_DEDUCED_TYPENAME mode_of::type > Chris@16: struct composite_mode Chris@16: : select< Chris@16: is_convertible, FirstMode, Chris@16: is_convertible, SecondMode, Chris@16: is_convertible, input, Chris@16: else_, output Chris@16: > Chris@16: { }; Chris@16: Chris@16: // Chris@16: // Template name: composite_device. Chris@16: // Description: Provides a Device view of a Filter, Device pair. Chris@16: // Template parameters: Chris@16: // Filter - A model of Filter. Chris@16: // Device - An indirect model of Device. Chris@16: // Chris@16: template< typename Filter, Chris@16: typename Device, Chris@16: typename Mode = Chris@16: BOOST_DEDUCED_TYPENAME composite_mode::type > Chris@16: class composite_device { Chris@16: private: Chris@16: typedef typename detail::param_type::type param_type; Chris@16: typedef typename mode_of::type filter_mode; Chris@16: typedef typename mode_of::type device_mode; Chris@16: typedef typename Chris@16: iostreams::select< // Disambiguation for Tru64. Chris@16: is_direct, direct_adapter, Chris@16: is_std_io, Device&, Chris@16: else_, Device Chris@16: >::type value_type; Chris@16: BOOST_STATIC_ASSERT(is_filter::value); Chris@16: BOOST_STATIC_ASSERT(is_device::value); Chris@16: public: Chris@16: typedef typename char_type_of::type char_type; Chris@16: struct category Chris@16: : Mode, Chris@16: device_tag, Chris@16: closable_tag, Chris@16: flushable_tag, Chris@16: localizable_tag, Chris@16: optimally_buffered_tag Chris@16: { }; Chris@16: composite_device(const Filter& flt, param_type dev); Chris@16: std::streamsize read(char_type* s, std::streamsize n); Chris@16: std::streamsize write(const char_type* s, std::streamsize n); Chris@16: std::streampos seek( stream_offset off, BOOST_IOS::seekdir way, Chris@16: BOOST_IOS::openmode which = Chris@16: BOOST_IOS::in | BOOST_IOS::out ); Chris@16: Chris@16: void close(); Chris@16: void close(BOOST_IOS::openmode which); Chris@16: bool flush(); Chris@16: std::streamsize optimal_buffer_size() const; Chris@16: Chris@16: template // Avoid dependency on Chris@16: void imbue(const Locale& loc) Chris@16: { Chris@16: iostreams::imbue(filter_, loc); Chris@16: iostreams::imbue(device_, loc); Chris@16: } Chris@16: Chris@16: Filter& first() { return filter_; } Chris@16: Device& second() { return device_; } Chris@16: private: Chris@16: Filter filter_; Chris@16: value_type device_; Chris@16: }; Chris@16: Chris@16: // Chris@16: // Template name: composite_device. Chris@16: // Description: Provides a Device view of a Filter, Device pair. Chris@16: // Template parameters: Chris@16: // Filter - A model of Filter. Chris@16: // Device - An indirect model of Device. Chris@16: // Chris@16: template< typename Filter1, Chris@16: typename Filter2, Chris@16: typename Mode = Chris@16: BOOST_DEDUCED_TYPENAME composite_mode::type > Chris@16: class composite_filter { Chris@16: private: Chris@16: typedef reference_wrapper filter_ref; Chris@16: typedef typename mode_of::type first_mode; Chris@16: typedef typename mode_of::type second_mode; Chris@16: Chris@16: // A dual-use filter cannot be composed with a read-write filter Chris@16: BOOST_STATIC_ASSERT( Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) || Chris@16: (is_convertible::value) Chris@16: ); Chris@16: BOOST_STATIC_ASSERT( Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) || Chris@16: (is_convertible::value) Chris@16: ); Chris@16: BOOST_STATIC_ASSERT(is_filter::value); Chris@16: BOOST_STATIC_ASSERT(is_filter::value); Chris@16: public: Chris@16: typedef typename char_type_of::type char_type; Chris@16: struct category Chris@16: : Mode, Chris@16: filter_tag, Chris@16: multichar_tag, Chris@16: closable_tag, Chris@16: flushable_tag, Chris@16: localizable_tag, Chris@16: optimally_buffered_tag Chris@16: { }; Chris@16: composite_filter(const Filter1& filter1, const Filter2& filter2) Chris@16: : filter1_(filter1), filter2_(filter2) Chris@16: { } Chris@16: Chris@16: template Chris@16: std::streamsize read(Source& src, char_type* s, std::streamsize n) Chris@16: { Chris@16: composite_device cmp(boost::ref(filter2_), src); Chris@16: return iostreams::read(filter1_, cmp, s, n); Chris@16: } Chris@16: Chris@16: template Chris@16: std::streamsize write(Sink& snk, const char_type* s, std::streamsize n) Chris@16: { Chris@16: composite_device cmp(boost::ref(filter2_), snk); Chris@16: return iostreams::write(filter1_, cmp, s, n); Chris@16: } Chris@16: Chris@16: template Chris@16: std::streampos seek( Device& dev, stream_offset off, BOOST_IOS::seekdir way, Chris@16: BOOST_IOS::openmode which = Chris@16: BOOST_IOS::in | BOOST_IOS::out ) Chris@16: { Chris@16: composite_device cmp(boost::ref(filter2_), dev); Chris@16: return iostreams::seek(filter1_, cmp, off, way, which); Chris@16: } Chris@16: Chris@16: template Chris@16: void close(Device& dev) Chris@16: { Chris@16: BOOST_STATIC_ASSERT((!is_convertible::value)); Chris@16: BOOST_STATIC_ASSERT((!is_convertible::value)); Chris@16: Chris@16: // Create a new device by composing the second filter2_ with dev. Chris@16: composite_device cmp(boost::ref(filter2_), dev); Chris@16: Chris@16: // Close input sequences in reverse order and output sequences in Chris@16: // forward order Chris@16: if (!is_convertible::value) { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::in), Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::in), Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::out), Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::out) Chris@16: ); Chris@16: } else if (is_convertible::value) { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::in), Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::in) Chris@16: ); Chris@16: } else { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::out), Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::out) Chris@16: ); Chris@16: } Chris@16: } Chris@16: Chris@16: template Chris@16: void close(Device& dev, BOOST_IOS::openmode which) Chris@16: { Chris@16: BOOST_STATIC_ASSERT( Chris@16: (is_convertible::value) || Chris@16: (is_convertible::value) Chris@16: ); Chris@16: Chris@16: // Create a new device by composing the second filter2_ with dev. Chris@16: composite_device cmp(boost::ref(filter2_), dev); Chris@16: Chris@16: // Close input sequences in reverse order Chris@16: if ( which == BOOST_IOS::in && Chris@16: ( !is_convertible::value || Chris@16: is_convertible::value ) ) Chris@16: { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::in), Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::in) Chris@16: ); Chris@16: } Chris@16: Chris@16: // Close output sequences in forward order Chris@16: if ( which == BOOST_IOS::out && Chris@16: ( !is_convertible::value || Chris@16: is_convertible::value ) ) Chris@16: { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter1_, cmp, BOOST_IOS::out), Chris@16: detail::call_close(filter2_, dev, BOOST_IOS::out) Chris@16: ); Chris@16: } Chris@16: } Chris@16: Chris@16: template Chris@16: bool flush(Device& dev) Chris@16: { Chris@16: composite_device cmp(filter2_, dev); Chris@16: return iostreams::flush(filter1_, cmp); Chris@16: } Chris@16: Chris@16: std::streamsize optimal_buffer_size() const Chris@16: { Chris@16: std::streamsize first = iostreams::optimal_buffer_size(filter1_); Chris@16: std::streamsize second = iostreams::optimal_buffer_size(filter2_); Chris@16: return first < second ? second : first; Chris@16: } Chris@16: Chris@16: template // Avoid dependency on Chris@16: void imbue(const Locale& loc) Chris@16: { // To do: consider using RAII. Chris@16: iostreams::imbue(filter1_, loc); Chris@16: iostreams::imbue(filter2_, loc); Chris@16: } Chris@16: Chris@16: Filter1& first() { return filter1_; } Chris@16: Filter2& second() { return filter2_; } Chris@16: private: Chris@16: Filter1 filter1_; Chris@16: Filter2 filter2_; Chris@16: }; Chris@16: Chris@16: template Chris@16: struct composite_traits Chris@16: : mpl::if_< Chris@16: is_device, Chris@16: composite_device, Chris@16: composite_filter Chris@16: > Chris@16: { }; Chris@16: Chris@16: } // End namespace detail. Chris@16: Chris@16: template Chris@16: struct composite : detail::composite_traits::type { Chris@16: typedef typename detail::param_type::type param_type; Chris@16: typedef typename detail::composite_traits::type base; Chris@16: composite(const Filter& flt, param_type dev) Chris@16: : base(flt, dev) Chris@16: { } Chris@16: }; Chris@16: Chris@16: //--------------Implementation of compose-------------------------------------// Chris@16: Chris@16: // Note: The following workarounds are patterned after resolve.hpp. It has not Chris@16: // yet been confirmed that they are necessary. Chris@16: Chris@16: #ifndef BOOST_IOSTREAMS_BROKEN_OVERLOAD_RESOLUTION //-------------------------// Chris@16: # ifndef BOOST_IOSTREAMS_NO_STREAM_TEMPLATES //-------------------------------// Chris@16: Chris@16: template Chris@16: composite Chris@16: compose( const Filter& filter, const FilterOrDevice& fod Chris@16: BOOST_IOSTREAMS_DISABLE_IF_STREAM(FilterOrDevice) ) Chris@16: { return composite(filter, fod); } Chris@16: Chris@16: template Chris@16: composite< Filter, std::basic_streambuf > Chris@16: compose(const Filter& filter, std::basic_streambuf& sb) Chris@16: { return composite< Filter, std::basic_streambuf >(filter, sb); } Chris@16: Chris@16: template Chris@16: composite< Filter, std::basic_istream > Chris@16: compose(const Filter& filter, std::basic_istream& is) Chris@16: { return composite< Filter, std::basic_istream >(filter, is); } Chris@16: Chris@16: template Chris@16: composite< Filter, std::basic_ostream > Chris@16: compose(const Filter& filter, std::basic_ostream& os) Chris@16: { return composite< Filter, std::basic_ostream >(filter, os); } Chris@16: Chris@16: template Chris@16: composite< Filter, std::basic_iostream > Chris@16: compose(const Filter& filter, std::basic_iostream& io) Chris@16: { return composite< Filter, std::basic_iostream >(filter, io); } Chris@16: Chris@16: # else // # ifndef BOOST_IOSTREAMS_NO_STREAM_TEMPLATES //---------------------// Chris@16: Chris@16: template Chris@16: composite Chris@16: compose( const Filter& filter, const FilterOrDevice& fod Chris@16: BOOST_IOSTREAMS_DISABLE_IF_STREAM(FilterOrDevice) ) Chris@16: { return composite(filter, fod); } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& filter, std::streambuf& sb) Chris@16: { return composite(filter, sb); } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& filter, std::istream& is) Chris@16: { return composite(filter, is); } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& filter, std::ostream& os) Chris@16: { return composite(filter, os); } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& filter, std::iostream& io) Chris@16: { return composite(filter, io); } Chris@16: Chris@16: # endif // # ifndef BOOST_IOSTREAMS_NO_STREAM_TEMPLATES //--------------------// Chris@16: #else // #ifndef BOOST_IOSTREAMS_BROKEN_OVERLOAD_RESOLUTION //----------------// Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& flt, const Stream& strm, mpl::true_) Chris@16: { // Bad overload resolution. Chris@16: return composite(flt, const_cast(strm)); Chris@16: } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose(const Filter& flt, const FilterOrDevice& fod, mpl::false_) Chris@16: { return composite(flt, fod); } Chris@16: Chris@16: template Chris@16: composite Chris@16: compose( const Filter& flt, const FilterOrDevice& fod Chris@16: BOOST_IOSTREAMS_DISABLE_IF_STREAM(T) ) Chris@16: { return compose(flt, fod, is_std_io()); } Chris@16: Chris@16: # if !BOOST_WORKAROUND(__BORLANDC__, < 0x600) && \ Chris@16: !BOOST_WORKAROUND(BOOST_MSVC, <= 1300) && \ Chris@16: !defined(__GNUC__) // ---------------------------------------------------// Chris@16: Chris@16: template Chris@16: composite Chris@16: compose (const Filter& filter, FilterOrDevice& fod) Chris@16: { return composite(filter, fod); } Chris@16: Chris@16: # endif // Borland 5.x, VC6-7.0 or GCC 2.9x //--------------------------------// Chris@16: #endif // #ifndef BOOST_IOSTREAMS_BROKEN_OVERLOAD_RESOLUTION //---------------// Chris@16: Chris@16: //----------------------------------------------------------------------------// Chris@16: Chris@16: namespace detail { Chris@16: Chris@16: //--------------Implementation of composite_device---------------------------// Chris@16: Chris@16: template Chris@16: composite_device::composite_device Chris@16: (const Filter& flt, param_type dev) Chris@16: : filter_(flt), device_(dev) Chris@16: { } Chris@16: Chris@16: template Chris@16: inline std::streamsize composite_device::read Chris@16: (char_type* s, std::streamsize n) Chris@16: { return iostreams::read(filter_, device_, s, n); } Chris@16: Chris@16: template Chris@16: inline std::streamsize composite_device::write Chris@16: (const char_type* s, std::streamsize n) Chris@16: { return iostreams::write(filter_, device_, s, n); } Chris@16: Chris@16: template Chris@16: std::streampos composite_device::seek Chris@16: (stream_offset off, BOOST_IOS::seekdir way, BOOST_IOS::openmode which) Chris@16: { return iostreams::seek(filter_, device_, off, way, which); } Chris@16: Chris@16: template Chris@16: void composite_device::close() Chris@16: { Chris@16: BOOST_STATIC_ASSERT((!is_convertible::value)); Chris@16: BOOST_STATIC_ASSERT( Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) || Chris@16: !(is_convertible::value) Chris@16: ); Chris@16: Chris@16: // Close input sequences in reverse order and output sequences Chris@16: // in forward order Chris@16: if (!is_convertible::value) { Chris@16: detail::execute_all( Chris@16: detail::call_close(device_, BOOST_IOS::in), Chris@16: detail::call_close(filter_, device_, BOOST_IOS::in), Chris@16: detail::call_close(filter_, device_, BOOST_IOS::out), Chris@16: detail::call_close(device_, BOOST_IOS::out) Chris@16: ); Chris@16: } else if (is_convertible::value) { Chris@16: detail::execute_all( Chris@16: detail::call_close(device_, BOOST_IOS::in), Chris@16: detail::call_close(filter_, device_, BOOST_IOS::in) Chris@16: ); Chris@16: } else { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter_, device_, BOOST_IOS::out), Chris@16: detail::call_close(device_, BOOST_IOS::out) Chris@16: ); Chris@16: } Chris@16: } Chris@16: Chris@16: template Chris@16: void composite_device::close(BOOST_IOS::openmode which) Chris@16: { Chris@16: BOOST_STATIC_ASSERT((is_convertible::value)); Chris@16: BOOST_STATIC_ASSERT(!(is_convertible::value)); Chris@16: Chris@16: // Close input sequences in reverse order Chris@16: if (which == BOOST_IOS::in) { Chris@16: detail::execute_all( Chris@16: detail::call_close(device_, BOOST_IOS::in), Chris@16: detail::call_close(filter_, device_, BOOST_IOS::in) Chris@16: ); Chris@16: } Chris@16: Chris@16: // Close output sequences in forward order Chris@16: if (which == BOOST_IOS::out) { Chris@16: detail::execute_all( Chris@16: detail::call_close(filter_, device_, BOOST_IOS::out), Chris@16: detail::call_close(device_, BOOST_IOS::out) Chris@16: ); Chris@16: } Chris@16: } Chris@16: Chris@16: template Chris@16: bool composite_device::flush() Chris@16: { Chris@16: bool r1 = iostreams::flush(filter_, device_); Chris@16: bool r2 = iostreams::flush(device_); Chris@16: return r1 && r2; Chris@16: } Chris@16: Chris@16: template Chris@16: std::streamsize Chris@16: composite_device::optimal_buffer_size() const Chris@16: { return iostreams::optimal_buffer_size(device_); } Chris@16: Chris@16: } // End namespace detail. Chris@16: Chris@16: } } // End namespaces iostreams, boost. Chris@16: Chris@16: #include Chris@16: Chris@16: #endif // #ifndef BOOST_IOSTREAMS_COMPOSE_HPP_INCLUDED