|
sl@0
|
1 |
// (C) Copyright Jonathan Turkanis 2003.
|
|
sl@0
|
2 |
// Distributed under the Boost Software License, Version 1.0. (See accompanying
|
|
sl@0
|
3 |
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt.)
|
|
sl@0
|
4 |
|
|
sl@0
|
5 |
// See http://www.boost.org/libs/iostreams for documentation.
|
|
sl@0
|
6 |
|
|
sl@0
|
7 |
#ifndef BOOST_IOSTREAMS_PIPABLE_HPP_INCLUDED
|
|
sl@0
|
8 |
#define BOOST_IOSTREAMS_PIPABLE_HPP_INCLUDED
|
|
sl@0
|
9 |
|
|
sl@0
|
10 |
#if defined(_MSC_VER) && (_MSC_VER >= 1020)
|
|
sl@0
|
11 |
# pragma once
|
|
sl@0
|
12 |
#endif
|
|
sl@0
|
13 |
|
|
sl@0
|
14 |
#include <boost/config.hpp> // BOOST_MSVC.
|
|
sl@0
|
15 |
#include <boost/detail/workaround.hpp>
|
|
sl@0
|
16 |
#include <boost/iostreams/detail/template_params.hpp>
|
|
sl@0
|
17 |
#include <boost/iostreams/traits.hpp>
|
|
sl@0
|
18 |
#include <boost/mpl/bool.hpp>
|
|
sl@0
|
19 |
#include <boost/preprocessor/punctuation/comma_if.hpp>
|
|
sl@0
|
20 |
#include <boost/preprocessor/repetition/enum_params.hpp>
|
|
sl@0
|
21 |
#include <boost/static_assert.hpp>
|
|
sl@0
|
22 |
#if BOOST_WORKAROUND(BOOST_MSVC, < 1300)
|
|
sl@0
|
23 |
# include <boost/type_traits/is_base_and_derived.hpp>
|
|
sl@0
|
24 |
#endif
|
|
sl@0
|
25 |
|
|
sl@0
|
26 |
#define BOOST_IOSTREAMS_PIPABLE(filter, arity) \
|
|
sl@0
|
27 |
template< BOOST_PP_ENUM_PARAMS(arity, typename T) \
|
|
sl@0
|
28 |
BOOST_PP_COMMA_IF(arity) typename Component> \
|
|
sl@0
|
29 |
::boost::iostreams::pipeline< \
|
|
sl@0
|
30 |
::boost::iostreams::detail::pipeline_segment< \
|
|
sl@0
|
31 |
filter BOOST_IOSTREAMS_TEMPLATE_ARGS(arity, T) \
|
|
sl@0
|
32 |
>, \
|
|
sl@0
|
33 |
Component \
|
|
sl@0
|
34 |
> operator|( const filter BOOST_IOSTREAMS_TEMPLATE_ARGS(arity, T)& f, \
|
|
sl@0
|
35 |
const Component& c ) \
|
|
sl@0
|
36 |
{ \
|
|
sl@0
|
37 |
typedef ::boost::iostreams::detail::pipeline_segment< \
|
|
sl@0
|
38 |
filter BOOST_IOSTREAMS_TEMPLATE_ARGS(arity, T) \
|
|
sl@0
|
39 |
> segment; \
|
|
sl@0
|
40 |
return ::boost::iostreams::pipeline<segment, Component> \
|
|
sl@0
|
41 |
(segment(f), c); \
|
|
sl@0
|
42 |
} \
|
|
sl@0
|
43 |
/**/
|
|
sl@0
|
44 |
|
|
sl@0
|
45 |
namespace boost { namespace iostreams {
|
|
sl@0
|
46 |
|
|
sl@0
|
47 |
template<typename Pipeline, typename Component>
|
|
sl@0
|
48 |
struct pipeline;
|
|
sl@0
|
49 |
|
|
sl@0
|
50 |
namespace detail {
|
|
sl@0
|
51 |
|
|
sl@0
|
52 |
#if BOOST_WORKAROUND(BOOST_MSVC, <= 1300)
|
|
sl@0
|
53 |
struct pipeline_base { };
|
|
sl@0
|
54 |
|
|
sl@0
|
55 |
template<typename T>
|
|
sl@0
|
56 |
struct is_pipeline
|
|
sl@0
|
57 |
: is_base_and_derived<pipeline_base, T>
|
|
sl@0
|
58 |
{ };
|
|
sl@0
|
59 |
#endif
|
|
sl@0
|
60 |
#if BOOST_WORKAROUND(__BORLANDC__, < 0x600)
|
|
sl@0
|
61 |
template<typename T>
|
|
sl@0
|
62 |
struct is_pipeline : mpl::false_ { };
|
|
sl@0
|
63 |
|
|
sl@0
|
64 |
template<typename Pipeline, typename Component>
|
|
sl@0
|
65 |
struct is_pipeline< pipeline<Pipeline, Component> > : mpl::true_ { };
|
|
sl@0
|
66 |
#endif
|
|
sl@0
|
67 |
|
|
sl@0
|
68 |
template<typename Component>
|
|
sl@0
|
69 |
class pipeline_segment
|
|
sl@0
|
70 |
#if BOOST_WORKAROUND(BOOST_MSVC, <= 1300)
|
|
sl@0
|
71 |
: pipeline_base
|
|
sl@0
|
72 |
#endif
|
|
sl@0
|
73 |
{
|
|
sl@0
|
74 |
public:
|
|
sl@0
|
75 |
pipeline_segment(const Component& component)
|
|
sl@0
|
76 |
: component_(component)
|
|
sl@0
|
77 |
{ }
|
|
sl@0
|
78 |
template<typename Fn>
|
|
sl@0
|
79 |
void for_each(Fn fn) const { fn(component_); }
|
|
sl@0
|
80 |
template<typename Chain>
|
|
sl@0
|
81 |
void push(Chain& chn) const { chn.push(component_); }
|
|
sl@0
|
82 |
private:
|
|
sl@0
|
83 |
const Component& component_;
|
|
sl@0
|
84 |
};
|
|
sl@0
|
85 |
|
|
sl@0
|
86 |
} // End namespace detail.
|
|
sl@0
|
87 |
|
|
sl@0
|
88 |
//------------------Definition of Pipeline------------------------------------//
|
|
sl@0
|
89 |
|
|
sl@0
|
90 |
template<typename Pipeline, typename Component>
|
|
sl@0
|
91 |
struct pipeline : Pipeline {
|
|
sl@0
|
92 |
typedef Pipeline pipeline_type;
|
|
sl@0
|
93 |
typedef Component component_type;
|
|
sl@0
|
94 |
pipeline(const Pipeline& p, const Component& component)
|
|
sl@0
|
95 |
: Pipeline(p), component_(component)
|
|
sl@0
|
96 |
{ }
|
|
sl@0
|
97 |
template<typename Fn>
|
|
sl@0
|
98 |
void for_each(Fn fn) const
|
|
sl@0
|
99 |
{
|
|
sl@0
|
100 |
Pipeline::for_each(fn);
|
|
sl@0
|
101 |
fn(component_);
|
|
sl@0
|
102 |
}
|
|
sl@0
|
103 |
template<typename Chain>
|
|
sl@0
|
104 |
void push(Chain& chn) const
|
|
sl@0
|
105 |
{
|
|
sl@0
|
106 |
Pipeline::push(chn);
|
|
sl@0
|
107 |
chn.push(component_);
|
|
sl@0
|
108 |
}
|
|
sl@0
|
109 |
const Pipeline& tail() const { return *this; }
|
|
sl@0
|
110 |
const Component& head() const { return component_; }
|
|
sl@0
|
111 |
private:
|
|
sl@0
|
112 |
const Component& component_;
|
|
sl@0
|
113 |
};
|
|
sl@0
|
114 |
|
|
sl@0
|
115 |
template<typename Pipeline, typename Filter, typename Component>
|
|
sl@0
|
116 |
pipeline<pipeline<Pipeline, Filter>, Component>
|
|
sl@0
|
117 |
operator|(const pipeline<Pipeline, Filter>& p, const Component& cmp)
|
|
sl@0
|
118 |
{
|
|
sl@0
|
119 |
BOOST_STATIC_ASSERT(is_filter<Filter>::value);
|
|
sl@0
|
120 |
return pipeline<pipeline<Pipeline, Filter>, Component>(p, cmp);
|
|
sl@0
|
121 |
}
|
|
sl@0
|
122 |
|
|
sl@0
|
123 |
} } // End namespaces iostreams, boost.
|
|
sl@0
|
124 |
|
|
sl@0
|
125 |
#endif // #ifndef BOOST_IOSTREAMS_PIPABLE_HPP_INCLUDED
|