1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
|
/* -*- C++ -*-
* Copyright (C) 2003 Thiago Macieira <[email protected]>
*
*
* Permission is hereby granted, free of charge, to any person obtaining
* a copy of this software and associated documentation files (the
* "Software"), to deal in the Software without restriction, including
* without limitation the rights to use, copy, modify, merge, publish,
* distribute, sublicense, and/or sell copies of the Software, and to
* permit persons to whom the Software is furnished to do so, subject to
* the following conditions:
*
* The above copyright notice and this permission notice shall be included
* in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
* LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
#ifndef KBUFFEREDSOCKET_H
#define KBUFFEREDSOCKET_H
#include <tqobject.h>
#include <tqcstring.h>
#include <tqvaluelist.h>
#include "kstreamsocket.h"
#include <tdelibs_export.h>
class KIOBufferBase;
namespace KNetwork {
class KBufferedSocketPrivate;
/** @class KBufferedSocket kbufferedsocket.h kbufferedsocket.h
* @brief Buffered stream sockets.
*
* This class allows the user to create and operate buffered stream sockets
* such as those used in most Internet connections. This class is
* also the one that resembles the most to the old @ref QSocket
* implementation.
*
* Objects of this type operate only in non-blocking mode. A call to
* setBlocking(true) will result in an error.
*
* @note Buffered sockets only make sense if you're using them from
* the main (event-loop) thread. This is actually a restriction
* imposed by Qt's TQSocketNotifier. If you want to use a socket
* in an auxiliary thread, please use KStreamSocket.
*
* @see KNetwork::KStreamSocket, KNetwork::KServerSocket
* @author Thiago Macieira <[email protected]>
*/
class TDECORE_EXPORT KBufferedSocket: public KStreamSocket
{
Q_OBJECT
TQ_OBJECT
public:
/**
* Default constructor.
*
* @param node destination host
* @param service destination service to connect to
* @param parent the parent object for this object
* @param name the internal name for this object
*/
KBufferedSocket(const TQString& node = TQString::null, const TQString& service = TQString::null,
TQObject* parent = 0L, const char *name = 0L);
/**
* Destructor.
*/
virtual ~KBufferedSocket();
/**
* Be sure to catch new devices.
*/
virtual void setSocketDevice(KSocketDevice* device);
protected:
/**
* Buffered sockets can only operate in non-blocking mode.
*/
virtual bool setSocketOptions(int opts);
public:
/**
* Closes the socket for new data, but allow data that had been buffered
* for output with @ref writeBlock to be still be written.
*
* @sa closeNow
*/
virtual void close();
/**
* Make use of the buffers.
*/
#ifdef USE_QT3
virtual TQ_LONG bytesAvailable() const;
#endif
#ifdef USE_QT4
virtual qint64 bytesAvailable() const;
#endif
/**
* Make use of buffers.
*/
virtual TQ_LONG waitForMore(int msecs, bool *timeout = 0L);
/**
* Reads data from the socket. Make use of buffers.
*/
virtual TQT_TQIO_LONG tqreadBlock(char *data, TQT_TQIO_ULONG maxlen);
/**
* @overload
* Reads data from a socket.
*
* The @p from parameter is always set to @ref peerAddress()
*/
virtual TQT_TQIO_LONG tqreadBlock(char *data, TQT_TQIO_ULONG maxlen, KSocketAddress& from);
/**
* Peeks data from the socket.
*/
virtual TQ_LONG peekBlock(char *data, TQ_ULONG maxlen);
/**
* @overload
* Peeks data from the socket.
*
* The @p from parameter is always set to @ref peerAddress()
*/
virtual TQ_LONG peekBlock(char *data, TQ_ULONG maxlen, KSocketAddress &from);
/**
* Writes data to the socket.
*/
virtual TQT_TQIO_LONG tqwriteBlock(const char *data, TQT_TQIO_ULONG len);
/**
* @overload
* Writes data to the socket.
*
* The @p to parameter is discarded.
*/
virtual TQT_TQIO_LONG tqwriteBlock(const char *data, TQT_TQIO_ULONG len, const KSocketAddress& to);
/**
* Catch changes.
*/
virtual void enableRead(bool enable);
/**
* Catch changes.
*/
virtual void enableWrite(bool enable);
/**
* Sets the use of input buffering.
*/
void setInputBuffering(bool enable);
/**
* Retrieves the input buffer object.
*/
KIOBufferBase* inputBuffer();
/**
* Sets the use of output buffering.
*/
void setOutputBuffering(bool enable);
/**
* Retrieves the output buffer object.
*/
KIOBufferBase* outputBuffer();
/**
* Returns the length of the output buffer.
*/
#ifdef USE_QT3
virtual TQ_ULONG bytesToWrite() const;
#endif
#ifdef USE_QT4
virtual qint64 bytesToWrite() const;
#endif
/**
* Closes the socket and discards any output data that had been buffered
* with @ref writeBlock but that had not yet been written.
*
* @sa close
*/
virtual void closeNow();
/**
* Returns true if a line can be read with @ref readLine
*/
bool canReadLine() const;
/**
* Reads a line of data from the socket buffers.
*/
TQCString readLine();
// KDE4: make virtual, add timeout to match the Qt4 signature
// and move to another class up the hierarchy
/**
* Blocks until the connection is either established, or completely
* failed.
*/
void waitForConnect();
protected:
/**
* Catch connection to clear the buffers
*/
virtual void stateChanging(SocketState newState);
protected slots:
/**
* Slot called when there's read activity.
*/
virtual void slotReadActivity();
/**
* Slot called when there's write activity.
*/
virtual void slotWriteActivity();
signals:
/**
* This signal is emitted whenever data is written.
*/
void bytesWritten(int bytes);
private:
KBufferedSocket(const KBufferedSocket&);
KBufferedSocket& operator=(const KBufferedSocket&);
KBufferedSocketPrivate *d;
public:
// KDE4: remove this function
/**
* @deprecated
* Closes the socket.
*
* This function is provided to ease porting from KExtendedSocket,
* which required a call to reset() in order to be able to connect again
* using the same device. This is not necessary in KBufferedSocket any more.
*/
#ifdef USE_QT3
inline void reset()
#endif
#ifdef USE_QT4
inline bool reset()
#endif
{ closeNow(); }
};
} // namespace KNetwork
#endif
|