-rw-r--r-- | x11/ipc/server/ocopserver.cpp | 51 | ||||
-rw-r--r-- | x11/libqpe-x11/qpe/qpeapplication.cpp | 90 | ||||
-rw-r--r-- | x11/libqpe-x11/qpe/qpeapplication.h | 2 |
3 files changed, 123 insertions, 20 deletions
diff --git a/x11/ipc/server/ocopserver.cpp b/x11/ipc/server/ocopserver.cpp index 4940cb8..0f818b7 100644 --- a/x11/ipc/server/ocopserver.cpp +++ b/x11/ipc/server/ocopserver.cpp | |||
@@ -164,7 +164,7 @@ void OCopServer::newOnClient( int fd ) { | |||
164 | * | 164 | * |
165 | */ | 165 | */ |
166 | if (head.magic == 47 ) { | 166 | if (head.magic == 47 ) { |
167 | qWarning("magic match"); | 167 | // qWarning("magic match"); |
168 | QCString channel( head.chlen+1 ); | 168 | QCString channel( head.chlen+1 ); |
169 | QCString func( head.funclen+1 ); | 169 | QCString func( head.funclen+1 ); |
170 | QByteArray data ( head.datalen ); | 170 | QByteArray data ( head.datalen ); |
@@ -172,15 +172,15 @@ void OCopServer::newOnClient( int fd ) { | |||
172 | /* | 172 | /* |
173 | * we do not check for errors | 173 | * we do not check for errors |
174 | */ | 174 | */ |
175 | qWarning("read "); | 175 | // qWarning("read "); |
176 | int s = read(fd, channel.data(), head.chlen ); | 176 | int s = read(fd, channel.data(), head.chlen ); |
177 | s = read(fd, func.data(), head.funclen ); | 177 | s = read(fd, func.data(), head.funclen ); |
178 | s = read(fd, data.data(), head.datalen ); | 178 | s = read(fd, data.data(), head.datalen ); |
179 | qWarning("read"); | 179 | // qWarning("read"); |
180 | 180 | ||
181 | /* debug output */ | 181 | /* debug output */ |
182 | qWarning("channel %s %d", channel.data(), head.chlen ); | 182 | // qWarning("channel %s %d", channel.data(), head.chlen ); |
183 | qWarning("func %s %d", func.data(), head.funclen ); | 183 | // qWarning("func %s %d", func.data(), head.funclen ); |
184 | /* debug end */ | 184 | /* debug end */ |
185 | 185 | ||
186 | /* | 186 | /* |
@@ -214,10 +214,6 @@ void OCopServer::registerClient( int fd ) { | |||
214 | void OCopServer::deregisterClient(int fd ) { | 214 | void OCopServer::deregisterClient(int fd ) { |
215 | QMap<int, OCOPClient>::Iterator it = m_clients.find( fd ); | 215 | QMap<int, OCOPClient>::Iterator it = m_clients.find( fd ); |
216 | if (it != m_clients.end() ) { | 216 | if (it != m_clients.end() ) { |
217 | OCOPClient client = it.data(); | ||
218 | delete client.notify; | ||
219 | m_clients.remove(fd ); | ||
220 | close(fd ); | ||
221 | /* | 217 | /* |
222 | * TIME_ME | 218 | * TIME_ME |
223 | * | 219 | * |
@@ -233,7 +229,7 @@ void OCopServer::deregisterClient(int fd ) { | |||
233 | /* | 229 | /* |
234 | * The channel contains this fd | 230 | * The channel contains this fd |
235 | */ | 231 | */ |
236 | qWarning("Channel %s", it2.key().data() ); | 232 | qWarning("Channel %s %d", it2.key().data(), it2.data().count() ); |
237 | if ( it2.data().contains( fd ) ) { | 233 | if ( it2.data().contains( fd ) ) { |
238 | qWarning("contains"); | 234 | qWarning("contains"); |
239 | QValueList<int> array = it2.data(); | 235 | QValueList<int> array = it2.data(); |
@@ -241,7 +237,7 @@ void OCopServer::deregisterClient(int fd ) { | |||
241 | /* | 237 | /* |
242 | * remove channel or just replace | 238 | * remove channel or just replace |
243 | */ | 239 | */ |
244 | if ( array.count() == 1 ) { | 240 | if ( array.count() == 1 || array.count() == 0) { |
245 | qWarning("Invalidate!"); | 241 | qWarning("Invalidate!"); |
246 | /* is the list now invalidatet? */ | 242 | /* is the list now invalidatet? */ |
247 | m_channels.remove( it2 ); | 243 | m_channels.remove( it2 ); |
@@ -254,12 +250,18 @@ void OCopServer::deregisterClient(int fd ) { | |||
254 | */ | 250 | */ |
255 | goto repeatIt; | 251 | goto repeatIt; |
256 | }else{ | 252 | }else{ |
257 | qWarning("removing"); | 253 | qWarning("removing count %d %d",fd, array.count() ); |
258 | array.remove( fd ); | 254 | QValueList<int>::Iterator it3 = array.find( fd ); |
259 | it2 = m_channels.replace( it2.key(), array ); | 255 | it3 = array.remove( it3 ); |
256 | QCString key = it2.key().copy(); | ||
257 | it2 = m_channels.replace( key, array ); | ||
260 | } | 258 | } |
261 | } | 259 | } |
262 | } // off all channels | 260 | } // off all channels |
261 | OCOPClient client = it.data(); | ||
262 | delete client.notify; | ||
263 | m_clients.remove(fd ); | ||
264 | close(fd ); | ||
263 | } | 265 | } |
264 | qWarning("clients are now at %d", m_clients.count() ); | 266 | qWarning("clients are now at %d", m_clients.count() ); |
265 | }; | 267 | }; |
@@ -327,14 +329,21 @@ void OCopServer::addChannel( const QCString& channel, | |||
327 | int fd ) { | 329 | int fd ) { |
328 | QMap<QCString, QValueList<int> >::Iterator it; | 330 | QMap<QCString, QValueList<int> >::Iterator it; |
329 | it = m_channels.find( channel ); | 331 | it = m_channels.find( channel ); |
330 | 332 | if ( it != m_channels.end() ) { | |
331 | /* could be empty */ | 333 | /* could be empty */ |
332 | QValueList<int> list = it.data(); | 334 | QValueList<int> list = it.data(); |
333 | list.append( fd ); | 335 | list.append( fd ); |
336 | qWarning("count is now in addChannel %d %s", list.count(), channel.data() ); | ||
334 | it = m_channels.replace( channel, list ); | 337 | it = m_channels.replace( channel, list ); |
338 | }else { | ||
339 | QValueList<int> ints; | ||
340 | ints.append( fd ); | ||
341 | m_channels.insert( channel, ints ); | ||
342 | } | ||
335 | }; | 343 | }; |
336 | void OCopServer::delChannel( const QCString& channel, | 344 | void OCopServer::delChannel( const QCString& channel, |
337 | int fd ) { | 345 | int fd ) { |
346 | qWarning("remove %s, %d", channel.data(), fd ); | ||
338 | if (!m_channels.contains( channel ) ) | 347 | if (!m_channels.contains( channel ) ) |
339 | return; | 348 | return; |
340 | 349 | ||
@@ -342,19 +351,21 @@ void OCopServer::delChannel( const QCString& channel, | |||
342 | it = m_channels.find( channel ); | 351 | it = m_channels.find( channel ); |
343 | 352 | ||
344 | if ( it.data().contains(fd) ) { | 353 | if ( it.data().contains(fd) ) { |
345 | |||
346 | QValueList<int> ints = it.data(); | 354 | QValueList<int> ints = it.data(); |
347 | if ( ints.count() == 1 ) | 355 | if ( ints.count() == 1 ) |
348 | m_channels.remove( it ); | 356 | m_channels.remove( channel ); |
349 | else{ | 357 | else{ |
350 | QValueList<int> ints = it.data(); | 358 | QValueList<int> ints = it.data(); |
351 | ints.remove( fd ); | 359 | QValueList<int>::Iterator rem = ints.find( fd ); |
352 | m_channels.replace( it.key(), ints ); | 360 | rem = ints.remove( rem ); |
361 | QCString str = it.key().copy(); | ||
362 | m_channels.replace( str, ints ); | ||
353 | } | 363 | } |
364 | qWarning(" channel count is now %d", ints.count() ); | ||
354 | } | 365 | } |
355 | } | 366 | } |
356 | void OCopServer::isRegistered( const QCString& channel, int fd) { | 367 | void OCopServer::isRegistered( const QCString& channel, int fd) { |
357 | qWarning("isRegistered"); | 368 | // qWarning("isRegistered"); |
358 | OCOPHead head; | 369 | OCOPHead head; |
359 | QCString func(2); | 370 | QCString func(2); |
360 | 371 | ||
diff --git a/x11/libqpe-x11/qpe/qpeapplication.cpp b/x11/libqpe-x11/qpe/qpeapplication.cpp index 8785c74..75a8189 100644 --- a/x11/libqpe-x11/qpe/qpeapplication.cpp +++ b/x11/libqpe-x11/qpe/qpeapplication.cpp | |||
@@ -5,6 +5,7 @@ | |||
5 | #include <unistd.h> | 5 | #include <unistd.h> |
6 | #include <sys/file.h> | 6 | #include <sys/file.h> |
7 | 7 | ||
8 | |||
8 | #include <qdir.h> | 9 | #include <qdir.h> |
9 | #include <qdialog.h> | 10 | #include <qdialog.h> |
10 | #include <qdragobject.h> | 11 | #include <qdragobject.h> |
@@ -16,6 +17,7 @@ | |||
16 | #include <qpalette.h> | 17 | #include <qpalette.h> |
17 | #include <qptrdict.h> | 18 | #include <qptrdict.h> |
18 | #include <qregexp.h> | 19 | #include <qregexp.h> |
20 | #include <qtimer.h> | ||
19 | 21 | ||
20 | #include <qpe/alarmserver.h> | 22 | #include <qpe/alarmserver.h> |
21 | #include <qpe/applnk.h> | 23 | #include <qpe/applnk.h> |
@@ -34,6 +36,15 @@ | |||
34 | #include <qpe/timestring.h> | 36 | #include <qpe/timestring.h> |
35 | #include <qpe/qcopenvelope_qws.h> | 37 | #include <qpe/qcopenvelope_qws.h> |
36 | 38 | ||
39 | |||
40 | #include <X11/Xlib.h> | ||
41 | #include <X11/Xutil.h> | ||
42 | |||
43 | const int XKeyPress = KeyPress; | ||
44 | const int XKeyRelease = KeyRelease; | ||
45 | #undef KeyPress | ||
46 | #undef KeyRelease | ||
47 | |||
37 | namespace { | 48 | namespace { |
38 | struct QCopRec{ | 49 | struct QCopRec{ |
39 | QCopRec( const QCString& ch, const QCString& msg, const QByteArray& ar ) | 50 | QCopRec( const QCString& ch, const QCString& msg, const QByteArray& ar ) |
@@ -76,6 +87,11 @@ public: | |||
76 | QString appName; | 87 | QString appName; |
77 | QString styleName; | 88 | QString styleName; |
78 | QString decorationName; | 89 | QString decorationName; |
90 | Atom wm_delete_window; | ||
91 | Atom wm_take_focus; | ||
92 | Atom wm_context_help; | ||
93 | Atom wm_context_accept; | ||
94 | Atom wm_protocols; | ||
79 | 95 | ||
80 | private: | 96 | private: |
81 | QList<QCopRec> qcopq; | 97 | QList<QCopRec> qcopq; |
@@ -219,6 +235,32 @@ QPEApplication::QPEApplication(int &arg, char** argv, Type t) | |||
219 | d->loadTextCodecs(); | 235 | d->loadTextCodecs(); |
220 | d->loadImageCodecs(); | 236 | d->loadImageCodecs(); |
221 | 237 | ||
238 | // Init X-Atom | ||
239 | Atom *atoms[5]; | ||
240 | Atom atoms_re[5]; | ||
241 | char* names[5]; | ||
242 | int n = 0; | ||
243 | atoms[n] = &d->wm_delete_window; | ||
244 | names[n++] = "WM_DELETE_WINDOW"; | ||
245 | |||
246 | atoms[n] = &d->wm_take_focus; | ||
247 | names[n++] = "WM_TAKE_FOCUS"; | ||
248 | |||
249 | atoms[n] = &d->wm_context_help; | ||
250 | names[n++] = "_NET_WM_CONTEXT_HELP"; | ||
251 | |||
252 | atoms[n] = &d->wm_context_accept; | ||
253 | names[n++] = "_NET_WM_CONTEXT_ACCEPT"; | ||
254 | |||
255 | atoms[n] = &d->wm_protocols; | ||
256 | names[n++] = "WM_PROTOCOLS"; | ||
257 | |||
258 | XInternAtoms( qt_xdisplay(), names, n, FALSE, atoms_re); | ||
259 | // now copy the values over to the properties | ||
260 | for (int i = 0; i < n; i++ ) | ||
261 | *atoms[i] = atoms_re[i]; | ||
262 | // done with X11 Stuff | ||
263 | |||
222 | int dw = desktop()->width(); | 264 | int dw = desktop()->width(); |
223 | if ( dw < 200 ) { | 265 | if ( dw < 200 ) { |
224 | setFont( QFont( "helvetica", 8 ) ); | 266 | setFont( QFont( "helvetica", 8 ) ); |
@@ -530,6 +572,26 @@ QPEApplication::StylusMode QPEApplication::stylusOperation( QWidget* w) { | |||
530 | 572 | ||
531 | // eventFilter...... | 573 | // eventFilter...... |
532 | bool QPEApplication::eventFilter( QObject* o, QEvent* e ) { | 574 | bool QPEApplication::eventFilter( QObject* o, QEvent* e ) { |
575 | /* | ||
576 | * We want our WM to show Ok and a X button | ||
577 | * on dialogs | ||
578 | * our part is to set the _NET_WM_CONTEXT_ACCEPT | ||
579 | * propery | ||
580 | * and then wait for a client message -zecke | ||
581 | * on show we will add the prop | ||
582 | */ | ||
583 | if (o->inherits("QDialog") && e->type() == QEvent::Show ) { | ||
584 | QDialog* dialog = (QDialog*)o; | ||
585 | Atom wm_prot[45]; | ||
586 | int n = 0; | ||
587 | wm_prot[n++] = d->wm_delete_window; | ||
588 | wm_prot[n++] = d->wm_take_focus; | ||
589 | wm_prot[n++] = d->wm_context_accept; | ||
590 | if ( dialog->testWFlags( WStyle_ContextHelp ) ) | ||
591 | wm_prot[n++] = d->wm_context_help; | ||
592 | XSetWMProtocols( qt_xdisplay(), dialog->winId(), wm_prot, n ); | ||
593 | return TRUE; // should be save | ||
594 | } | ||
533 | if ( stylusDict && e->type() >= QEvent::MouseButtonPress && e->type() <= QEvent::MouseMove ) { | 595 | if ( stylusDict && e->type() >= QEvent::MouseButtonPress && e->type() <= QEvent::MouseMove ) { |
534 | QMouseEvent * me = ( QMouseEvent* ) e; | 596 | QMouseEvent * me = ( QMouseEvent* ) e; |
535 | StylusMode mode = (StylusMode)(int)stylusDict->find(o); | 597 | StylusMode mode = (StylusMode)(int)stylusDict->find(o); |
@@ -657,6 +719,34 @@ void QPEApplication::prepareForTermination( bool willrestart ) | |||
657 | sleep( 1 ); // You have 1 second to comply. | 719 | sleep( 1 ); // You have 1 second to comply. |
658 | #endif | 720 | #endif |
659 | } | 721 | } |
722 | int QPEApplication::x11ClientMessage(QWidget* w, XEvent* event, bool b ) { | ||
723 | qWarning("X11 ClientMessage %d %d", event->type, ClientMessage); | ||
724 | if ( event->type == ClientMessage ) { | ||
725 | if ( (event->xclient.message_type == d->wm_protocols) && | ||
726 | (event->xclient.data.l[0] == d->wm_context_accept ) ) { | ||
727 | qWarning("accepted!!!"); | ||
728 | /* | ||
729 | * I'm not sure if we should use activeWidget | ||
730 | * or activeModalWidget | ||
731 | * a QDialog could be not modal too | ||
732 | */ | ||
733 | if ( w->inherits("QDialog" ) ) { | ||
734 | qWarning("inherits QDialog!!!"); | ||
735 | QDialog* dia = (QDialog*)w; | ||
736 | /* | ||
737 | * call it directly or via QTimer::singleShot? | ||
738 | */ | ||
739 | QTimer::singleShot(0, dia, SLOT(reject() ) ); | ||
740 | return 0; | ||
741 | } | ||
742 | |||
743 | } | ||
744 | } | ||
745 | return QApplication::x11ClientMessage(w, event, b ); | ||
746 | } | ||
747 | |||
748 | #define KeyPress XKeyPress | ||
749 | #define KeyRelease XKeyRelease | ||
660 | 750 | ||
661 | #if defined(QT_QWS_IPAQ) || defined(QT_QWS_EBX) | 751 | #if defined(QT_QWS_IPAQ) || defined(QT_QWS_EBX) |
662 | 752 | ||
diff --git a/x11/libqpe-x11/qpe/qpeapplication.h b/x11/libqpe-x11/qpe/qpeapplication.h index 333f331..254fbfa 100644 --- a/x11/libqpe-x11/qpe/qpeapplication.h +++ b/x11/libqpe-x11/qpe/qpeapplication.h | |||
@@ -61,6 +61,8 @@ public: | |||
61 | DisableSuspend = 2, | 61 | DisableSuspend = 2, |
62 | Enable = 100 | 62 | Enable = 100 |
63 | }; | 63 | }; |
64 | /* reimplemented for internal purposes */ | ||
65 | int x11ClientMessage( QWidget*, XEvent*, bool ); | ||
64 | 66 | ||
65 | signals: | 67 | signals: |
66 | void clientMoused(); | 68 | void clientMoused(); |