1 /////////////////////////////////////////////////////////////////////////////
3 // Purpose: Interprocess communication implementation (wxSocket version)
4 // Author: Julian Smart
5 // Modified by: Guilhem Lavaux (big rewrite) May 1997, 1998
6 // Guillermo Rodriguez (updated for wxSocket v2) Jan 2000
7 // (callbacks deprecated) Mar 2000
10 // Copyright: (c) Julian Smart 1993
11 // (c) Guilhem Lavaux 1997, 1998
12 // (c) 2000 Guillermo Rodriguez <guille@iies.es>
13 // Licence: wxWindows licence
14 /////////////////////////////////////////////////////////////////////////////
21 #if wxUSE_SOCKETS && wxUSE_IPC
23 #include "wx/ipcbase.h"
24 #include "wx/socket.h"
25 #include "wx/sckstrm.h"
26 #include "wx/datstrm.h"
29 * Mini-DDE implementation
31 Most transactions involve a topic name and an item name (choose these
32 as befits your application).
36 - ask the server to execute commands (data) associated with a topic
37 - request data from server by topic and item
38 - poke data into the server
39 - ask the server to start an advice loop on topic/item
40 - ask the server to stop an advice loop
44 - respond to execute, request, poke and advice start/stop
45 - send advise data to client
47 Note that this limits the server in the ways it can send data to the
48 client, i.e. it can't send unsolicited information.
52 class WXDLLIMPEXP_FWD_NET wxTCPServer
;
53 class WXDLLIMPEXP_FWD_NET wxTCPClient
;
55 class WXDLLIMPEXP_NET wxTCPConnection
: public wxConnectionBase
58 wxTCPConnection() { Init(); }
59 wxTCPConnection(void *buffer
, size_t size
)
60 : wxConnectionBase(buffer
, size
)
65 virtual ~wxTCPConnection();
67 // implement base class pure virtual methods
68 virtual const void *Request(const wxString
& item
,
70 wxIPCFormat format
= wxIPC_TEXT
);
71 virtual bool StartAdvise(const wxString
& item
);
72 virtual bool StopAdvise(const wxString
& item
);
73 virtual bool Disconnect(void);
75 // Will be used in the future to enable the compression but does nothing
77 void Compress(bool on
);
81 virtual bool DoExecute(const void *data
, size_t size
, wxIPCFormat format
);
82 virtual bool DoPoke(const wxString
& item
, const void *data
, size_t size
,
84 virtual bool DoAdvise(const wxString
& item
, const void *data
, size_t size
,
89 wxSocketStream
*m_sockstrm
;
90 wxDataInputStream
*m_codeci
;
91 wxDataOutputStream
*m_codeco
;
95 // common part of both ctors
98 friend class wxTCPServer
;
99 friend class wxTCPClient
;
100 friend class wxTCPEventHandler
;
102 DECLARE_NO_COPY_CLASS(wxTCPConnection
)
103 DECLARE_DYNAMIC_CLASS(wxTCPConnection
)
106 class WXDLLIMPEXP_NET wxTCPServer
: public wxServerBase
110 virtual ~wxTCPServer();
112 // Returns false on error (e.g. port number is already in use)
113 virtual bool Create(const wxString
& serverName
);
115 virtual wxConnectionBase
*OnAcceptConnection(const wxString
& topic
);
118 wxSocketServer
*m_server
;
121 // the name of the file associated to the Unix domain socket, may be empty
123 #endif // __UNIX_LIKE__
125 DECLARE_NO_COPY_CLASS(wxTCPServer
)
126 DECLARE_DYNAMIC_CLASS(wxTCPServer
)
129 class WXDLLIMPEXP_NET wxTCPClient
: public wxClientBase
134 virtual bool ValidHost(const wxString
& host
);
136 // Call this to make a connection. Returns NULL if cannot.
137 virtual wxConnectionBase
*MakeConnection(const wxString
& host
,
138 const wxString
& server
,
139 const wxString
& topic
);
141 // Callbacks to CLIENT - override at will
142 virtual wxConnectionBase
*OnMakeConnection();
145 DECLARE_DYNAMIC_CLASS(wxTCPClient
)
148 #endif // wxUSE_SOCKETS && wxUSE_IPC
150 #endif // _WX_SCKIPC_H