1*8a106958SDamjan Jovanovic /**************************************************************
2*8a106958SDamjan Jovanovic *
3*8a106958SDamjan Jovanovic * Licensed to the Apache Software Foundation (ASF) under one
4*8a106958SDamjan Jovanovic * or more contributor license agreements. See the NOTICE file
5*8a106958SDamjan Jovanovic * distributed with this work for additional information
6*8a106958SDamjan Jovanovic * regarding copyright ownership. The ASF licenses this file
7*8a106958SDamjan Jovanovic * to you under the Apache License, Version 2.0 (the
8*8a106958SDamjan Jovanovic * "License"); you may not use this file except in compliance
9*8a106958SDamjan Jovanovic * with the License. You may obtain a copy of the License at
10*8a106958SDamjan Jovanovic *
11*8a106958SDamjan Jovanovic * http://www.apache.org/licenses/LICENSE-2.0
12*8a106958SDamjan Jovanovic *
13*8a106958SDamjan Jovanovic * Unless required by applicable law or agreed to in writing,
14*8a106958SDamjan Jovanovic * software distributed under the License is distributed on an
15*8a106958SDamjan Jovanovic * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*8a106958SDamjan Jovanovic * KIND, either express or implied. See the License for the
17*8a106958SDamjan Jovanovic * specific language governing permissions and limitations
18*8a106958SDamjan Jovanovic * under the License.
19*8a106958SDamjan Jovanovic *
20*8a106958SDamjan Jovanovic *************************************************************/
21*8a106958SDamjan Jovanovic
22*8a106958SDamjan Jovanovic
23*8a106958SDamjan Jovanovic
24*8a106958SDamjan Jovanovic #ifndef CSV_BSTREAM_HXX
25*8a106958SDamjan Jovanovic #define CSV_BSTREAM_HXX
26*8a106958SDamjan Jovanovic
27*8a106958SDamjan Jovanovic #include <string.h>
28*8a106958SDamjan Jovanovic #include <cosv/string.hxx>
29*8a106958SDamjan Jovanovic
30*8a106958SDamjan Jovanovic
31*8a106958SDamjan Jovanovic namespace csv
32*8a106958SDamjan Jovanovic {
33*8a106958SDamjan Jovanovic
34*8a106958SDamjan Jovanovic
35*8a106958SDamjan Jovanovic enum seek_dir
36*8a106958SDamjan Jovanovic {
37*8a106958SDamjan Jovanovic beg = 0,
38*8a106958SDamjan Jovanovic cur = 1,
39*8a106958SDamjan Jovanovic end = 2
40*8a106958SDamjan Jovanovic };
41*8a106958SDamjan Jovanovic
42*8a106958SDamjan Jovanovic
43*8a106958SDamjan Jovanovic class bistream
44*8a106958SDamjan Jovanovic {
45*8a106958SDamjan Jovanovic public:
46*8a106958SDamjan Jovanovic // LIFECYCLE
~bistream()47*8a106958SDamjan Jovanovic virtual ~bistream() {}
48*8a106958SDamjan Jovanovic
49*8a106958SDamjan Jovanovic // OPERATIONS
50*8a106958SDamjan Jovanovic /// @return Number of actually read bytes.
51*8a106958SDamjan Jovanovic uintt read(
52*8a106958SDamjan Jovanovic void * out_pDest,
53*8a106958SDamjan Jovanovic uintt i_nNrofBytes);
54*8a106958SDamjan Jovanovic // INQUIRY
55*8a106958SDamjan Jovanovic /** @return True, if already one try to read had failed.
56*8a106958SDamjan Jovanovic There is no guarantee, that it returns true, if end of data
57*8a106958SDamjan Jovanovic is just reached.
58*8a106958SDamjan Jovanovic Though it will return false, if there is still somemething
59*8a106958SDamjan Jovanovic to read.
60*8a106958SDamjan Jovanovic */
61*8a106958SDamjan Jovanovic bool eod() const;
62*8a106958SDamjan Jovanovic
63*8a106958SDamjan Jovanovic private:
64*8a106958SDamjan Jovanovic virtual uintt do_read(
65*8a106958SDamjan Jovanovic void * out_pDest,
66*8a106958SDamjan Jovanovic uintt i_nNrofBytes) = 0;
67*8a106958SDamjan Jovanovic virtual bool inq_eod() const = 0;
68*8a106958SDamjan Jovanovic };
69*8a106958SDamjan Jovanovic
70*8a106958SDamjan Jovanovic
71*8a106958SDamjan Jovanovic class bostream
72*8a106958SDamjan Jovanovic {
73*8a106958SDamjan Jovanovic public:
74*8a106958SDamjan Jovanovic // LIFECYCLE
~bostream()75*8a106958SDamjan Jovanovic virtual ~bostream() {}
76*8a106958SDamjan Jovanovic
77*8a106958SDamjan Jovanovic // OPERATIONS
78*8a106958SDamjan Jovanovic /// @return Number of actually written bytes.
79*8a106958SDamjan Jovanovic uintt write(
80*8a106958SDamjan Jovanovic const void * i_pSrc,
81*8a106958SDamjan Jovanovic uintt i_nNrofBytes);
82*8a106958SDamjan Jovanovic /// @return Number of actually written bytes.
83*8a106958SDamjan Jovanovic uintt write(
84*8a106958SDamjan Jovanovic const char * i_pSrc );
85*8a106958SDamjan Jovanovic /// @return Number of actually written bytes.
86*8a106958SDamjan Jovanovic uintt write(
87*8a106958SDamjan Jovanovic const String & i_pSrc );
88*8a106958SDamjan Jovanovic private:
89*8a106958SDamjan Jovanovic virtual uintt do_write(
90*8a106958SDamjan Jovanovic const void * i_pSrc,
91*8a106958SDamjan Jovanovic uintt i_nNrofBytes) = 0;
92*8a106958SDamjan Jovanovic };
93*8a106958SDamjan Jovanovic
94*8a106958SDamjan Jovanovic
95*8a106958SDamjan Jovanovic class bstream : public bistream,
96*8a106958SDamjan Jovanovic public bostream
97*8a106958SDamjan Jovanovic {
98*8a106958SDamjan Jovanovic public:
99*8a106958SDamjan Jovanovic uintt seek(
100*8a106958SDamjan Jovanovic intt i_nDistanceFromBegin,
101*8a106958SDamjan Jovanovic seek_dir i_eStartPoint = ::csv::beg );
102*8a106958SDamjan Jovanovic uintt position() const;
103*8a106958SDamjan Jovanovic
104*8a106958SDamjan Jovanovic private:
105*8a106958SDamjan Jovanovic virtual uintt do_seek(
106*8a106958SDamjan Jovanovic intt i_nDistance,
107*8a106958SDamjan Jovanovic seek_dir i_eStartPoint = ::csv::beg ) = 0;
108*8a106958SDamjan Jovanovic virtual uintt inq_position() const = 0;
109*8a106958SDamjan Jovanovic };
110*8a106958SDamjan Jovanovic
111*8a106958SDamjan Jovanovic
112*8a106958SDamjan Jovanovic // IMPLEMENTATION
113*8a106958SDamjan Jovanovic inline uintt
read(void * o_pDest,uintt i_nNrofBytes)114*8a106958SDamjan Jovanovic bistream::read( void * o_pDest,
115*8a106958SDamjan Jovanovic uintt i_nNrofBytes)
116*8a106958SDamjan Jovanovic { return do_read(o_pDest, i_nNrofBytes); }
117*8a106958SDamjan Jovanovic inline bool
eod() const118*8a106958SDamjan Jovanovic bistream::eod() const
119*8a106958SDamjan Jovanovic { return inq_eod(); }
120*8a106958SDamjan Jovanovic
121*8a106958SDamjan Jovanovic inline uintt
write(const void * i_pSrc,uintt i_nNrofBytes)122*8a106958SDamjan Jovanovic bostream::write( const void * i_pSrc,
123*8a106958SDamjan Jovanovic uintt i_nNrofBytes)
124*8a106958SDamjan Jovanovic { return do_write( i_pSrc, i_nNrofBytes ); }
125*8a106958SDamjan Jovanovic inline uintt
write(const char * i_sSrc)126*8a106958SDamjan Jovanovic bostream::write( const char * i_sSrc )
127*8a106958SDamjan Jovanovic { return write( i_sSrc, strlen(i_sSrc) ); }
128*8a106958SDamjan Jovanovic inline uintt
write(const String & i_sSrc)129*8a106958SDamjan Jovanovic bostream::write( const String & i_sSrc )
130*8a106958SDamjan Jovanovic { return write( i_sSrc.c_str(), i_sSrc.length() ); }
131*8a106958SDamjan Jovanovic
132*8a106958SDamjan Jovanovic inline uintt
seek(intt i_nDistance,seek_dir i_eStartPoint)133*8a106958SDamjan Jovanovic bstream::seek( intt i_nDistance,
134*8a106958SDamjan Jovanovic seek_dir i_eStartPoint )
135*8a106958SDamjan Jovanovic { return do_seek( i_nDistance, i_eStartPoint ); }
136*8a106958SDamjan Jovanovic inline uintt
position() const137*8a106958SDamjan Jovanovic bstream::position() const
138*8a106958SDamjan Jovanovic { return inq_position(); }
139*8a106958SDamjan Jovanovic
140*8a106958SDamjan Jovanovic
141*8a106958SDamjan Jovanovic
142*8a106958SDamjan Jovanovic } // namespace csv
143*8a106958SDamjan Jovanovic
144*8a106958SDamjan Jovanovic
145*8a106958SDamjan Jovanovic #endif
146