1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/ossrv_pub/boost_apis/boost/iostreams/tee.hpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,170 @@
1.4 +// (C) Copyright Jonathan Turkanis 2005.
1.5 +// Distributed under the Boost Software License, Version 1.0. (See accompanying
1.6 +// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt.)
1.7 +
1.8 +// See http://www.boost.org/libs/iostreams for documentation.
1.9 +
1.10 +#ifndef BOOST_IOSTREAMS_TEE_HPP_INCLUDED
1.11 +#define BOOST_IOSTREAMS_TEE_HPP_INCLUDED
1.12 +
1.13 +#if defined(_MSC_VER) && (_MSC_VER >= 1020)
1.14 +# pragma once
1.15 +#endif
1.16 +
1.17 +#include <cassert>
1.18 +#include <boost/config.hpp> // BOOST_DEDUCE_TYPENAME.
1.19 +#include <boost/iostreams/categories.hpp>
1.20 +#include <boost/iostreams/detail/adapter/basic_adapter.hpp>
1.21 +#include <boost/iostreams/detail/call_traits.hpp>
1.22 +#include <boost/iostreams/detail/closer.hpp>
1.23 +#include <boost/iostreams/operations.hpp>
1.24 +#include <boost/iostreams/pipeline.hpp>
1.25 +#include <boost/iostreams/traits.hpp>
1.26 +#include <boost/static_assert.hpp>
1.27 +#include <boost/type_traits/is_convertible.hpp>
1.28 +#include <boost/type_traits/is_same.hpp>
1.29 +
1.30 +namespace boost { namespace iostreams {
1.31 +
1.32 +//
1.33 +// Template name: tee_filter.
1.34 +// Template paramters:
1.35 +// Device - A blocking Sink.
1.36 +//
1.37 +template<typename Device>
1.38 +class tee_filter : public detail::basic_adapter<Device> {
1.39 +public:
1.40 + typedef typename detail::param_type<Device>::type param_type;
1.41 + typedef typename char_type_of<Device>::type char_type;
1.42 + struct category
1.43 + : multichar_output_filter_tag,
1.44 + closable_tag,
1.45 + flushable_tag,
1.46 + localizable_tag,
1.47 + optimally_buffered_tag
1.48 + { };
1.49 +
1.50 + BOOST_STATIC_ASSERT((
1.51 + is_convertible< // Using mode_of causes failures on VC6-7.0.
1.52 + BOOST_DEDUCED_TYPENAME iostreams::category_of<Device>::type, output
1.53 + >::value
1.54 + ));
1.55 +
1.56 + explicit tee_filter(param_type dev)
1.57 + : detail::basic_adapter<Device>(dev)
1.58 + { }
1.59 +
1.60 + template<typename Sink>
1.61 + std::streamsize write(Sink& snk, const char_type* s, std::streamsize n)
1.62 + {
1.63 + std::streamsize result = iostreams::write(snk, s, n);
1.64 + std::streamsize result2 = iostreams::write(this->component(), s, result);
1.65 + (void) result2; // Suppress 'unused variable' warning.
1.66 + assert(result == result2);
1.67 + return result;
1.68 + }
1.69 +
1.70 + template<typename Next>
1.71 + void close( Next&,
1.72 + BOOST_IOS::openmode which =
1.73 + BOOST_IOS::in | BOOST_IOS::out )
1.74 + { iostreams::close(this->component(), which); }
1.75 +
1.76 + template<typename Sink>
1.77 + bool flush(Sink& snk)
1.78 + {
1.79 + bool r1 = iostreams::flush(snk);
1.80 + bool r2 = iostreams::flush(this->component());
1.81 + return r1 && r2;
1.82 + }
1.83 +};
1.84 +BOOST_IOSTREAMS_PIPABLE(tee_filter, 1)
1.85 +
1.86 +//
1.87 +// Template name: tee_device.
1.88 +// Template paramters:
1.89 +// Sink1 - A blocking Sink.
1.90 +// Sink2 - A blocking Sink.
1.91 +//
1.92 +template<typename Sink1, typename Sink2>
1.93 +class tee_device {
1.94 +public:
1.95 + typedef typename detail::param_type<Sink1>::type param_type1;
1.96 + typedef typename detail::param_type<Sink2>::type param_type2;
1.97 + typedef typename detail::value_type<Sink1>::type value_type1;
1.98 + typedef typename detail::value_type<Sink2>::type value_type2;
1.99 + typedef typename char_type_of<Sink1>::type char_type;
1.100 + BOOST_STATIC_ASSERT((
1.101 + is_same<
1.102 + char_type,
1.103 + BOOST_DEDUCED_TYPENAME char_type_of<Sink2>::type
1.104 + >::value
1.105 + ));
1.106 + BOOST_STATIC_ASSERT((
1.107 + is_convertible< // Using mode_of causes failures on VC6-7.0.
1.108 + BOOST_DEDUCED_TYPENAME iostreams::category_of<Sink1>::type, output
1.109 + >::value
1.110 + ));
1.111 + BOOST_STATIC_ASSERT((
1.112 + is_convertible< // Using mode_of causes failures on VC6-7.0.
1.113 + BOOST_DEDUCED_TYPENAME iostreams::category_of<Sink2>::type, output
1.114 + >::value
1.115 + ));
1.116 + struct category
1.117 + : output,
1.118 + device_tag,
1.119 + closable_tag,
1.120 + flushable_tag,
1.121 + localizable_tag,
1.122 + optimally_buffered_tag
1.123 + { };
1.124 + tee_device(param_type1 sink1, param_type2 sink2)
1.125 + : sink1_(sink1), sink2_(sink2)
1.126 + { }
1.127 + std::streamsize write(const char_type* s, std::streamsize n)
1.128 + {
1.129 + std::streamsize result1 = iostreams::write(sink1_, s, n);
1.130 + std::streamsize result2 = iostreams::write(sink2_, s, n);
1.131 + (void) result1; // Suppress 'unused variable' warning.
1.132 + (void) result2;
1.133 + assert(result1 == n && result2 == n);
1.134 + return n;
1.135 + }
1.136 + void close(BOOST_IOS::openmode which = BOOST_IOS::in | BOOST_IOS::out)
1.137 + {
1.138 + detail::external_closer<Sink2> close2(sink2_, which);
1.139 + detail::external_closer<Sink1> close1(sink1_, which);
1.140 + }
1.141 + bool flush()
1.142 + {
1.143 + bool r1 = iostreams::flush(sink1_);
1.144 + bool r2 = iostreams::flush(sink2_);
1.145 + return r1 && r2;
1.146 + }
1.147 + template<typename Locale>
1.148 + void imbue(const Locale& loc)
1.149 + {
1.150 + iostreams::imbue(sink1_, loc);
1.151 + iostreams::imbue(sink2_, loc);
1.152 + }
1.153 + std::streamsize optimal_buffer_size() const
1.154 + {
1.155 + return (std::max) ( iostreams::optimal_buffer_size(sink1_),
1.156 + iostreams::optimal_buffer_size(sink2_) );
1.157 + }
1.158 +private:
1.159 + value_type1 sink1_;
1.160 + value_type2 sink2_;
1.161 +};
1.162 +
1.163 +template<typename Sink>
1.164 +tee_filter<Sink> tee(const Sink& snk)
1.165 +{ return tee_filter<Sink>(snk); }
1.166 +
1.167 +template<typename Sink1, typename Sink2>
1.168 +tee_device<Sink1, Sink2> tee(const Sink1& sink1, const Sink2& sink2)
1.169 +{ return tee_device<Sink1, Sink2>(sink1, sink2); }
1.170 +
1.171 +} } // End namespaces iostreams, boost.
1.172 +
1.173 +#endif // #ifndef BOOST_IOSTREAMS_TEE_HPP_INCLUDED