Mercurial > projects > hoofbaby

comparison deps/Platinum/Source/Core/PltStreamPump.h @ 0:3425707ddbf6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Initial import (hopefully this mercurial stuff works...)
author fraserofthenight
date Mon, 06 Jul 2009 08:06:28 -0700
parents
children
comparison
equal deleted inserted replaced
-1:000000000000 0:3425707ddbf6
1 /*****************************************************************
2 |
3 | Platinum - Stream Pump
4 |
5 | Copyright (c) 2004-2008, Plutinosoft, LLC.
6 | All rights reserved.
7 | http://www.plutinosoft.com
8 |
9 | This program is free software; you can redistribute it and/or
10 | modify it under the terms of the GNU General Public License
11 | as published by the Free Software Foundation; either version 2
12 | of the License, or (at your option) any later version.
13 |
14 | OEMs, ISVs, VARs and other distributors that combine and
15 | distribute commercially licensed software with Platinum software
16 | and do not wish to distribute the source code for the commercially
17 | licensed software under version 2, or (at your option) any later
18 | version, of the GNU General Public License (the "GPL") must enter
19 | into a commercial license agreement with Plutinosoft, LLC.
20 |
21 | This program is distributed in the hope that it will be useful,
22 | but WITHOUT ANY WARRANTY; without even the implied warranty of
23 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
24 | GNU General Public License for more details.
25 |
26 | You should have received a copy of the GNU General Public License
27 | along with this program; see the file LICENSE.txt. If not, write to
28 | the Free Software Foundation, Inc.,
29 | 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
30 | http://www.gnu.org/licenses/gpl-2.0.html
31 |
32 ****************************************************************/
33
34 #ifndef _PLT_STREAM_PUMP_H_
35 #define _PLT_STREAM_PUMP_H_
36
37 /*----------------------------------------------------------------------
38 | includes
39 +---------------------------------------------------------------------*/
40 #include "NptStreams.h"
41 #include "NptRingBuffer.h"
42
43 /*----------------------------------------------------------------------
44 | PLT_PipeInputStream
45 +---------------------------------------------------------------------*/
46 class PLT_PipeInputStream
47 {
48 public:
49 // constructor and destructor
50 virtual ~PLT_PipeInputStream() {};
51
52 // methods
53 virtual NPT_Result Receive(NPT_InputStream& stream, NPT_Size max_bytes_to_read, NPT_Size* bytes_read = 0) = 0;
54 };
55
56 typedef NPT_Reference<PLT_PipeInputStream> PLT_PipeInputStreamReference;
57
58 /*----------------------------------------------------------------------
59 | PLT_PipeOutputStream
60 +---------------------------------------------------------------------*/
61 class PLT_PipeOutputStream
62 {
63 public:
64 // constructor and destructor
65 virtual ~PLT_PipeOutputStream() {};
66
67 // methods
68 virtual NPT_Result Transmit(NPT_OutputStream& stream) = 0;
69 };
70
71 typedef NPT_Reference<PLT_PipeOutputStream> PLT_PipeOutputStreamReference;
72
73 /*----------------------------------------------------------------------
74 | PLT_StreamPump class
75 +---------------------------------------------------------------------*/
76 class PLT_StreamPump
77 {
78 public:
79 virtual ~PLT_StreamPump();
80
81 protected:
82 // methods
83 PLT_StreamPump(NPT_Size size = 65535);
84 NPT_Result PullData(NPT_InputStream& input, NPT_Size max_bytes_to_read);
85 NPT_Result PushData(NPT_OutputStream& output, NPT_Size& bytes_written);
86
87 // members
88 NPT_RingBuffer* m_RingBuffer;
89 NPT_Offset m_TotalBytesRead;
90 NPT_Offset m_TotalBytesWritten;
91 };
92
93 /*----------------------------------------------------------------------
94 | PLT_PipeInputStreamPump class
95 +---------------------------------------------------------------------*/
96 class PLT_PipeInputStreamPump : public PLT_StreamPump,
97 public PLT_PipeInputStream
98 {
99 public:
100 PLT_PipeInputStreamPump(NPT_OutputStreamReference& output, NPT_Size size = 65535);
101 virtual ~PLT_PipeInputStreamPump();
102
103 NPT_Result Receive(NPT_InputStream& input, NPT_Size max_bytes_to_read, NPT_Size* bytes_read);
104
105 protected:
106 NPT_OutputStreamReference m_Output;
107 NPT_Result m_LastRes;
108 };
109
110 /*----------------------------------------------------------------------
111 | PLT_PipeInputStreamPump class
112 +---------------------------------------------------------------------*/
113 class PLT_PipeOutputStreamPump : public PLT_StreamPump,
114 public PLT_PipeOutputStream
115 {
116 public:
117 PLT_PipeOutputStreamPump(NPT_InputStreamReference& input,
118 NPT_Size size = 65535,
119 NPT_Size max_bytes_to_read = 0);
120 virtual ~PLT_PipeOutputStreamPump();
121
122 NPT_Result Transmit(NPT_OutputStream& output);
123
124 protected:
125 NPT_InputStreamReference m_Input;
126 NPT_Size m_MaxBytesToRead;
127 NPT_Result m_LastRes;
128 };
129
130
131 #endif // _PLT_STREAM_PUMP_H_