include/wx/sckipc.h

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        sckipc.h
   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
   8 // Created:     1993
   9 // RCS-ID:      $Id$
  10 // Copyright:   (c) Julian Smart 1993
  11 //              (c) Guilhem Lavaux 1997, 1998
  12 //              (c) 2000 Guillermo Rodriguez <guille@iies.es>
  13 // Licence:     wxWindows license
  14 /////////////////////////////////////////////////////////////////////////////
  15
  16 #ifndef _WX_SCKIPC_H
  17 #define _WX_SCKIPC_H
  18
  19 #ifdef __GNUG__
  20 #pragma interface "sckipc.h"
  21 #endif
  22
  23 #include "wx/defs.h"
  24
  25 #if wxUSE_SOCKETS && wxUSE_IPC
  26
  27 #include "wx/ipcbase.h"
  28 #include "wx/socket.h"
  29 #include "wx/sckstrm.h"
  30 #include "wx/datstrm.h"
  31
  32 /*
  33  * Mini-DDE implementation
  34
  35    Most transactions involve a topic name and an item name (choose these
  36    as befits your application).
  37
  38    A client can:
  39
  40    - ask the server to execute commands (data) associated with a topic
  41    - request data from server by topic and item
  42    - poke data into the server
  43    - ask the server to start an advice loop on topic/item
  44    - ask the server to stop an advice loop
  45
  46    A server can:
  47
  48    - respond to execute, request, poke and advice start/stop
  49    - send advise data to client
  50
  51    Note that this limits the server in the ways it can send data to the
  52    client, i.e. it can't send unsolicited information.
  53  *
  54  */
  55
  56 class WXDLLEXPORT wxTCPServer;
  57 class WXDLLEXPORT wxTCPClient;
  58
  59 class WXDLLEXPORT wxTCPConnection: public wxConnectionBase
  60 {
  61   DECLARE_DYNAMIC_CLASS(wxTCPConnection)
  62 public:
  63   wxTCPConnection(char *buffer, int size);
  64   wxTCPConnection();
  65   virtual ~wxTCPConnection();
  66
  67   // Calls that CLIENT can make
  68   virtual bool Execute(const wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT);
  69   virtual char *Request(const wxString& item, int *size = NULL, wxIPCFormat format = wxIPC_TEXT);
  70   virtual bool Poke(const wxString& item, wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT);
  71   virtual bool StartAdvise(const wxString& item);
  72   virtual bool StopAdvise(const wxString& item);
  73
  74   // Calls that SERVER can make
  75   virtual bool Advise(const wxString& item, wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT);
  76
  77   // Calls that both can make
  78   virtual bool Disconnect(void);
  79
  80   // Default behaviour is to delete connection and return TRUE
  81   virtual bool OnDisconnect(void) { delete this; return TRUE; }
  82
  83   // To enable the compressor
  84   void Compress(bool on);
  85
  86 protected:
  87   wxSocketBase *m_sock;
  88   wxSocketStream *m_sockstrm;
  89   wxDataInputStream *m_codeci;
  90   wxDataOutputStream *m_codeco;
  91   wxString m_topic;
  92
  93   friend class wxTCPServer;
  94   friend class wxTCPClient;
  95   friend class wxTCPEventHandler;
  96
  97 private:
  98   //
  99   // We're hiding an Execute method in ConnectionBase
 100   //
 101   virtual bool Execute(const wxString& str)
 102     { return Execute(str, -1, wxIPC_TEXT); }
 103 };
 104
 105 class wxTCPServer: public wxServerBase
 106 {
 107   DECLARE_DYNAMIC_CLASS(wxTCPServer)
 108
 109 public:
 110   wxTCPConnection *topLevelConnection;
 111
 112   wxTCPServer();
 113   virtual ~wxTCPServer();
 114
 115   // Returns FALSE if can't create server (e.g. port number is already in use)
 116   virtual bool Create(const wxString& server_name);
 117   virtual wxConnectionBase *OnAcceptConnection(const wxString& topic);
 118 };
 119
 120 class wxTCPClient: public wxClientBase
 121 {
 122   DECLARE_DYNAMIC_CLASS(wxTCPClient)
 123
 124 public:
 125   wxTCPClient();
 126   virtual ~wxTCPClient();
 127
 128   virtual bool ValidHost(const wxString& host);
 129   // Call this to make a connection.
 130   // Returns NULL if cannot.
 131   virtual wxConnectionBase *MakeConnection(const wxString& host,
 132                                            const wxString& server,
 133                                            const wxString& topic);
 134
 135   // Tailor this to return own connection.
 136   virtual wxConnectionBase *OnMakeConnection();
 137 };
 138
 139 #endif // wxUSE_SOCKETS && wxUSE_IPC
 140
 141 #endif // _WX_SCKIPC_H