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
270
271
272
273
274
275
|
/****************************************************************************
**
** Implementation of TQSocketNotifier class
**
** Created : 951114
**
** Copyright (C) 2010 Timothy Pearson and (C) 1992-2008 Trolltech ASA.
**
** This file is part of the kernel module of the TQt GUI Toolkit.
**
** This file may be used under the terms of the GNU General
** Public License versions 2.0 or 3.0 as published by the Free
** Software Foundation and appearing in the files LICENSE.GPL2
** and LICENSE.GPL3 included in the packaging of this file.
** Alternatively you may (at your option) use any later version
** of the GNU General Public License if such license has been
** publicly approved by Trolltech ASA (or its successors, if any)
** and the KDE Free TQt Foundation.
**
** Please review the following information to ensure GNU General
** Public Licensing requirements will be met:
** http://trolltech.com/products/qt/licenses/licensing/opensource/.
** If you are unsure which license is appropriate for your use, please
** review the following information:
** http://trolltech.com/products/qt/licenses/licensing/licensingoverview
** or contact the sales department at sales@trolltech.com.
**
** This file may be used under the terms of the Q Public License as
** defined by Trolltech ASA and appearing in the file LICENSE.TQPL
** included in the packaging of this file. Licensees holding valid TQt
** Commercial licenses may use this file in accordance with the TQt
** Commercial License Agreement provided with the Software.
**
** This file is provided "AS IS" with NO WARRANTY OF ANY KIND,
** INCLUDING THE WARRANTIES OF DESIGN, MERCHANTABILITY AND FITNESS FOR
** A PARTICULAR PURPOSE. Trolltech reserves all rights not granted
** herein.
**
**********************************************************************/
#include "tqsocketnotifier.h"
#include "tqapplication.h"
#include "tqevent.h"
#include "tqeventloop.h"
#include "tqplatformdefs.h"
#if defined(TQ_OS_UNIX)
#include <sys/types.h>
#endif
#if 0
//#ifdef USE_QT4
TQSocketNotifier::TQSocketNotifier( int socket, Type type, TQObject *tqparent, const char *name ) : QSocketNotifier(socket, type, tqparent) {
setObjectName(name);
}
#else // USE_QT4
/*!
\class TQSocketNotifier tqsocketnotifier.h
\brief The TQSocketNotifier class provides support for socket callbacks.
\ingroup io
This class makes it possible to write asynchronous socket-based
code in TQt. Using synchronous socket operations blocks the
program, which is clearly not acceptable for an event-driven GUI
program.
Once you have opened a non-blocking socket (whether for TCP, UDP,
a UNIX-domain socket, or any other protocol family your operating
system supports), you can create a socket notifier to monitor the
socket. Then you connect the activated() signal to the slot you
want to be called when a socket event occurs.
Note for Windows users: the socket passed to TQSocketNotifier will
become non-blocking, even if it was created as a blocking socket.
There are three types of socket notifiers (read, write and
exception); you must specify one of these in the constructor.
The type specifies when the activated() signal is to be emitted:
\list 1
\i TQSocketNotifier::Read - There is data to be read (socket read event).
\i TQSocketNotifier::Write - Data can be written (socket write event).
\i TQSocketNofifier::Exception - An exception has occurred (socket
exception event). We recommend against using this.
\endlist
For example, if you need to monitor both reads and writes for the
same socket you must create two socket notifiers.
For read notifiers it makes little sense to connect the
activated() signal to more than one slot because the data can be
read from the socket only once.
Also observe that if you do not read all the available data when
the read notifier fires, it fires again and again.
For write notifiers, immediately disable the notifier after the
activated() signal has been received and you have sent the data to
be written on the socket. When you have more data to be written,
enable it again to get a new activated() signal. The exception is
if the socket data writing operation (send() or equivalent) fails
with a "would block" error, which means that some buffer is full
and you must wait before sending more data. In that case you do
not need to disable and re-enable the write notifier; it will fire
again as soon as the system allows more data to be sent.
The behavior of a write notifier that is left in enabled state
after having emitting the first activated() signal (and no "would
block" error has occurred) is undefined. Depending on the
operating system, it may fire on every pass of the event loop or
not at all.
If you need a time-out for your sockets you can use either \link
TQObject::startTimer() timer events\endlink or the TQTimer class.
Socket action is detected in the \link TQApplication::exec() main
event loop\endlink of TQt. The X11 version of TQt has a single UNIX
select() call that incorporates all socket notifiers and the X
socket.
Note that on XFree86 for OS/2, select() works only in the thread
in which main() is running; you should therefore use that thread
for GUI operations.
\sa TQSocket, TQServerSocket, TQSocketDevice, TQFile::handle()
*/
/*!
\enum TQSocketNotifier::Type
\value Read
\value Write
\value Exception
*/
/*!
Constructs a socket notifier called \a name, with the tqparent, \a
tqparent. It watches \a socket for \a type events, and enables it.
It is generally advisable to explicitly enable or disable the
socket notifier, especially for write notifiers.
\sa setEnabled(), isEnabled()
*/
TQSocketNotifier::TQSocketNotifier( int socket, Type type, TQObject *tqparent,
const char *name )
: TQObject( tqparent, name )
{
#if defined(TQT_CHECK_RANGE)
if ( socket < 0 )
qWarning( "TQSocketNotifier: Invalid socket specified" );
# if defined(TQ_OS_UNIX)
if ( socket >= FD_SETSIZE )
qWarning( "TQSocketNotifier: Socket descriptor too large for select()" );
# endif
#endif
sockfd = socket;
sntype = type;
snenabled = TRUE;
TQApplication::eventLoop()->registerSocketNotifier( this );
}
/*!
Destroys the socket notifier.
*/
TQSocketNotifier::~TQSocketNotifier()
{
setEnabled( FALSE );
}
/*!
\fn void TQSocketNotifier::activated( int socket )
This signal is emitted under certain conditions specified by the
notifier type():
\list 1
\i TQSocketNotifier::Read - There is data to be read (socket read event).
\i TQSocketNotifier::Write - Data can be written (socket write event).
\i TQSocketNofifier::Exception - An exception has occurred (socket
exception event).
\endlist
The \a socket argument is the \link socket() socket\endlink identifier.
\sa type(), socket()
*/
/*!
\fn int TQSocketNotifier::socket() const
Returns the socket identifier specified to the constructor.
\sa type()
*/
/*!
\fn Type TQSocketNotifier::type() const
Returns the socket event type specified to the constructor: \c
TQSocketNotifier::Read, \c TQSocketNotifier::Write, or \c
TQSocketNotifier::Exception.
\sa socket()
*/
/*!
\fn bool TQSocketNotifier::isEnabled() const
Returns TRUE if the notifier is enabled; otherwise returns FALSE.
\sa setEnabled()
*/
/*!
Enables the notifier if \a enable is TRUE or disables it if \a
enable is FALSE.
The notifier is enabled by default.
If the notifier is enabled, it emits the activated() signal
whenever a socket event corresponding to its \link type()
type\endlink occurs. If it is disabled, it ignores socket events
(the same effect as not creating the socket notifier).
Write notifiers should normally be disabled immediately after the
activated() signal has been emitted; see discussion of write
notifiers in the \link #details class description\endlink above.
\sa isEnabled(), activated()
*/
void TQSocketNotifier::setEnabled( bool enable )
{
if ( sockfd < 0 )
return;
if ( snenabled == enable ) // no change
return;
snenabled = enable;
TQEventLoop *eventloop = TQApplication::eventLoop();
if ( ! eventloop ) // perhaps application is shutting down
return;
if ( snenabled )
eventloop->registerSocketNotifier( this );
else
eventloop->unregisterSocketNotifier( this );
}
/*!\reimp
*/
bool TQSocketNotifier::event( TQEvent *e )
{
// Emits the activated() signal when a \c TQEvent::SockAct is
// received.
TQObject::event( e ); // will activate filters
if ( e->type() == TQEvent::SockAct ) {
emit activated( sockfd );
return TRUE;
}
return FALSE;
}
#endif // USE_QT4
|