]> git.saurik.com Git - wxWidgets.git/blame - src/common/sckipc.cpp
Added mouse event handler invocations
[wxWidgets.git] / src / common / sckipc.cpp
CommitLineData
f4ada568 1/////////////////////////////////////////////////////////////////////////////
d5da0ce7 2// Name: src/common/sckipc.cpp
f4ada568 3// Purpose: Interprocess communication implementation (wxSocket version)
0834112f 4// Author: Julian Smart
f4ada568 5// Modified by: Guilhem Lavaux (big rewrite) May 1997, 1998
0834112f 6// Guillermo Rodriguez (updated for wxSocket v2) Jan 2000
cdc59bb6 7// (callbacks deprecated) Mar 2000
0dbfd66d 8// Vadim Zeitlin (added support for Unix sockets) Apr 2002
f4ada568
GL
9// Created: 1993
10// RCS-ID: $Id$
0834112f
GRG
11// Copyright: (c) Julian Smart 1993
12// (c) Guilhem Lavaux 1997, 1998
13// (c) 2000 Guillermo Rodriguez <guille@iies.es>
65571936 14// Licence: wxWindows licence
f4ada568
GL
15/////////////////////////////////////////////////////////////////////////////
16
cdc59bb6
GRG
17// ==========================================================================
18// declarations
19// ==========================================================================
20
21// --------------------------------------------------------------------------
22// headers
23// --------------------------------------------------------------------------
24
fcc6dddd
JS
25// For compilers that support precompilation, includes "wx.h".
26#include "wx/wxprec.h"
f4ada568 27
fcc6dddd 28#ifdef __BORLANDC__
d5da0ce7 29 #pragma hdrstop
f4ada568
GL
30#endif
31
d5da0ce7
WS
32#if wxUSE_SOCKETS && wxUSE_IPC && wxUSE_STREAMS
33
34#include "wx/sckipc.h"
35
fcc6dddd 36#ifndef WX_PRECOMP
d5da0ce7
WS
37 #include "wx/log.h"
38 #include "wx/event.h"
02761f6c 39 #include "wx/module.h"
fcc6dddd
JS
40#endif
41
42#include <stdlib.h>
43#include <stdio.h>
0dbfd66d 44#include <errno.h>
fcc6dddd 45
f4ada568 46#include "wx/socket.h"
f4ada568 47
cdc59bb6
GRG
48// --------------------------------------------------------------------------
49// macros and constants
50// --------------------------------------------------------------------------
f4ada568
GL
51
52// It seems to be already defined somewhere in the Xt includes.
53#ifndef __XT__
54// Message codes
cdc59bb6
GRG
55enum
56{
f4ada568
GL
57 IPC_EXECUTE = 1,
58 IPC_REQUEST,
59 IPC_POKE,
60 IPC_ADVISE_START,
61 IPC_ADVISE_REQUEST,
62 IPC_ADVISE,
63 IPC_ADVISE_STOP,
64 IPC_REQUEST_REPLY,
65 IPC_FAIL,
66 IPC_CONNECT,
67 IPC_DISCONNECT
68};
69#endif
70
d3ea6527 71// All sockets will be created with the following flags
a24cc774 72#define SCKIPC_FLAGS (wxSOCKET_WAITALL)
d3ea6527 73
0dbfd66d
VZ
74// headers needed for umask()
75#ifdef __UNIX_LIKE__
76 #include <sys/types.h>
77 #include <sys/stat.h>
78#endif // __UNIX_LIKE__
79
80// ----------------------------------------------------------------------------
81// private functions
82// ----------------------------------------------------------------------------
83
84// get the address object for the given server name, the caller must delete it
85static wxSockAddress *
525d8583 86GetAddressFromName(const wxString& serverName, const wxString& host = wxEmptyString)
0dbfd66d
VZ
87{
88 // we always use INET sockets under non-Unix systems
7a59be6d 89#if defined(__UNIX__) && !defined(__WINDOWS__) && !defined(__WINE__) && (!defined(__WXMAC__) || defined(__DARWIN__))
0dbfd66d
VZ
90 // under Unix, if the server name looks like a path, create a AF_UNIX
91 // socket instead of AF_INET one
92 if ( serverName.Find(_T('/')) != wxNOT_FOUND )
93 {
94 wxUNIXaddress *addr = new wxUNIXaddress;
95 addr->Filename(serverName);
96
97 return addr;
98 }
99#endif // Unix/!Unix
100 {
101 wxIPV4address *addr = new wxIPV4address;
102 addr->Service(serverName);
103 if ( !host.empty() )
104 {
105 addr->Hostname(host);
106 }
107
108 return addr;
109 }
110}
111
cdc59bb6
GRG
112// --------------------------------------------------------------------------
113// wxTCPEventHandler stuff (private class)
114// --------------------------------------------------------------------------
115
116class wxTCPEventHandler : public wxEvtHandler
117{
118public:
d9e9fb52 119 wxTCPEventHandler() : wxEvtHandler() {}
cdc59bb6
GRG
120
121 void Client_OnRequest(wxSocketEvent& event);
122 void Server_OnRequest(wxSocketEvent& event);
123
124 DECLARE_EVENT_TABLE()
fc7a2a60 125 DECLARE_NO_COPY_CLASS(wxTCPEventHandler)
cdc59bb6
GRG
126};
127
128enum
129{
130 _CLIENT_ONREQUEST_ID = 1000,
131 _SERVER_ONREQUEST_ID
132};
133
134static wxTCPEventHandler *gs_handler = NULL;
135
136// ==========================================================================
137// implementation
138// ==========================================================================
139
140IMPLEMENT_DYNAMIC_CLASS(wxTCPServer, wxServerBase)
141IMPLEMENT_DYNAMIC_CLASS(wxTCPClient, wxClientBase)
142IMPLEMENT_CLASS(wxTCPConnection, wxConnectionBase)
143
144// --------------------------------------------------------------------------
f4ada568 145// wxTCPClient
cdc59bb6 146// --------------------------------------------------------------------------
f4ada568 147
cdc59bb6 148wxTCPClient::wxTCPClient () : wxClientBase()
f4ada568
GL
149{
150}
151
6e31e940 152wxTCPClient::~wxTCPClient ()
f4ada568
GL
153{
154}
155
156bool wxTCPClient::ValidHost(const wxString& host)
157{
158 wxIPV4address addr;
159
160 return addr.Hostname(host);
161}
162
163wxConnectionBase *wxTCPClient::MakeConnection (const wxString& host,
0dbfd66d 164 const wxString& serverName,
f4ada568
GL
165 const wxString& topic)
166{
e1026179
VZ
167 wxSockAddress *addr = GetAddressFromName(serverName, host);
168 if ( !addr )
169 return NULL;
170
d3ea6527 171 wxSocketClient *client = new wxSocketClient(SCKIPC_FLAGS);
f4ada568 172 wxSocketStream *stream = new wxSocketStream(*client);
0834112f
GRG
173 wxDataInputStream *data_is = new wxDataInputStream(*stream);
174 wxDataOutputStream *data_os = new wxDataOutputStream(*stream);
175
0dbfd66d
VZ
176 bool ok = client->Connect(*addr);
177 delete addr;
f4ada568 178
0dbfd66d 179 if ( ok )
0834112f
GRG
180 {
181 unsigned char msg;
26a25f95 182
0834112f
GRG
183 // Send topic name, and enquire whether this has succeeded
184 data_os->Write8(IPC_CONNECT);
185 data_os->WriteString(topic);
26a25f95 186
0834112f
GRG
187 msg = data_is->Read8();
188
189 // OK! Confirmation.
190 if (msg == IPC_CONNECT)
191 {
192 wxTCPConnection *connection = (wxTCPConnection *)OnMakeConnection ();
193
194 if (connection)
195 {
3adb47a9 196 if (connection->IsKindOf(CLASSINFO(wxTCPConnection)))
0834112f
GRG
197 {
198 connection->m_topic = topic;
199 connection->m_sock = client;
200 connection->m_sockstrm = stream;
201 connection->m_codeci = data_is;
202 connection->m_codeco = data_os;
cdc59bb6
GRG
203 client->SetEventHandler(*gs_handler, _CLIENT_ONREQUEST_ID);
204 client->SetClientData(connection);
0834112f 205 client->SetNotify(wxSOCKET_INPUT_FLAG | wxSOCKET_LOST_FLAG);
d775fa82 206 client->Notify(true);
0834112f
GRG
207 return connection;
208 }
3adb47a9
GRG
209 else
210 {
211 delete connection;
212 // and fall through to delete everything else
213 }
f4ada568 214 }
f4ada568 215 }
f4ada568 216 }
0834112f 217
3adb47a9 218 // Something went wrong, delete everything
0834112f
GRG
219 delete data_is;
220 delete data_os;
221 delete stream;
3adb47a9
GRG
222 client->Destroy();
223
0834112f 224 return NULL;
f4ada568
GL
225}
226
227wxConnectionBase *wxTCPClient::OnMakeConnection()
228{
e5b502f3 229 return new wxTCPConnection();
f4ada568
GL
230}
231
cdc59bb6 232// --------------------------------------------------------------------------
f4ada568 233// wxTCPServer
cdc59bb6 234// --------------------------------------------------------------------------
f4ada568 235
cdc59bb6 236wxTCPServer::wxTCPServer () : wxServerBase()
f4ada568 237{
f6bcfd97 238 m_server = NULL;
f4ada568
GL
239}
240
f6bcfd97 241bool wxTCPServer::Create(const wxString& serverName)
f4ada568 242{
f6bcfd97
BP
243 // Destroy previous server, if any
244 if (m_server)
245 {
246 m_server->SetClientData(NULL);
247 m_server->Destroy();
248 m_server = NULL;
249 }
f4ada568 250
0dbfd66d
VZ
251 wxSockAddress *addr = GetAddressFromName(serverName);
252 if ( !addr )
d775fa82 253 return false;
0dbfd66d
VZ
254
255#ifdef __UNIX_LIKE__
256 mode_t umaskOld;
257 if ( addr->Type() == wxSockAddress::UNIX )
258 {
259 // ensure that the file doesn't exist as otherwise calling socket() would
260 // fail
401eb3de 261 int rc = remove(serverName.fn_str());
0dbfd66d
VZ
262 if ( rc < 0 && errno != ENOENT )
263 {
264 delete addr;
265
d775fa82 266 return false;
0dbfd66d
VZ
267 }
268
269 // also set the umask to prevent the others from reading our file
270 umaskOld = umask(077);
271 }
272 else
273 {
274 // unused anyhow but shut down the compiler warnings
275 umaskOld = 0;
276 }
277#endif // __UNIX_LIKE__
f4ada568 278
f6bcfd97 279 // Create a socket listening on the specified port
0dbfd66d
VZ
280 m_server = new wxSocketServer(*addr, SCKIPC_FLAGS);
281
282#ifdef __UNIX_LIKE__
283 if ( addr->Type() == wxSockAddress::UNIX )
284 {
285 // restore the umask
286 umask(umaskOld);
287
288 // save the file name to remove it later
289 m_filename = serverName;
290 }
291#endif // __UNIX_LIKE__
292
293 delete addr;
f6bcfd97
BP
294
295 if (!m_server->Ok())
296 {
297 m_server->Destroy();
298 m_server = NULL;
299
d775fa82 300 return false;
f6bcfd97
BP
301 }
302
303 m_server->SetEventHandler(*gs_handler, _SERVER_ONREQUEST_ID);
304 m_server->SetClientData(this);
305 m_server->SetNotify(wxSOCKET_CONNECTION_FLAG);
d775fa82 306 m_server->Notify(true);
f4ada568 307
d775fa82 308 return true;
f4ada568
GL
309}
310
6e31e940 311wxTCPServer::~wxTCPServer()
f4ada568 312{
0dbfd66d
VZ
313 if (m_server)
314 {
315 m_server->SetClientData(NULL);
316 m_server->Destroy();
317 }
318
319#ifdef __UNIX_LIKE__
320 if ( !m_filename.empty() )
321 {
401eb3de 322 if ( remove(m_filename.fn_str()) != 0 )
0dbfd66d
VZ
323 {
324 wxLogDebug(_T("Stale AF_UNIX file '%s' left."), m_filename.c_str());
325 }
326 }
327#endif // __UNIX_LIKE__
f4ada568
GL
328}
329
e22036dc 330wxConnectionBase *wxTCPServer::OnAcceptConnection( const wxString& WXUNUSED(topic) )
f4ada568
GL
331{
332 return new wxTCPConnection();
333}
334
cdc59bb6 335// --------------------------------------------------------------------------
f4ada568 336// wxTCPConnection
cdc59bb6 337// --------------------------------------------------------------------------
f4ada568 338
cdc59bb6 339wxTCPConnection::wxTCPConnection () : wxConnectionBase()
f4ada568 340{
cdc59bb6
GRG
341 m_sock = NULL;
342 m_sockstrm = NULL;
343 m_codeci = NULL;
344 m_codeco = NULL;
f4ada568
GL
345}
346
b814b812
JS
347wxTCPConnection::wxTCPConnection(wxChar *buffer, int size)
348 : wxConnectionBase(buffer, size)
7921cf2b 349{
b814b812
JS
350 m_sock = NULL;
351 m_sockstrm = NULL;
352 m_codeci = NULL;
353 m_codeco = NULL;
7921cf2b
JS
354}
355
6e31e940 356wxTCPConnection::~wxTCPConnection ()
f4ada568 357{
b814b812 358 Disconnect();
3adb47a9 359
e5b502f3
GRG
360 if (m_sock)
361 {
362 m_sock->SetClientData(NULL);
363 m_sock->Destroy();
364 }
8913c40c
RR
365
366 /* Delete after destroy */
367 wxDELETE(m_codeci);
368 wxDELETE(m_codeco);
369 wxDELETE(m_sockstrm);
f4ada568
GL
370}
371
cb43b372 372void wxTCPConnection::Compress(bool WXUNUSED(on))
f4ada568
GL
373{
374 // Use wxLZWStream
375}
376
377// Calls that CLIENT can make.
6e31e940 378bool wxTCPConnection::Disconnect ()
f4ada568 379{
b814b812 380 if ( !GetConnected() )
d775fa82 381 return true;
f4ada568 382 // Send the the disconnect message to the peer.
75ed1d15 383 m_codeco->Write8(IPC_DISCONNECT);
82c91ef5
VZ
384
385 if ( m_sock )
386 {
387 m_sock->Notify(false);
388 m_sock->Close();
389 }
390
d775fa82 391 SetConnected(false);
f4ada568 392
d775fa82 393 return true;
f4ada568
GL
394}
395
0834112f 396bool wxTCPConnection::Execute(const wxChar *data, int size, wxIPCFormat format)
f4ada568
GL
397{
398 if (!m_sock->IsConnected())
d775fa82 399 return false;
f4ada568
GL
400
401 // Prepare EXECUTE message
75ed1d15
GL
402 m_codeco->Write8(IPC_EXECUTE);
403 m_codeco->Write8(format);
0834112f 404
f4ada568 405 if (size < 0)
9d860992 406 size = (wxStrlen(data) + 1) * sizeof(wxChar); // includes final NUL
0834112f
GRG
407
408 m_codeco->Write32(size);
409 m_sockstrm->Write(data, size);
f4ada568 410
d775fa82 411 return true;
f4ada568
GL
412}
413
d38e8d5f 414wxChar *wxTCPConnection::Request (const wxString& item, int *size, wxIPCFormat format)
f4ada568
GL
415{
416 if (!m_sock->IsConnected())
417 return NULL;
418
75ed1d15
GL
419 m_codeco->Write8(IPC_REQUEST);
420 m_codeco->WriteString(item);
421 m_codeco->Write8(format);
f4ada568
GL
422
423 // If Unpack doesn't initialize it.
424 int ret;
425
75ed1d15 426 ret = m_codeci->Read8();
f4ada568
GL
427 if (ret == IPC_FAIL)
428 return NULL;
0834112f
GRG
429 else
430 {
f4ada568 431 size_t s;
f4ada568 432
75ed1d15 433 s = m_codeci->Read32();
8913c40c 434
b814b812
JS
435 wxChar *data = GetBufferAtLeast( s );
436 wxASSERT_MSG(data != NULL,
437 _T("Buffer too small in wxTCPConnection::Request") );
fae05df5 438 m_sockstrm->Read(data, s);
f4ada568
GL
439
440 if (size)
441 *size = s;
442 return data;
443 }
444}
445
783b6cfd 446bool wxTCPConnection::Poke (const wxString& item, wxChar *data, int size, wxIPCFormat format)
f4ada568
GL
447{
448 if (!m_sock->IsConnected())
d775fa82 449 return false;
f4ada568 450
75ed1d15
GL
451 m_codeco->Write8(IPC_POKE);
452 m_codeco->WriteString(item);
453 m_codeco->Write8(format);
0834112f 454
f4ada568 455 if (size < 0)
9d860992 456 size = (wxStrlen(data) + 1) * sizeof(wxChar); // includes final NUL
0834112f
GRG
457
458 m_codeco->Write32(size);
459 m_sockstrm->Write(data, size);
f4ada568 460
d775fa82 461 return true;
f4ada568
GL
462}
463
464bool wxTCPConnection::StartAdvise (const wxString& item)
465{
466 int ret;
467
468 if (!m_sock->IsConnected())
d775fa82 469 return false;
f4ada568 470
75ed1d15
GL
471 m_codeco->Write8(IPC_ADVISE_START);
472 m_codeco->WriteString(item);
f4ada568 473
75ed1d15 474 ret = m_codeci->Read8();
f4ada568
GL
475
476 if (ret != IPC_FAIL)
d775fa82 477 return true;
f4ada568 478 else
d775fa82 479 return false;
f4ada568
GL
480}
481
482bool wxTCPConnection::StopAdvise (const wxString& item)
483{
484 int msg;
485
486 if (!m_sock->IsConnected())
d775fa82 487 return false;
f4ada568 488
75ed1d15
GL
489 m_codeco->Write8(IPC_ADVISE_STOP);
490 m_codeco->WriteString(item);
f4ada568 491
75ed1d15 492 msg = m_codeci->Read8();
f4ada568
GL
493
494 if (msg != IPC_FAIL)
d775fa82 495 return true;
f4ada568 496 else
d775fa82 497 return false;
f4ada568
GL
498}
499
500// Calls that SERVER can make
501bool wxTCPConnection::Advise (const wxString& item,
783b6cfd 502 wxChar *data, int size, wxIPCFormat format)
f4ada568
GL
503{
504 if (!m_sock->IsConnected())
d775fa82 505 return false;
f4ada568 506
75ed1d15
GL
507 m_codeco->Write8(IPC_ADVISE);
508 m_codeco->WriteString(item);
509 m_codeco->Write8(format);
0834112f 510
f4ada568 511 if (size < 0)
9d860992 512 size = (wxStrlen(data) + 1) * sizeof(wxChar); // includes final NUL
0834112f
GRG
513
514 m_codeco->Write32(size);
515 m_sockstrm->Write(data, size);
f4ada568 516
d775fa82 517 return true;
f4ada568
GL
518}
519
cdc59bb6
GRG
520// --------------------------------------------------------------------------
521// wxTCPEventHandler (private class)
522// --------------------------------------------------------------------------
523
524BEGIN_EVENT_TABLE(wxTCPEventHandler, wxEvtHandler)
525 EVT_SOCKET(_CLIENT_ONREQUEST_ID, wxTCPEventHandler::Client_OnRequest)
526 EVT_SOCKET(_SERVER_ONREQUEST_ID, wxTCPEventHandler::Server_OnRequest)
527END_EVENT_TABLE()
528
529void wxTCPEventHandler::Client_OnRequest(wxSocketEvent &event)
f4ada568 530{
cdc59bb6 531 wxSocketBase *sock = event.GetSocket();
8913c40c
RR
532 if (!sock) { /* No socket, no glory */
533 return ;
534 }
cdc59bb6 535 wxSocketNotify evt = event.GetSocketEvent();
1f0500b3 536 wxTCPConnection *connection = (wxTCPConnection *)(sock->GetClientData());
cdc59bb6 537
e5b502f3
GRG
538 // This socket is being deleted; skip this event
539 if (!connection)
540 return;
541
75ed1d15 542 wxDataInputStream *codeci;
26a25f95 543 wxDataOutputStream *codeco;
fae05df5 544 wxSocketStream *sockstrm;
f4ada568
GL
545 wxString topic_name = connection->m_topic;
546 wxString item;
547
e5b502f3 548 // We lost the connection: destroy everything
0834112f
GRG
549 if (evt == wxSOCKET_LOST)
550 {
d775fa82 551 sock->Notify(false);
cdc59bb6 552 sock->Close();
f4ada568
GL
553 connection->OnDisconnect();
554 return;
555 }
556
557 // Receive message number.
75ed1d15
GL
558 codeci = connection->m_codeci;
559 codeco = connection->m_codeco;
fae05df5 560 sockstrm = connection->m_sockstrm;
999836aa 561 int msg = codeci->Read8();
f4ada568 562
0834112f
GRG
563 switch (msg)
564 {
565 case IPC_EXECUTE:
566 {
d38e8d5f 567 wxChar *data;
26a25f95 568 size_t size;
0d2a2b60 569 wxIPCFormat format;
26a25f95 570
0d2a2b60 571 format = (wxIPCFormat)codeci->Read8();
75ed1d15 572 size = codeci->Read32();
8913c40c 573
b814b812
JS
574 data = connection->GetBufferAtLeast( size );
575 wxASSERT_MSG(data != NULL,
576 _T("Buffer too small in wxTCPEventHandler::Client_OnRequest") );
fae05df5 577 sockstrm->Read(data, size);
f4ada568 578
e0fbcda6 579 connection->OnExecute (topic_name, data, size, format);
f4ada568 580
f4ada568
GL
581 break;
582 }
0834112f
GRG
583 case IPC_ADVISE:
584 {
d38e8d5f 585 wxChar *data;
f4ada568 586 size_t size;
0d2a2b60 587 wxIPCFormat format;
f4ada568 588
75ed1d15 589 item = codeci->ReadString();
0d2a2b60 590 format = (wxIPCFormat)codeci->Read8();
75ed1d15 591 size = codeci->Read32();
b814b812
JS
592 data = connection->GetBufferAtLeast( size );
593 wxASSERT_MSG(data != NULL,
594 _T("Buffer too small in wxTCPEventHandler::Client_OnRequest") );
fae05df5 595 sockstrm->Read(data, size);
26a25f95 596
e0fbcda6 597 connection->OnAdvise (topic_name, item, data, size, format);
f4ada568 598
f4ada568
GL
599 break;
600 }
0834112f
GRG
601 case IPC_ADVISE_START:
602 {
75ed1d15 603 item = codeci->ReadString();
f4ada568
GL
604
605 bool ok = connection->OnStartAdvise (topic_name, item);
606 if (ok)
75ed1d15 607 codeco->Write8(IPC_ADVISE_START);
f4ada568 608 else
75ed1d15 609 codeco->Write8(IPC_FAIL);
f4ada568
GL
610
611 break;
612 }
0834112f
GRG
613 case IPC_ADVISE_STOP:
614 {
75ed1d15 615 item = codeci->ReadString();
f4ada568
GL
616
617 bool ok = connection->OnStopAdvise (topic_name, item);
618 if (ok)
75ed1d15 619 codeco->Write8(IPC_ADVISE_STOP);
f4ada568 620 else
75ed1d15 621 codeco->Write8(IPC_FAIL);
f4ada568
GL
622
623 break;
624 }
0834112f
GRG
625 case IPC_POKE:
626 {
0d2a2b60 627 wxIPCFormat format;
f4ada568 628 size_t size;
783b6cfd 629 wxChar *data;
f4ada568 630
75ed1d15 631 item = codeci->ReadString();
0d2a2b60 632 format = (wxIPCFormat)codeci->Read8();
75ed1d15 633 size = codeci->Read32();
b814b812
JS
634 data = connection->GetBufferAtLeast( size );
635 wxASSERT_MSG(data != NULL,
636 _T("Buffer too small in wxTCPEventHandler::Client_OnRequest") );
fae05df5 637 sockstrm->Read(data, size);
26a25f95 638
f4ada568
GL
639 connection->OnPoke (topic_name, item, data, size, format);
640
f4ada568
GL
641 break;
642 }
0834112f
GRG
643 case IPC_REQUEST:
644 {
0d2a2b60 645 wxIPCFormat format;
f4ada568 646
75ed1d15 647 item = codeci->ReadString();
0d2a2b60 648 format = (wxIPCFormat)codeci->Read8();
f4ada568
GL
649
650 int user_size = -1;
d38e8d5f 651 wxChar *user_data = connection->OnRequest (topic_name, item, &user_size, format);
f4ada568 652
0834112f
GRG
653 if (user_data)
654 {
75ed1d15 655 codeco->Write8(IPC_REQUEST_REPLY);
0834112f
GRG
656
657 if (user_size == -1)
9d860992 658 user_size = (wxStrlen(user_data) + 1) * sizeof(wxChar); // includes final NUL
0834112f
GRG
659
660 codeco->Write32(user_size);
661 sockstrm->Write(user_data, user_size);
662 }
663 else
75ed1d15 664 codeco->Write8(IPC_FAIL);
f4ada568
GL
665
666 break;
667 }
0834112f
GRG
668 case IPC_DISCONNECT:
669 {
d775fa82 670 sock->Notify(false);
cdc59bb6 671 sock->Close();
d775fa82 672 connection->SetConnected(false);
f4ada568
GL
673 connection->OnDisconnect();
674 break;
675 }
676 default:
75ed1d15 677 codeco->Write8(IPC_FAIL);
f4ada568
GL
678 break;
679 }
680}
681
cdc59bb6 682void wxTCPEventHandler::Server_OnRequest(wxSocketEvent &event)
f4ada568 683{
cdc59bb6 684 wxSocketServer *server = (wxSocketServer *) event.GetSocket();
8913c40c
RR
685 if (!server) { /* No server, Then exit */
686 return ;
687 }
f6bcfd97 688 wxTCPServer *ipcserv = (wxTCPServer *) server->GetClientData();
f4ada568 689
e5b502f3
GRG
690 // This socket is being deleted; skip this event
691 if (!ipcserv)
692 return;
693
cdc59bb6 694 if (event.GetSocketEvent() != wxSOCKET_CONNECTION)
f4ada568
GL
695 return;
696
3adb47a9 697 // Accept the connection, getting a new socket
cdc59bb6 698 wxSocketBase *sock = server->Accept();
8913c40c
RR
699 if (!sock) { /* No socket, no glory */
700 return ;
701 }
0834112f 702 if (!sock->Ok())
3adb47a9
GRG
703 {
704 sock->Destroy();
0834112f 705 return;
3adb47a9 706 }
f4ada568 707
cdc59bb6
GRG
708 wxSocketStream *stream = new wxSocketStream(*sock);
709 wxDataInputStream *codeci = new wxDataInputStream(*stream);
710 wxDataOutputStream *codeco = new wxDataOutputStream(*stream);
f4ada568 711
f4ada568 712 int msg;
75ed1d15 713 msg = codeci->Read8();
f4ada568 714
0834112f
GRG
715 if (msg == IPC_CONNECT)
716 {
f4ada568 717 wxString topic_name;
75ed1d15 718 topic_name = codeci->ReadString();
f4ada568 719
f4ada568
GL
720 wxTCPConnection *new_connection =
721 (wxTCPConnection *)ipcserv->OnAcceptConnection (topic_name);
3adb47a9 722
0834112f
GRG
723 if (new_connection)
724 {
3adb47a9 725 if (new_connection->IsKindOf(CLASSINFO(wxTCPConnection)))
0834112f 726 {
3adb47a9
GRG
727 // Acknowledge success
728 codeco->Write8(IPC_CONNECT);
729 new_connection->m_topic = topic_name;
26a25f95 730 new_connection->m_sock = sock;
3adb47a9
GRG
731 new_connection->m_sockstrm = stream;
732 new_connection->m_codeci = codeci;
733 new_connection->m_codeco = codeco;
cdc59bb6
GRG
734 sock->SetEventHandler(*gs_handler, _CLIENT_ONREQUEST_ID);
735 sock->SetClientData(new_connection);
3adb47a9 736 sock->SetNotify(wxSOCKET_INPUT_FLAG | wxSOCKET_LOST_FLAG);
d775fa82 737 sock->Notify(true);
f4ada568
GL
738 return;
739 }
3adb47a9
GRG
740 else
741 {
742 delete new_connection;
743 // and fall through to delete everything else
744 }
f4ada568
GL
745 }
746 }
3adb47a9
GRG
747
748 // Something went wrong, send failure message and delete everything
749 codeco->Write8(IPC_FAIL);
750
751 delete codeco;
752 delete codeci;
753 delete stream;
754 sock->Destroy();
f4ada568 755}
35a4dab7 756
cdc59bb6
GRG
757// --------------------------------------------------------------------------
758// wxTCPEventHandlerModule (private class)
759// --------------------------------------------------------------------------
760
ed4c6c69 761class wxTCPEventHandlerModule: public wxModule
cdc59bb6
GRG
762{
763 DECLARE_DYNAMIC_CLASS(wxTCPEventHandlerModule)
764
765public:
d775fa82 766 bool OnInit() { gs_handler = new wxTCPEventHandler(); return true; }
cdc59bb6
GRG
767 void OnExit() { wxDELETE(gs_handler); }
768};
769
770IMPLEMENT_DYNAMIC_CLASS(wxTCPEventHandlerModule, wxModule)
771
772
35a4dab7 773#endif
d5da0ce7 774 // wxUSE_SOCKETS && wxUSE_IPC && wxUSE_STREAMS