author | Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com> |
Tue, 06 Jul 2010 15:10:48 +0300 | |
changeset 30 | 5dc02b23752f |
parent 18 | 2f34d5167611 |
child 33 | 3e2da88830cd |
permissions | -rw-r--r-- |
0 | 1 |
/**************************************************************************** |
2 |
** |
|
18
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
3 |
** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies). |
0 | 4 |
** All rights reserved. |
5 |
** Contact: Nokia Corporation (qt-info@nokia.com) |
|
6 |
** |
|
7 |
** This file is part of the QtCore module of the Qt Toolkit. |
|
8 |
** |
|
9 |
** $QT_BEGIN_LICENSE:LGPL$ |
|
10 |
** No Commercial Usage |
|
11 |
** This file contains pre-release code and may not be distributed. |
|
12 |
** You may use this file in accordance with the terms and conditions |
|
13 |
** contained in the Technology Preview License Agreement accompanying |
|
14 |
** this package. |
|
15 |
** |
|
16 |
** GNU Lesser General Public License Usage |
|
17 |
** Alternatively, this file may be used under the terms of the GNU Lesser |
|
18 |
** General Public License version 2.1 as published by the Free Software |
|
19 |
** Foundation and appearing in the file LICENSE.LGPL included in the |
|
20 |
** packaging of this file. Please review the following information to |
|
21 |
** ensure the GNU Lesser General Public License version 2.1 requirements |
|
22 |
** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. |
|
23 |
** |
|
24 |
** In addition, as a special exception, Nokia gives you certain additional |
|
25 |
** rights. These rights are described in the Nokia Qt LGPL Exception |
|
26 |
** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. |
|
27 |
** |
|
28 |
** If you have questions regarding the use of this file, please contact |
|
29 |
** Nokia at qt-info@nokia.com. |
|
30 |
** |
|
31 |
** |
|
32 |
** |
|
33 |
** |
|
34 |
** |
|
35 |
** |
|
36 |
** |
|
37 |
** |
|
38 |
** $QT_END_LICENSE$ |
|
39 |
** |
|
40 |
****************************************************************************/ |
|
41 |
||
42 |
#include "qeventdispatcher_win_p.h" |
|
43 |
||
44 |
#include "qcoreapplication.h" |
|
45 |
#include "qhash.h" |
|
46 |
#include "qlibrary.h" |
|
47 |
#include "qpair.h" |
|
48 |
#include "qset.h" |
|
49 |
#include "qsocketnotifier.h" |
|
50 |
#include "qvarlengtharray.h" |
|
51 |
#include "qwineventnotifier_p.h" |
|
52 |
||
53 |
#include "qabstracteventdispatcher_p.h" |
|
54 |
#include "qcoreapplication_p.h" |
|
55 |
#include <private/qthread_p.h> |
|
56 |
#include <private/qmutexpool_p.h> |
|
57 |
||
58 |
QT_BEGIN_NAMESPACE |
|
59 |
||
60 |
HINSTANCE qWinAppInst(); |
|
61 |
extern uint qGlobalPostedEventsCount(); |
|
62 |
||
63 |
#ifndef TIME_KILL_SYNCHRONOUS |
|
64 |
# define TIME_KILL_SYNCHRONOUS 0x0100 |
|
65 |
#endif |
|
66 |
||
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
67 |
#ifndef QS_RAWINPUT |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
68 |
# define QS_RAWINPUT 0x0400 |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
69 |
#endif |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
70 |
|
18
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
71 |
#ifndef WM_TOUCH |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
72 |
# define WM_TOUCH 0x0240 |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
73 |
#endif |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
74 |
#ifndef WM_GESTURE |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
75 |
# define WM_GESTURE 0x0119 |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
76 |
# define WM_GESTURENOTIFY 0x011A |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
77 |
#endif |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
78 |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
79 |
enum { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
80 |
WM_QT_SOCKETNOTIFIER = WM_USER, |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
81 |
WM_QT_SENDPOSTEDEVENTS = WM_USER + 1, |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
82 |
SendPostedEventsTimerId = ~1u |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
83 |
}; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
84 |
|
0 | 85 |
#if defined(Q_OS_WINCE) |
86 |
QT_BEGIN_INCLUDE_NAMESPACE |
|
87 |
#include <winsock.h> |
|
88 |
// Asynchronous Winsocks ------------------------------------------ |
|
89 |
#ifndef QT_NO_THREAD |
|
90 |
#include <qthread.h> |
|
91 |
#include <qmap.h> |
|
92 |
#include <qmutex.h> |
|
93 |
QT_END_INCLUDE_NAMESPACE |
|
94 |
||
95 |
//#define QCE_ASYNC_DEBUG |
|
96 |
||
97 |
namespace { |
|
98 |
class SocketAsyncHandler; |
|
99 |
||
100 |
class SocketAsyncHandler : public QThread |
|
101 |
{ |
|
102 |
public: |
|
103 |
SocketAsyncHandler(); |
|
104 |
~SocketAsyncHandler(); |
|
105 |
void run(); |
|
106 |
void select(SOCKET sock, HWND handle, unsigned int msg, long ev); |
|
107 |
void removeSelect(SOCKET sock); |
|
108 |
void safeRemove(SOCKET sock); |
|
109 |
private: |
|
110 |
struct SockInfo { |
|
111 |
HWND handle; |
|
112 |
unsigned int msg; |
|
113 |
long ev; |
|
114 |
}; |
|
115 |
QMap<SOCKET, SockInfo> sockets; |
|
116 |
QMutex mutex; |
|
117 |
QWaitCondition cond; |
|
118 |
bool supposedToDie; |
|
119 |
}; |
|
120 |
||
121 |
SocketAsyncHandler::SocketAsyncHandler() |
|
122 |
: supposedToDie(false) |
|
123 |
{ |
|
124 |
} |
|
125 |
||
126 |
SocketAsyncHandler::~SocketAsyncHandler() |
|
127 |
{ |
|
128 |
mutex.lock(); |
|
129 |
supposedToDie = true; |
|
130 |
mutex.unlock(); |
|
131 |
cond.wakeOne(); |
|
132 |
wait(); |
|
133 |
while (sockets.size() > 0) |
|
134 |
removeSelect(sockets.begin().key()); |
|
135 |
} |
|
136 |
||
137 |
void SocketAsyncHandler::removeSelect(SOCKET sock) |
|
138 |
{ |
|
139 |
if (!sockets.contains(sock)) |
|
140 |
return; |
|
141 |
sockets.remove(sock); |
|
142 |
return; |
|
143 |
} |
|
144 |
||
145 |
void SocketAsyncHandler::safeRemove(SOCKET sock) |
|
146 |
{ |
|
147 |
QMutexLocker locker(&mutex); |
|
148 |
removeSelect(sock); |
|
149 |
} |
|
150 |
||
151 |
void SocketAsyncHandler::select(SOCKET sock, HWND handle, unsigned int msg, long ev) |
|
152 |
{ |
|
153 |
QMutexLocker locker(&mutex); |
|
154 |
||
155 |
if (sockets.contains(sock)) |
|
156 |
sockets.remove(sock); |
|
157 |
||
158 |
SockInfo info; |
|
159 |
info.handle = handle; |
|
160 |
info.msg = msg; |
|
161 |
info.ev = ev; |
|
162 |
sockets.insert(sock, info); |
|
163 |
cond.wakeOne(); |
|
164 |
} |
|
165 |
||
166 |
void SocketAsyncHandler::run() |
|
167 |
{ |
|
168 |
do { |
|
169 |
mutex.lock(); |
|
170 |
||
171 |
while (!supposedToDie && sockets.isEmpty()) { |
|
172 |
cond.wait(&mutex); |
|
173 |
} |
|
174 |
||
175 |
if (supposedToDie) { |
|
176 |
mutex.unlock(); |
|
177 |
break; |
|
178 |
} |
|
179 |
||
180 |
// Copy current items to reduce lock time |
|
181 |
// and to be able to use SendMessage |
|
182 |
QMap<SOCKET, SockInfo> currentSockets = sockets; |
|
183 |
mutex.unlock(); |
|
184 |
||
185 |
fd_set readS, writeS, exS; |
|
186 |
FD_ZERO(&readS); |
|
187 |
FD_ZERO(&writeS); |
|
188 |
FD_ZERO(&exS); |
|
189 |
||
190 |
int maxFd = 0; |
|
191 |
||
192 |
for (QMap<SOCKET, SockInfo>::iterator it = currentSockets.begin(); it != currentSockets.end(); ++it) { |
|
193 |
const SockInfo &info = it.value(); |
|
194 |
int socket = it.key(); |
|
195 |
maxFd = qMax(maxFd, socket); |
|
196 |
||
197 |
if ((info.ev & FD_READ) || (info.ev & FD_CLOSE) || (info.ev & FD_ACCEPT)) |
|
198 |
FD_SET(socket, &readS); |
|
199 |
if ((info.ev & FD_WRITE)|| (info.ev & FD_CONNECT)) |
|
200 |
FD_SET(socket, &writeS); |
|
201 |
if (info.ev & FD_OOB) |
|
202 |
FD_SET(socket, &exS); |
|
203 |
} |
|
204 |
||
205 |
timeval timeout; |
|
206 |
timeout.tv_sec = 0; |
|
207 |
timeout.tv_usec = 50000; |
|
208 |
int result = ::select(maxFd + 1, &readS, &writeS, &exS, &timeout); |
|
209 |
if (result > 0) { |
|
210 |
HWND handle; |
|
211 |
unsigned int tmpMsg; |
|
212 |
SOCKET sock; |
|
213 |
HRESULT ret; |
|
214 |
for (QMap<SOCKET, SockInfo>::const_iterator it = currentSockets.constBegin(); |
|
215 |
it != currentSockets.constEnd(); ++it) { |
|
216 |
handle = (*it).handle; |
|
217 |
tmpMsg = (*it).msg; |
|
218 |
sock = it.key(); |
|
219 |
if (FD_ISSET(sock, &readS)) |
|
220 |
ret = SendMessage(handle, tmpMsg, sock, FD_READ); |
|
221 |
||
222 |
if (FD_ISSET(sock, &writeS)) |
|
223 |
ret = SendMessage(handle, tmpMsg, sock, FD_WRITE); |
|
224 |
||
225 |
if (FD_ISSET(sock, &exS)) |
|
226 |
ret = SendMessage(handle, tmpMsg, sock, FD_OOB); |
|
227 |
} |
|
228 |
} |
|
229 |
||
230 |
#ifdef QCE_ASYNC_DEBUG |
|
231 |
else if (result == 0) { //timeout |
|
232 |
qDebug(" WSAAsync select timeout"); |
|
233 |
} else if (result < 0) { // SocketError |
|
234 |
// This might happen because of two reasons |
|
235 |
// 1. We already closed a socket in between the copy and the select |
|
236 |
// and thus select() returns an error |
|
237 |
// 2. Something is really wrong, then |
|
238 |
// ### Loop on all descriptors, try to select and remove the |
|
239 |
// ### broken one. |
|
240 |
qWarning("WSAAsync select error %d", WSAGetLastError()); |
|
241 |
} |
|
242 |
#endif |
|
243 |
} while(true); |
|
244 |
} |
|
245 |
} // namespace |
|
246 |
||
247 |
Q_GLOBAL_STATIC(SocketAsyncHandler, qt_async_handler) |
|
248 |
||
249 |
int WSAAsyncSelect(SOCKET sock, HWND handle, unsigned int msg, long ev) |
|
250 |
{ |
|
251 |
if (sock == 0 || handle == 0 || handle == INVALID_HANDLE_VALUE) { |
|
252 |
WSASetLastError(WSAEINVAL); |
|
253 |
return SOCKET_ERROR; |
|
254 |
} |
|
255 |
||
256 |
if (msg == 0 && ev == 0) |
|
257 |
qt_async_handler()->safeRemove(sock); |
|
258 |
else |
|
259 |
qt_async_handler()->select(sock, handle, msg, ev); |
|
260 |
||
261 |
qt_async_handler()->start(QThread::LowPriority); |
|
262 |
WSASetLastError(0); |
|
263 |
return 0; |
|
264 |
} |
|
265 |
#else // QT_NO_THREAD |
|
266 |
int WSAAsyncSelect(SOCKET, HWND, unsigned int, long) |
|
267 |
{ |
|
268 |
return SOCKET_ERROR; |
|
269 |
} |
|
270 |
#endif |
|
271 |
#endif // Q_OS_WINCE |
|
272 |
||
273 |
class QEventDispatcherWin32Private; |
|
274 |
||
275 |
struct QSockNot { |
|
276 |
QSocketNotifier *obj; |
|
277 |
int fd; |
|
278 |
}; |
|
279 |
typedef QHash<int, QSockNot *> QSNDict; |
|
280 |
||
281 |
struct WinTimerInfo { // internal timer info |
|
282 |
QObject *dispatcher; |
|
283 |
int timerId; |
|
284 |
int interval; |
|
285 |
QObject *obj; // - object to receive events |
|
286 |
bool inTimerEvent; |
|
287 |
int fastTimerId; |
|
288 |
}; |
|
289 |
||
290 |
class QZeroTimerEvent : public QTimerEvent |
|
291 |
{ |
|
292 |
public: |
|
293 |
inline QZeroTimerEvent(int timerId) |
|
294 |
: QTimerEvent(timerId) |
|
295 |
{ t = QEvent::ZeroTimerEvent; } |
|
296 |
}; |
|
297 |
||
298 |
typedef QList<WinTimerInfo*> WinTimerVec; // vector of TimerInfo structs |
|
299 |
typedef QHash<int, WinTimerInfo*> WinTimerDict; // fast dict of timers |
|
300 |
||
301 |
#if !defined(DWORD_PTR) && !defined(Q_WS_WIN64) |
|
302 |
#define DWORD_PTR DWORD |
|
303 |
#endif |
|
304 |
||
305 |
typedef MMRESULT(WINAPI *ptimeSetEvent)(UINT, UINT, LPTIMECALLBACK, DWORD_PTR, UINT); |
|
306 |
typedef MMRESULT(WINAPI *ptimeKillEvent)(UINT); |
|
307 |
||
308 |
static ptimeSetEvent qtimeSetEvent = 0; |
|
309 |
static ptimeKillEvent qtimeKillEvent = 0; |
|
310 |
||
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
311 |
LRESULT QT_WIN_CALLBACK qt_internal_proc(HWND hwnd, UINT message, WPARAM wp, LPARAM lp); |
0 | 312 |
|
313 |
static void resolveTimerAPI() |
|
314 |
{ |
|
315 |
static bool triedResolve = false; |
|
316 |
if (!triedResolve) { |
|
317 |
#ifndef QT_NO_THREAD |
|
318 |
QMutexLocker locker(QMutexPool::globalInstanceGet(&triedResolve)); |
|
319 |
if (triedResolve) |
|
320 |
return; |
|
321 |
#endif |
|
322 |
triedResolve = true; |
|
323 |
#if !defined(Q_OS_WINCE) |
|
324 |
qtimeSetEvent = (ptimeSetEvent)QLibrary::resolve(QLatin1String("winmm"), "timeSetEvent"); |
|
325 |
qtimeKillEvent = (ptimeKillEvent)QLibrary::resolve(QLatin1String("winmm"), "timeKillEvent"); |
|
326 |
#else |
|
327 |
qtimeSetEvent = (ptimeSetEvent)QLibrary::resolve(QLatin1String("Mmtimer"), "timeSetEvent"); |
|
328 |
qtimeKillEvent = (ptimeKillEvent)QLibrary::resolve(QLatin1String("Mmtimer"), "timeKillEvent"); |
|
329 |
#endif |
|
330 |
} |
|
331 |
} |
|
332 |
||
333 |
||
334 |
class QEventDispatcherWin32Private : public QAbstractEventDispatcherPrivate |
|
335 |
{ |
|
336 |
Q_DECLARE_PUBLIC(QEventDispatcherWin32) |
|
337 |
public: |
|
338 |
QEventDispatcherWin32Private(); |
|
339 |
~QEventDispatcherWin32Private(); |
|
340 |
||
341 |
DWORD threadId; |
|
342 |
||
343 |
bool interrupt; |
|
344 |
||
345 |
// internal window handle used for socketnotifiers/timers/etc |
|
346 |
HWND internalHwnd; |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
347 |
HHOOK getMessageHook; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
348 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
349 |
// for controlling when to send posted events |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
350 |
QAtomicInt serialNumber; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
351 |
int lastSerialNumber; |
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
352 |
#ifndef Q_OS_WINCE |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
353 |
int lastMessageTime; |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
354 |
#endif |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
355 |
QAtomicInt wakeUps; |
0 | 356 |
|
357 |
// timers |
|
358 |
WinTimerVec timerVec; |
|
359 |
WinTimerDict timerDict; |
|
360 |
void registerTimer(WinTimerInfo *t); |
|
361 |
void unregisterTimer(WinTimerInfo *t, bool closingDown = false); |
|
362 |
void sendTimerEvent(int timerId); |
|
363 |
||
364 |
// socket notifiers |
|
365 |
QSNDict sn_read; |
|
366 |
QSNDict sn_write; |
|
367 |
QSNDict sn_except; |
|
368 |
void doWsaAsyncSelect(int socket); |
|
369 |
||
370 |
QList<QWinEventNotifier *> winEventNotifierList; |
|
371 |
void activateEventNotifier(QWinEventNotifier * wen); |
|
372 |
||
373 |
QList<MSG> queuedUserInputEvents; |
|
374 |
QList<MSG> queuedSocketEvents; |
|
375 |
}; |
|
376 |
||
377 |
QEventDispatcherWin32Private::QEventDispatcherWin32Private() |
|
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
378 |
: threadId(GetCurrentThreadId()), interrupt(false), internalHwnd(0), getMessageHook(0), |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
379 |
serialNumber(0), lastSerialNumber(0), |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
380 |
#ifndef Q_OS_WINCE |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
381 |
lastMessageTime(0), |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
382 |
#endif |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
383 |
wakeUps(0) |
0 | 384 |
{ |
385 |
resolveTimerAPI(); |
|
386 |
} |
|
387 |
||
388 |
QEventDispatcherWin32Private::~QEventDispatcherWin32Private() |
|
389 |
{ |
|
390 |
if (internalHwnd) |
|
391 |
DestroyWindow(internalHwnd); |
|
392 |
QString className = QLatin1String("QEventDispatcherWin32_Internal_Widget") + QString::number(quintptr(qt_internal_proc)); |
|
393 |
UnregisterClass((wchar_t*)className.utf16(), qWinAppInst()); |
|
394 |
} |
|
395 |
||
396 |
void QEventDispatcherWin32Private::activateEventNotifier(QWinEventNotifier * wen) |
|
397 |
{ |
|
398 |
QEvent event(QEvent::WinEventAct); |
|
399 |
QCoreApplication::sendEvent(wen, &event); |
|
400 |
} |
|
401 |
||
402 |
// ### Qt 5: remove |
|
403 |
Q_CORE_EXPORT bool winPeekMessage(MSG* msg, HWND hWnd, UINT wMsgFilterMin, |
|
404 |
UINT wMsgFilterMax, UINT wRemoveMsg) |
|
405 |
{ |
|
406 |
return PeekMessage(msg, hWnd, wMsgFilterMin, wMsgFilterMax, wRemoveMsg); |
|
407 |
} |
|
408 |
||
409 |
// ### Qt 5: remove |
|
410 |
Q_CORE_EXPORT bool winPostMessage(HWND hWnd, UINT msg, WPARAM wParam, LPARAM lParam) |
|
411 |
{ |
|
412 |
return PostMessage(hWnd, msg, wParam, lParam); |
|
413 |
} |
|
414 |
||
415 |
// ### Qt 5: remove |
|
416 |
Q_CORE_EXPORT bool winGetMessage(MSG* msg, HWND hWnd, UINT wMsgFilterMin, |
|
417 |
UINT wMsgFilterMax) |
|
418 |
{ |
|
419 |
return GetMessage(msg, hWnd, wMsgFilterMin, wMsgFilterMax); |
|
420 |
} |
|
421 |
||
422 |
// This function is called by a workerthread |
|
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
423 |
void WINAPI QT_WIN_CALLBACK qt_fast_timer_proc(uint timerId, uint /*reserved*/, DWORD_PTR user, DWORD_PTR /*reserved*/, DWORD_PTR /*reserved*/) |
0 | 424 |
{ |
425 |
if (!timerId) // sanity check |
|
426 |
return; |
|
427 |
WinTimerInfo *t = (WinTimerInfo*)user; |
|
428 |
Q_ASSERT(t); |
|
429 |
QCoreApplication::postEvent(t->dispatcher, new QTimerEvent(t->timerId)); |
|
430 |
} |
|
431 |
||
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
432 |
LRESULT QT_WIN_CALLBACK qt_internal_proc(HWND hwnd, UINT message, WPARAM wp, LPARAM lp) |
0 | 433 |
{ |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
434 |
if (message == WM_NCCREATE) |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
435 |
return true; |
0 | 436 |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
437 |
MSG msg; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
438 |
msg.hwnd = hwnd; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
439 |
msg.message = message; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
440 |
msg.wParam = wp; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
441 |
msg.lParam = lp; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
442 |
QCoreApplication *app = QCoreApplication::instance(); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
443 |
long result; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
444 |
if (!app) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
445 |
if (message == WM_TIMER) |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
446 |
KillTimer(hwnd, wp); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
447 |
return 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
448 |
} else if (app->filterEvent(&msg, &result)) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
449 |
return result; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
450 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
451 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
452 |
#ifdef GWLP_USERDATA |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
453 |
QEventDispatcherWin32 *q = (QEventDispatcherWin32 *) GetWindowLongPtr(hwnd, GWLP_USERDATA); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
454 |
#else |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
455 |
QEventDispatcherWin32 *q = (QEventDispatcherWin32 *) GetWindowLong(hwnd, GWL_USERDATA); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
456 |
#endif |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
457 |
QEventDispatcherWin32Private *d = 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
458 |
if (q != 0) |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
459 |
d = q->d_func(); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
460 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
461 |
if (message == WM_QT_SOCKETNOTIFIER) { |
0 | 462 |
// socket notifier message |
463 |
int type = -1; |
|
464 |
switch (WSAGETSELECTEVENT(lp)) { |
|
465 |
case FD_READ: |
|
466 |
case FD_CLOSE: |
|
467 |
case FD_ACCEPT: |
|
468 |
type = 0; |
|
469 |
break; |
|
470 |
case FD_WRITE: |
|
471 |
case FD_CONNECT: |
|
472 |
type = 1; |
|
473 |
break; |
|
474 |
case FD_OOB: |
|
475 |
type = 2; |
|
476 |
break; |
|
477 |
} |
|
478 |
if (type >= 0) { |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
479 |
Q_ASSERT(d != 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
480 |
QSNDict *sn_vec[3] = { &d->sn_read, &d->sn_write, &d->sn_except }; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
481 |
QSNDict *dict = sn_vec[type]; |
0 | 482 |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
483 |
QSockNot *sn = dict ? dict->value(wp) : 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
484 |
if (sn) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
485 |
QEvent event(QEvent::SockAct); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
486 |
QCoreApplication::sendEvent(sn->obj, &event); |
0 | 487 |
} |
488 |
} |
|
489 |
return 0; |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
490 |
} else if (message == WM_TIMER) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
491 |
Q_ASSERT(d != 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
492 |
d->sendTimerEvent(wp); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
493 |
return 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
494 |
} else if (message == WM_QT_SENDPOSTEDEVENTS) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
495 |
int localSerialNumber = d->serialNumber; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
496 |
if (localSerialNumber != d->lastSerialNumber) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
497 |
d->lastSerialNumber = localSerialNumber; |
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
498 |
#ifndef Q_OS_WINCE |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
499 |
d->lastMessageTime = GetMessageTime(); |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
500 |
#endif |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
501 |
QCoreApplicationPrivate::sendPostedEvents(0, 0, d->threadData); |
0 | 502 |
} |
503 |
return 0; |
|
504 |
} |
|
505 |
||
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
506 |
return DefWindowProc(hwnd, message, wp, lp); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
507 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
508 |
|
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
509 |
LRESULT QT_WIN_CALLBACK qt_GetMessageHook(int code, WPARAM wp, LPARAM lp) |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
510 |
{ |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
511 |
if (wp == PM_REMOVE) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
512 |
QEventDispatcherWin32 *q = qobject_cast<QEventDispatcherWin32 *>(QAbstractEventDispatcher::instance()); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
513 |
Q_ASSERT(q != 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
514 |
if (q) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
515 |
QEventDispatcherWin32Private *d = q->d_func(); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
516 |
int localSerialNumber = d->serialNumber; |
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
517 |
if (HIWORD(GetQueueStatus(QS_INPUT | QS_RAWINPUT | QS_TIMER)) == 0 |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
518 |
#ifndef Q_OS_WINCE |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
519 |
|| GetMessageTime() - d->lastMessageTime >= 10 |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
520 |
#endif |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
521 |
) { |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
522 |
// no more input or timer events in the message queue or more than 10ms has elapsed since |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
523 |
// we send posted events, we can allow posted events to be sent now |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
524 |
(void) d->wakeUps.fetchAndStoreRelease(0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
525 |
MSG *msg = (MSG *) lp; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
526 |
if (localSerialNumber != d->lastSerialNumber |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
527 |
// if this message IS the one that triggers sendPostedEvents(), no need to post it again |
18
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
528 |
&& (msg->hwnd != d->internalHwnd |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
529 |
|| msg->message != WM_QT_SENDPOSTEDEVENTS)) { |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
530 |
PostMessage(d->internalHwnd, WM_QT_SENDPOSTEDEVENTS, 0, 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
531 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
532 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
533 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
534 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
535 |
#ifdef Q_OS_WINCE |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
536 |
return 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
537 |
#else |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
538 |
return CallNextHookEx(0, code, wp, lp); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
539 |
#endif |
0 | 540 |
} |
541 |
||
542 |
static HWND qt_create_internal_window(const QEventDispatcherWin32 *eventDispatcher) |
|
543 |
{ |
|
544 |
// make sure that multiple Qt's can coexist in the same process |
|
545 |
QString className = QLatin1String("QEventDispatcherWin32_Internal_Widget") + QString::number(quintptr(qt_internal_proc)); |
|
546 |
||
547 |
WNDCLASS wc; |
|
548 |
wc.style = 0; |
|
549 |
wc.lpfnWndProc = qt_internal_proc; |
|
550 |
wc.cbClsExtra = 0; |
|
551 |
wc.cbWndExtra = 0; |
|
552 |
wc.hInstance = qWinAppInst(); |
|
553 |
wc.hIcon = 0; |
|
554 |
wc.hCursor = 0; |
|
555 |
wc.hbrBackground = 0; |
|
556 |
wc.lpszMenuName = NULL; |
|
557 |
wc.lpszClassName = reinterpret_cast<const wchar_t *> (className.utf16()); |
|
558 |
||
559 |
RegisterClass(&wc); |
|
560 |
HWND wnd = CreateWindow(wc.lpszClassName, // classname |
|
561 |
wc.lpszClassName, // window name |
|
562 |
0, // style |
|
563 |
0, 0, 0, 0, // geometry |
|
564 |
0, // parent |
|
565 |
0, // menu handle |
|
566 |
qWinAppInst(), // application |
|
567 |
0); // windows creation data. |
|
568 |
||
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
569 |
if (!wnd) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
570 |
qWarning("QEventDispatcher: Failed to create QEventDispatcherWin32 internal window: %d\n", (int)GetLastError()); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
571 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
572 |
|
0 | 573 |
#ifdef GWLP_USERDATA |
574 |
SetWindowLongPtr(wnd, GWLP_USERDATA, (LONG_PTR)eventDispatcher); |
|
575 |
#else |
|
576 |
SetWindowLong(wnd, GWL_USERDATA, (LONG)eventDispatcher); |
|
577 |
#endif |
|
578 |
||
579 |
return wnd; |
|
580 |
} |
|
581 |
||
582 |
void QEventDispatcherWin32Private::registerTimer(WinTimerInfo *t) |
|
583 |
{ |
|
584 |
Q_ASSERT(internalHwnd); |
|
585 |
||
586 |
Q_Q(QEventDispatcherWin32); |
|
587 |
||
588 |
int ok = 0; |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
589 |
if (t->interval > 20 || !t->interval || !qtimeSetEvent) { |
0 | 590 |
ok = 1; |
591 |
if (!t->interval) // optimization for single-shot-zero-timer |
|
592 |
QCoreApplication::postEvent(q, new QZeroTimerEvent(t->timerId)); |
|
593 |
else |
|
594 |
ok = SetTimer(internalHwnd, t->timerId, (uint) t->interval, 0); |
|
595 |
} else { |
|
596 |
ok = t->fastTimerId = qtimeSetEvent(t->interval, 1, qt_fast_timer_proc, (DWORD_PTR)t, |
|
597 |
TIME_CALLBACK_FUNCTION | TIME_PERIODIC | TIME_KILL_SYNCHRONOUS); |
|
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
598 |
if (ok == 0) { // fall back to normal timer if no more multimedia timers available |
0 | 599 |
ok = SetTimer(internalHwnd, t->timerId, (uint) t->interval, 0); |
600 |
} |
|
601 |
} |
|
602 |
||
603 |
if (ok == 0) |
|
604 |
qErrnoWarning("QEventDispatcherWin32::registerTimer: Failed to create a timer"); |
|
605 |
} |
|
606 |
||
607 |
void QEventDispatcherWin32Private::unregisterTimer(WinTimerInfo *t, bool closingDown) |
|
608 |
{ |
|
609 |
// mark timer as unused |
|
610 |
if (!QObjectPrivate::get(t->obj)->inThreadChangeEvent && !closingDown) |
|
611 |
QAbstractEventDispatcherPrivate::releaseTimerId(t->timerId); |
|
612 |
||
613 |
if (t->interval == 0) { |
|
614 |
QCoreApplicationPrivate::removePostedTimerEvent(t->dispatcher, t->timerId); |
|
615 |
} else if (t->fastTimerId != 0) { |
|
616 |
qtimeKillEvent(t->fastTimerId); |
|
617 |
QCoreApplicationPrivate::removePostedTimerEvent(t->dispatcher, t->timerId); |
|
618 |
} else if (internalHwnd) { |
|
619 |
KillTimer(internalHwnd, t->timerId); |
|
620 |
} |
|
621 |
delete t; |
|
622 |
} |
|
623 |
||
624 |
void QEventDispatcherWin32Private::sendTimerEvent(int timerId) |
|
625 |
{ |
|
626 |
WinTimerInfo *t = timerDict.value(timerId); |
|
627 |
if (t && !t->inTimerEvent) { |
|
628 |
// send event, but don't allow it to recurse |
|
629 |
t->inTimerEvent = true; |
|
630 |
||
631 |
QTimerEvent e(t->timerId); |
|
632 |
QCoreApplication::sendEvent(t->obj, &e); |
|
633 |
||
634 |
// timer could have been removed |
|
635 |
t = timerDict.value(timerId); |
|
636 |
if (t) { |
|
637 |
t->inTimerEvent = false; |
|
638 |
} |
|
639 |
} |
|
640 |
} |
|
641 |
||
642 |
void QEventDispatcherWin32Private::doWsaAsyncSelect(int socket) |
|
643 |
{ |
|
644 |
Q_ASSERT(internalHwnd); |
|
645 |
int sn_event = 0; |
|
646 |
if (sn_read.contains(socket)) |
|
647 |
sn_event |= FD_READ | FD_CLOSE | FD_ACCEPT; |
|
648 |
if (sn_write.contains(socket)) |
|
649 |
sn_event |= FD_WRITE | FD_CONNECT; |
|
650 |
if (sn_except.contains(socket)) |
|
651 |
sn_event |= FD_OOB; |
|
652 |
// BoundsChecker may emit a warning for WSAAsyncSelect when sn_event == 0 |
|
653 |
// This is a BoundsChecker bug and not a Qt bug |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
654 |
WSAAsyncSelect(socket, internalHwnd, sn_event ? WM_QT_SOCKETNOTIFIER : 0, sn_event); |
0 | 655 |
} |
656 |
||
657 |
void QEventDispatcherWin32::createInternalHwnd() |
|
658 |
{ |
|
659 |
Q_D(QEventDispatcherWin32); |
|
660 |
||
661 |
Q_ASSERT(!d->internalHwnd); |
|
662 |
if (d->internalHwnd) |
|
663 |
return; |
|
664 |
d->internalHwnd = qt_create_internal_window(this); |
|
665 |
||
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
666 |
#ifndef Q_OS_WINCE |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
667 |
// setup GetMessage hook needed to drive our posted events |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
668 |
d->getMessageHook = SetWindowsHookEx(WH_GETMESSAGE, (HOOKPROC) qt_GetMessageHook, NULL, GetCurrentThreadId()); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
669 |
if (!d->getMessageHook) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
670 |
qFatal("Qt: INTERNALL ERROR: failed to install GetMessage hook"); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
671 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
672 |
#endif |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
673 |
|
0 | 674 |
// register all socket notifiers |
675 |
QList<int> sockets = (d->sn_read.keys().toSet() |
|
676 |
+ d->sn_write.keys().toSet() |
|
677 |
+ d->sn_except.keys().toSet()).toList(); |
|
678 |
for (int i = 0; i < sockets.count(); ++i) |
|
679 |
d->doWsaAsyncSelect(sockets.at(i)); |
|
680 |
||
681 |
// start all normal timers |
|
682 |
for (int i = 0; i < d->timerVec.count(); ++i) |
|
683 |
d->registerTimer(d->timerVec.at(i)); |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
684 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
685 |
// trigger a call to sendPostedEvents() |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
686 |
wakeUp(); |
0 | 687 |
} |
688 |
||
689 |
QEventDispatcherWin32::QEventDispatcherWin32(QObject *parent) |
|
690 |
: QAbstractEventDispatcher(*new QEventDispatcherWin32Private, parent) |
|
691 |
{ |
|
692 |
} |
|
693 |
||
694 |
QEventDispatcherWin32::~QEventDispatcherWin32() |
|
695 |
{ |
|
696 |
} |
|
697 |
||
698 |
bool QEventDispatcherWin32::processEvents(QEventLoop::ProcessEventsFlags flags) |
|
699 |
{ |
|
700 |
Q_D(QEventDispatcherWin32); |
|
701 |
||
702 |
if (!d->internalHwnd) |
|
703 |
createInternalHwnd(); |
|
704 |
||
705 |
d->interrupt = false; |
|
706 |
emit awake(); |
|
707 |
||
708 |
bool canWait; |
|
709 |
bool retVal = false; |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
710 |
bool seenWM_QT_SENDPOSTEDEVENTS = false; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
711 |
bool needWM_QT_SENDPOSTEDEVENTS = false; |
0 | 712 |
do { |
713 |
DWORD waitRet = 0; |
|
714 |
HANDLE pHandles[MAXIMUM_WAIT_OBJECTS - 1]; |
|
715 |
QVarLengthArray<MSG> processedTimers; |
|
716 |
while (!d->interrupt) { |
|
717 |
DWORD nCount = d->winEventNotifierList.count(); |
|
718 |
Q_ASSERT(nCount < MAXIMUM_WAIT_OBJECTS - 1); |
|
719 |
||
720 |
MSG msg; |
|
721 |
bool haveMessage; |
|
722 |
||
723 |
if (!(flags & QEventLoop::ExcludeUserInputEvents) && !d->queuedUserInputEvents.isEmpty()) { |
|
724 |
// process queued user input events |
|
725 |
haveMessage = true; |
|
726 |
msg = d->queuedUserInputEvents.takeFirst(); |
|
727 |
} else if(!(flags & QEventLoop::ExcludeSocketNotifiers) && !d->queuedSocketEvents.isEmpty()) { |
|
728 |
// process queued socket events |
|
729 |
haveMessage = true; |
|
730 |
msg = d->queuedSocketEvents.takeFirst(); |
|
731 |
} else { |
|
732 |
haveMessage = PeekMessage(&msg, 0, 0, 0, PM_REMOVE); |
|
733 |
if (haveMessage && (flags & QEventLoop::ExcludeUserInputEvents) |
|
734 |
&& ((msg.message >= WM_KEYFIRST |
|
735 |
&& msg.message <= WM_KEYLAST) |
|
736 |
|| (msg.message >= WM_MOUSEFIRST |
|
737 |
&& msg.message <= WM_MOUSELAST) |
|
738 |
|| msg.message == WM_MOUSEWHEEL |
|
739 |
|| msg.message == WM_MOUSEHWHEEL |
|
18
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
740 |
|| msg.message == WM_TOUCH |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
741 |
|| msg.message == WM_GESTURE |
2f34d5167611
Revision: 201011
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
3
diff
changeset
|
742 |
|| msg.message == WM_GESTURENOTIFY |
0 | 743 |
|| msg.message == WM_CLOSE)) { |
744 |
// queue user input events for later processing |
|
745 |
haveMessage = false; |
|
746 |
d->queuedUserInputEvents.append(msg); |
|
747 |
} |
|
748 |
if (haveMessage && (flags & QEventLoop::ExcludeSocketNotifiers) |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
749 |
&& (msg.message == WM_QT_SOCKETNOTIFIER && msg.hwnd == d->internalHwnd)) { |
0 | 750 |
// queue socket events for later processing |
751 |
haveMessage = false; |
|
752 |
d->queuedSocketEvents.append(msg); |
|
753 |
} |
|
754 |
} |
|
755 |
if (!haveMessage) { |
|
756 |
// no message - check for signalled objects |
|
757 |
for (int i=0; i<(int)nCount; i++) |
|
758 |
pHandles[i] = d->winEventNotifierList.at(i)->handle(); |
|
759 |
waitRet = MsgWaitForMultipleObjectsEx(nCount, pHandles, 0, QS_ALLINPUT, MWMO_ALERTABLE); |
|
760 |
if ((haveMessage = (waitRet == WAIT_OBJECT_0 + nCount))) { |
|
761 |
// a new message has arrived, process it |
|
762 |
continue; |
|
763 |
} |
|
764 |
} |
|
765 |
if (haveMessage) { |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
766 |
#ifdef Q_OS_WINCE |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
767 |
// WinCE doesn't support hooks at all, so we have to call this by hand :( |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
768 |
(void) qt_GetMessageHook(0, PM_REMOVE, (LPARAM) &msg); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
769 |
#endif |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
770 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
771 |
if (d->internalHwnd == msg.hwnd && msg.message == WM_QT_SENDPOSTEDEVENTS) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
772 |
if (seenWM_QT_SENDPOSTEDEVENTS) { |
30
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
773 |
// when calling processEvents() "manually", we only want to send posted |
5dc02b23752f
Revision: 201025
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
18
diff
changeset
|
774 |
// events once |
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
775 |
needWM_QT_SENDPOSTEDEVENTS = true; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
776 |
continue; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
777 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
778 |
seenWM_QT_SENDPOSTEDEVENTS = true; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
779 |
} else if (msg.message == WM_TIMER) { |
0 | 780 |
// avoid live-lock by keeping track of the timers we've already sent |
781 |
bool found = false; |
|
782 |
for (int i = 0; !found && i < processedTimers.count(); ++i) { |
|
783 |
const MSG processed = processedTimers.constData()[i]; |
|
784 |
found = (processed.wParam == msg.wParam && processed.hwnd == msg.hwnd && processed.lParam == msg.lParam); |
|
785 |
} |
|
786 |
if (found) |
|
787 |
continue; |
|
788 |
processedTimers.append(msg); |
|
789 |
} else if (msg.message == WM_QUIT) { |
|
790 |
if (QCoreApplication::instance()) |
|
791 |
QCoreApplication::instance()->quit(); |
|
792 |
return false; |
|
793 |
} |
|
794 |
||
795 |
if (!filterEvent(&msg)) { |
|
796 |
TranslateMessage(&msg); |
|
797 |
DispatchMessage(&msg); |
|
798 |
} |
|
799 |
} else if (waitRet >= WAIT_OBJECT_0 && waitRet < WAIT_OBJECT_0 + nCount) { |
|
800 |
d->activateEventNotifier(d->winEventNotifierList.at(waitRet - WAIT_OBJECT_0)); |
|
801 |
} else { |
|
802 |
// nothing todo so break |
|
803 |
break; |
|
804 |
} |
|
805 |
retVal = true; |
|
806 |
} |
|
807 |
||
808 |
// still nothing - wait for message or signalled objects |
|
809 |
canWait = (!retVal |
|
810 |
&& !d->interrupt |
|
811 |
&& (flags & QEventLoop::WaitForMoreEvents)); |
|
812 |
if (canWait) { |
|
813 |
DWORD nCount = d->winEventNotifierList.count(); |
|
814 |
Q_ASSERT(nCount < MAXIMUM_WAIT_OBJECTS - 1); |
|
815 |
for (int i=0; i<(int)nCount; i++) |
|
816 |
pHandles[i] = d->winEventNotifierList.at(i)->handle(); |
|
817 |
||
818 |
emit aboutToBlock(); |
|
819 |
waitRet = MsgWaitForMultipleObjectsEx(nCount, pHandles, INFINITE, QS_ALLINPUT, MWMO_ALERTABLE); |
|
820 |
emit awake(); |
|
821 |
if (waitRet >= WAIT_OBJECT_0 && waitRet < WAIT_OBJECT_0 + nCount) { |
|
822 |
d->activateEventNotifier(d->winEventNotifierList.at(waitRet - WAIT_OBJECT_0)); |
|
823 |
retVal = true; |
|
824 |
} |
|
825 |
} |
|
826 |
} while (canWait); |
|
827 |
||
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
828 |
if (!seenWM_QT_SENDPOSTEDEVENTS && (flags & QEventLoop::EventLoopExec) == 0) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
829 |
// when called "manually", always send posted events |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
830 |
QCoreApplicationPrivate::sendPostedEvents(0, 0, d->threadData); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
831 |
} |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
832 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
833 |
if (needWM_QT_SENDPOSTEDEVENTS) |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
834 |
PostMessage(d->internalHwnd, WM_QT_SENDPOSTEDEVENTS, 0, 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
835 |
|
0 | 836 |
return retVal; |
837 |
} |
|
838 |
||
839 |
bool QEventDispatcherWin32::hasPendingEvents() |
|
840 |
{ |
|
841 |
MSG msg; |
|
842 |
return qGlobalPostedEventsCount() || PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE); |
|
843 |
} |
|
844 |
||
845 |
void QEventDispatcherWin32::registerSocketNotifier(QSocketNotifier *notifier) |
|
846 |
{ |
|
847 |
Q_ASSERT(notifier); |
|
848 |
int sockfd = notifier->socket(); |
|
849 |
int type = notifier->type(); |
|
850 |
#ifndef QT_NO_DEBUG |
|
851 |
if (sockfd < 0) { |
|
852 |
qWarning("QSocketNotifier: Internal error"); |
|
853 |
return; |
|
854 |
} else if (notifier->thread() != thread() || thread() != QThread::currentThread()) { |
|
855 |
qWarning("QSocketNotifier: socket notifiers cannot be enabled from another thread"); |
|
856 |
return; |
|
857 |
} |
|
858 |
#endif |
|
859 |
||
860 |
Q_D(QEventDispatcherWin32); |
|
861 |
QSNDict *sn_vec[3] = { &d->sn_read, &d->sn_write, &d->sn_except }; |
|
862 |
QSNDict *dict = sn_vec[type]; |
|
863 |
||
864 |
if (QCoreApplication::closingDown()) // ### d->exitloop? |
|
865 |
return; // after sn_cleanup, don't reinitialize. |
|
866 |
||
867 |
if (dict->contains(sockfd)) { |
|
868 |
const char *t[] = { "Read", "Write", "Exception" }; |
|
869 |
/* Variable "socket" below is a function pointer. */ |
|
870 |
qWarning("QSocketNotifier: Multiple socket notifiers for " |
|
871 |
"same socket %d and type %s", sockfd, t[type]); |
|
872 |
} |
|
873 |
||
874 |
QSockNot *sn = new QSockNot; |
|
875 |
sn->obj = notifier; |
|
876 |
sn->fd = sockfd; |
|
877 |
dict->insert(sn->fd, sn); |
|
878 |
||
879 |
if (d->internalHwnd) |
|
880 |
d->doWsaAsyncSelect(sockfd); |
|
881 |
} |
|
882 |
||
883 |
void QEventDispatcherWin32::unregisterSocketNotifier(QSocketNotifier *notifier) |
|
884 |
{ |
|
885 |
Q_ASSERT(notifier); |
|
886 |
int sockfd = notifier->socket(); |
|
887 |
int type = notifier->type(); |
|
888 |
#ifndef QT_NO_DEBUG |
|
889 |
if (sockfd < 0) { |
|
890 |
qWarning("QSocketNotifier: Internal error"); |
|
891 |
return; |
|
892 |
} else if (notifier->thread() != thread() || thread() != QThread::currentThread()) { |
|
893 |
qWarning("QSocketNotifier: socket notifiers cannot be disabled from another thread"); |
|
894 |
return; |
|
895 |
} |
|
896 |
#endif |
|
897 |
||
898 |
Q_D(QEventDispatcherWin32); |
|
899 |
QSNDict *sn_vec[3] = { &d->sn_read, &d->sn_write, &d->sn_except }; |
|
900 |
QSNDict *dict = sn_vec[type]; |
|
901 |
QSockNot *sn = dict->value(sockfd); |
|
902 |
if (!sn) |
|
903 |
return; |
|
904 |
||
905 |
dict->remove(sockfd); |
|
906 |
delete sn; |
|
907 |
||
908 |
if (d->internalHwnd) |
|
909 |
d->doWsaAsyncSelect(sockfd); |
|
910 |
} |
|
911 |
||
912 |
void QEventDispatcherWin32::registerTimer(int timerId, int interval, QObject *object) |
|
913 |
{ |
|
914 |
if (timerId < 1 || interval < 0 || !object) { |
|
915 |
qWarning("QEventDispatcherWin32::registerTimer: invalid arguments"); |
|
916 |
return; |
|
917 |
} else if (object->thread() != thread() || thread() != QThread::currentThread()) { |
|
918 |
qWarning("QObject::startTimer: timers cannot be started from another thread"); |
|
919 |
return; |
|
920 |
} |
|
921 |
||
922 |
Q_D(QEventDispatcherWin32); |
|
923 |
||
924 |
register WinTimerInfo *t = new WinTimerInfo; |
|
925 |
t->dispatcher = this; |
|
926 |
t->timerId = timerId; |
|
927 |
t->interval = interval; |
|
928 |
t->obj = object; |
|
929 |
t->inTimerEvent = false; |
|
930 |
t->fastTimerId = 0; |
|
931 |
||
932 |
if (d->internalHwnd) |
|
933 |
d->registerTimer(t); |
|
934 |
||
935 |
d->timerVec.append(t); // store in timer vector |
|
936 |
d->timerDict.insert(t->timerId, t); // store timers in dict |
|
937 |
} |
|
938 |
||
939 |
bool QEventDispatcherWin32::unregisterTimer(int timerId) |
|
940 |
{ |
|
941 |
if (timerId < 1) { |
|
942 |
qWarning("QEventDispatcherWin32::unregisterTimer: invalid argument"); |
|
943 |
return false; |
|
944 |
} |
|
945 |
QThread *currentThread = QThread::currentThread(); |
|
946 |
if (thread() != currentThread) { |
|
947 |
qWarning("QObject::killTimer: timers cannot be stopped from another thread"); |
|
948 |
return false; |
|
949 |
} |
|
950 |
||
951 |
Q_D(QEventDispatcherWin32); |
|
952 |
if (d->timerVec.isEmpty() || timerId <= 0) |
|
953 |
return false; |
|
954 |
||
955 |
WinTimerInfo *t = d->timerDict.value(timerId); |
|
956 |
if (!t) |
|
957 |
return false; |
|
958 |
||
959 |
d->timerDict.remove(t->timerId); |
|
960 |
d->timerVec.removeAll(t); |
|
961 |
d->unregisterTimer(t); |
|
962 |
return true; |
|
963 |
} |
|
964 |
||
965 |
bool QEventDispatcherWin32::unregisterTimers(QObject *object) |
|
966 |
{ |
|
967 |
if (!object) { |
|
968 |
qWarning("QEventDispatcherWin32::unregisterTimers: invalid argument"); |
|
969 |
return false; |
|
970 |
} |
|
971 |
QThread *currentThread = QThread::currentThread(); |
|
972 |
if (object->thread() != thread() || thread() != currentThread) { |
|
973 |
qWarning("QObject::killTimers: timers cannot be stopped from another thread"); |
|
974 |
return false; |
|
975 |
} |
|
976 |
||
977 |
Q_D(QEventDispatcherWin32); |
|
978 |
if (d->timerVec.isEmpty()) |
|
979 |
return false; |
|
980 |
register WinTimerInfo *t; |
|
981 |
for (int i=0; i<d->timerVec.size(); i++) { |
|
982 |
t = d->timerVec.at(i); |
|
983 |
if (t && t->obj == object) { // object found |
|
984 |
d->timerDict.remove(t->timerId); |
|
985 |
d->timerVec.removeAt(i); |
|
986 |
d->unregisterTimer(t); |
|
987 |
--i; |
|
988 |
} |
|
989 |
} |
|
990 |
return true; |
|
991 |
} |
|
992 |
||
993 |
QList<QEventDispatcherWin32::TimerInfo> |
|
994 |
QEventDispatcherWin32::registeredTimers(QObject *object) const |
|
995 |
{ |
|
996 |
if (!object) { |
|
997 |
qWarning("QEventDispatcherWin32:registeredTimers: invalid argument"); |
|
998 |
return QList<TimerInfo>(); |
|
999 |
} |
|
1000 |
||
1001 |
Q_D(const QEventDispatcherWin32); |
|
1002 |
QList<TimerInfo> list; |
|
1003 |
for (int i = 0; i < d->timerVec.size(); ++i) { |
|
1004 |
const WinTimerInfo *t = d->timerVec.at(i); |
|
1005 |
if (t && t->obj == object) |
|
1006 |
list << TimerInfo(t->timerId, t->interval); |
|
1007 |
} |
|
1008 |
return list; |
|
1009 |
} |
|
1010 |
||
1011 |
bool QEventDispatcherWin32::registerEventNotifier(QWinEventNotifier *notifier) |
|
1012 |
{ |
|
1013 |
if (!notifier) { |
|
1014 |
qWarning("QWinEventNotifier: Internal error"); |
|
1015 |
return false; |
|
1016 |
} else if (notifier->thread() != thread() || thread() != QThread::currentThread()) { |
|
1017 |
qWarning("QWinEventNotifier: event notifiers cannot be enabled from another thread"); |
|
1018 |
return false; |
|
1019 |
} |
|
1020 |
||
1021 |
Q_D(QEventDispatcherWin32); |
|
1022 |
||
1023 |
if (d->winEventNotifierList.contains(notifier)) |
|
1024 |
return true; |
|
1025 |
||
1026 |
if (d->winEventNotifierList.count() >= MAXIMUM_WAIT_OBJECTS - 2) { |
|
1027 |
qWarning("QWinEventNotifier: Cannot have more than %d enabled at one time", MAXIMUM_WAIT_OBJECTS - 2); |
|
1028 |
return false; |
|
1029 |
} |
|
1030 |
d->winEventNotifierList.append(notifier); |
|
1031 |
return true; |
|
1032 |
} |
|
1033 |
||
1034 |
void QEventDispatcherWin32::unregisterEventNotifier(QWinEventNotifier *notifier) |
|
1035 |
{ |
|
1036 |
if (!notifier) { |
|
1037 |
qWarning("QWinEventNotifier: Internal error"); |
|
1038 |
return; |
|
1039 |
} else if (notifier->thread() != thread() || thread() != QThread::currentThread()) { |
|
1040 |
qWarning("QWinEventNotifier: event notifiers cannot be disabled from another thread"); |
|
1041 |
return; |
|
1042 |
} |
|
1043 |
||
1044 |
Q_D(QEventDispatcherWin32); |
|
1045 |
||
1046 |
int i = d->winEventNotifierList.indexOf(notifier); |
|
1047 |
if (i != -1) |
|
1048 |
d->winEventNotifierList.takeAt(i); |
|
1049 |
} |
|
1050 |
||
1051 |
void QEventDispatcherWin32::activateEventNotifiers() |
|
1052 |
{ |
|
1053 |
Q_D(QEventDispatcherWin32); |
|
1054 |
//### this could break if events are removed/added in the activation |
|
1055 |
for (int i=0; i<d->winEventNotifierList.count(); i++) { |
|
1056 |
#if !defined(Q_OS_WINCE) |
|
1057 |
if (WaitForSingleObjectEx(d->winEventNotifierList.at(i)->handle(), 0, TRUE) == WAIT_OBJECT_0) |
|
1058 |
d->activateEventNotifier(d->winEventNotifierList.at(i)); |
|
1059 |
#else |
|
1060 |
if (WaitForSingleObject(d->winEventNotifierList.at(i)->handle(), 0) == WAIT_OBJECT_0) |
|
1061 |
d->activateEventNotifier(d->winEventNotifierList.at(i)); |
|
1062 |
#endif |
|
1063 |
} |
|
1064 |
} |
|
1065 |
||
1066 |
void QEventDispatcherWin32::wakeUp() |
|
1067 |
{ |
|
1068 |
Q_D(QEventDispatcherWin32); |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1069 |
d->serialNumber.ref(); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1070 |
if (d->internalHwnd && d->wakeUps.testAndSetAcquire(0, 1)) { |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1071 |
// post a WM_QT_SENDPOSTEDEVENTS to this thread if there isn't one already pending |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1072 |
PostMessage(d->internalHwnd, WM_QT_SENDPOSTEDEVENTS, 0, 0); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1073 |
} |
0 | 1074 |
} |
1075 |
||
1076 |
void QEventDispatcherWin32::interrupt() |
|
1077 |
{ |
|
1078 |
Q_D(QEventDispatcherWin32); |
|
1079 |
d->interrupt = true; |
|
1080 |
wakeUp(); |
|
1081 |
} |
|
1082 |
||
1083 |
void QEventDispatcherWin32::flush() |
|
1084 |
{ } |
|
1085 |
||
1086 |
void QEventDispatcherWin32::startingUp() |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1087 |
{ } |
0 | 1088 |
|
1089 |
void QEventDispatcherWin32::closingDown() |
|
1090 |
{ |
|
1091 |
Q_D(QEventDispatcherWin32); |
|
1092 |
||
1093 |
// clean up any socketnotifiers |
|
1094 |
while (!d->sn_read.isEmpty()) |
|
1095 |
unregisterSocketNotifier((*(d->sn_read.begin()))->obj); |
|
1096 |
while (!d->sn_write.isEmpty()) |
|
1097 |
unregisterSocketNotifier((*(d->sn_write.begin()))->obj); |
|
1098 |
while (!d->sn_except.isEmpty()) |
|
1099 |
unregisterSocketNotifier((*(d->sn_except.begin()))->obj); |
|
1100 |
||
1101 |
// clean up any timers |
|
1102 |
for (int i = 0; i < d->timerVec.count(); ++i) |
|
1103 |
d->unregisterTimer(d->timerVec.at(i), true); |
|
1104 |
d->timerVec.clear(); |
|
1105 |
d->timerDict.clear(); |
|
3
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1106 |
|
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1107 |
#ifndef Q_OS_WINCE |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1108 |
if (d->getMessageHook) |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1109 |
UnhookWindowsHookEx(d->getMessageHook); |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1110 |
d->getMessageHook = 0; |
41300fa6a67c
Revision: 201003
Dremov Kirill (Nokia-D-MSW/Tampere) <kirill.dremov@nokia.com>
parents:
0
diff
changeset
|
1111 |
#endif |
0 | 1112 |
} |
1113 |
||
1114 |
bool QEventDispatcherWin32::event(QEvent *e) |
|
1115 |
{ |
|
1116 |
Q_D(QEventDispatcherWin32); |
|
1117 |
if (e->type() == QEvent::ZeroTimerEvent) { |
|
1118 |
QZeroTimerEvent *zte = static_cast<QZeroTimerEvent*>(e); |
|
1119 |
WinTimerInfo *t = d->timerDict.value(zte->timerId()); |
|
1120 |
if (t) { |
|
1121 |
t->inTimerEvent = true; |
|
1122 |
||
1123 |
QTimerEvent te(zte->timerId()); |
|
1124 |
QCoreApplication::sendEvent(t->obj, &te); |
|
1125 |
||
1126 |
t = d->timerDict.value(zte->timerId()); |
|
1127 |
if (t) { |
|
1128 |
if (t->interval == 0 && t->inTimerEvent) { |
|
1129 |
// post the next zero timer event as long as the timer was not restarted |
|
1130 |
QCoreApplication::postEvent(this, new QZeroTimerEvent(zte->timerId())); |
|
1131 |
} |
|
1132 |
||
1133 |
t->inTimerEvent = false; |
|
1134 |
} |
|
1135 |
} |
|
1136 |
return true; |
|
1137 |
} else if (e->type() == QEvent::Timer) { |
|
1138 |
QTimerEvent *te = static_cast<QTimerEvent*>(e); |
|
1139 |
d->sendTimerEvent(te->timerId()); |
|
1140 |
} |
|
1141 |
return QAbstractEventDispatcher::event(e); |
|
1142 |
} |
|
1143 |
||
1144 |
QT_END_NAMESPACE |