f010ad4812
By Michael Fielding As discussed on wx-dev. some fixes and improvements for Interprocess Communication (IPC), using DDE and TCP. 1. DDE buffers were using a global buffer 2. TCP buffers were allocated each time needed, and Request would have caused memory leaks had it been used. Fixed these both by using a self-resizing buffer in wxConnectionBase. Changed samples and docs to reflect the improved (but backward compatible) internal buffer management. wxConnectionBase could (in future) use wxMemoryBuffer. 3. IPC sample had trouble closing, causing crash, when closing server using window X button. Because it was (effectively) trying to delete a window in OnExit, when that window was already destroyed. Fixed by making IPCDialog and MyConnection remember if they'd destroyed each other. It's not elegant, but either the connection or the window could be deleted first. 4. Docs for wxDDE... and wxTCP... duplicated eachother, supposed to have same API. Some parts unclear. Patch removes dde and tcp-specific files (including from tipc.tex and classes.tex), and explains how ipc.h selects for you which one to use based on platform. Some other misc clarifications. 6. Client sample was suffering apparent memory leak because of not deleting connection object, and had a hack in there to do that. In fact this was due to the derived OnDisconnect not deleting itself, as it does in base class. Mentioned need to do it in docs, fixed sample so that it does. git-svn-id: https://svn.wxwidgets.org/svn/wx/wxWidgets/trunk@16907 c3d73ce0-8a6f-49c7-b76d-6d57e0e08775
164 lines
5.5 KiB
C++
164 lines
5.5 KiB
C++
/////////////////////////////////////////////////////////////////////////////
|
|
// Name: ipcbase.h
|
|
// Purpose: Base classes for IPC
|
|
// Author: Julian Smart
|
|
// Modified by:
|
|
// Created: 4/1/98
|
|
// RCS-ID: $Id$
|
|
// Copyright: (c) Julian Smart and Markus Holzem
|
|
// Licence: wxWindows license
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
|
|
#ifndef _WX_IPCBASEH__
|
|
#define _WX_IPCBASEH__
|
|
|
|
#if defined(__GNUG__) && !defined(__APPLE__)
|
|
#pragma interface "ipcbase.h"
|
|
#endif
|
|
|
|
#include "wx/defs.h"
|
|
#include "wx/object.h"
|
|
#include "wx/string.h"
|
|
|
|
enum wxIPCFormat
|
|
{
|
|
wxIPC_INVALID = 0,
|
|
wxIPC_TEXT = 1, /* CF_TEXT */
|
|
wxIPC_BITMAP = 2, /* CF_BITMAP */
|
|
wxIPC_METAFILE = 3, /* CF_METAFILEPICT */
|
|
wxIPC_SYLK = 4,
|
|
wxIPC_DIF = 5,
|
|
wxIPC_TIFF = 6,
|
|
wxIPC_OEMTEXT = 7, /* CF_OEMTEXT */
|
|
wxIPC_DIB = 8, /* CF_DIB */
|
|
wxIPC_PALETTE = 9,
|
|
wxIPC_PENDATA = 10,
|
|
wxIPC_RIFF = 11,
|
|
wxIPC_WAVE = 12,
|
|
wxIPC_UNICODETEXT = 13,
|
|
wxIPC_ENHMETAFILE = 14,
|
|
wxIPC_FILENAME = 15, /* CF_HDROP */
|
|
wxIPC_LOCALE = 16,
|
|
wxIPC_PRIVATE = 20
|
|
};
|
|
|
|
class WXDLLEXPORT wxServerBase;
|
|
class WXDLLEXPORT wxClientBase;
|
|
|
|
class WXDLLEXPORT wxConnectionBase: public wxObject
|
|
{
|
|
DECLARE_CLASS(wxConnectionBase)
|
|
|
|
public:
|
|
wxConnectionBase(wxChar *buffer, int size); // use external buffer
|
|
wxConnectionBase(); // use internal, adaptive buffer
|
|
wxConnectionBase(wxConnectionBase& copy);
|
|
~wxConnectionBase(void);
|
|
|
|
void SetConnected( bool c ) { m_connected = c; }
|
|
bool GetConnected() { return m_connected; }
|
|
|
|
// Calls that CLIENT can make
|
|
virtual bool Execute(const wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT ) = 0;
|
|
virtual bool Execute(const wxString& str) { return Execute(str, -1, wxIPC_TEXT); }
|
|
virtual char *Request(const wxString& item, int *size = (int *) NULL, wxIPCFormat format = wxIPC_TEXT) = 0;
|
|
virtual bool Poke(const wxString& item, wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT) = 0;
|
|
virtual bool StartAdvise(const wxString& item) = 0;
|
|
virtual bool StopAdvise(const wxString& item) = 0;
|
|
|
|
// Calls that SERVER can make
|
|
virtual bool Advise(const wxString& item, wxChar *data, int size = -1, wxIPCFormat format = wxIPC_TEXT) = 0;
|
|
|
|
// Calls that both can make
|
|
virtual bool Disconnect(void) = 0;
|
|
|
|
// Callbacks to SERVER - override at will
|
|
virtual bool OnExecute ( const wxString& WXUNUSED(topic),
|
|
char *WXUNUSED(data),
|
|
int WXUNUSED(size),
|
|
wxIPCFormat WXUNUSED(format) )
|
|
{ return FALSE; };
|
|
|
|
virtual char *OnRequest ( const wxString& WXUNUSED(topic),
|
|
const wxString& WXUNUSED(item),
|
|
int *WXUNUSED(size),
|
|
wxIPCFormat WXUNUSED(format) )
|
|
{ return (char *) NULL; };
|
|
|
|
virtual bool OnPoke ( const wxString& WXUNUSED(topic),
|
|
const wxString& WXUNUSED(item),
|
|
wxChar *WXUNUSED(data),
|
|
int WXUNUSED(size),
|
|
wxIPCFormat WXUNUSED(format) )
|
|
{ return FALSE; };
|
|
|
|
virtual bool OnStartAdvise ( const wxString& WXUNUSED(topic),
|
|
const wxString& WXUNUSED(item) )
|
|
{ return FALSE; };
|
|
|
|
virtual bool OnStopAdvise ( const wxString& WXUNUSED(topic),
|
|
const wxString& WXUNUSED(item) )
|
|
{ return FALSE; };
|
|
|
|
// Callbacks to CLIENT - override at will
|
|
virtual bool OnAdvise ( const wxString& WXUNUSED(topic),
|
|
const wxString& WXUNUSED(item),
|
|
char *WXUNUSED(data),
|
|
int WXUNUSED(size),
|
|
wxIPCFormat WXUNUSED(format) )
|
|
{ return FALSE; };
|
|
|
|
// Callbacks to BOTH - override at will
|
|
// Default behaviour is to delete connection and return TRUE
|
|
virtual bool OnDisconnect(void) = 0;
|
|
|
|
// return a buffer at least this size, reallocating buffer if needed
|
|
// returns NULL if using an inadequate user buffer - it can't be resized
|
|
wxChar * GetBufferAtLeast( size_t bytes );
|
|
|
|
protected:
|
|
bool m_connected;
|
|
private:
|
|
wxChar * m_buffer;
|
|
size_t m_buffersize;
|
|
bool m_deletebufferwhendone;
|
|
};
|
|
|
|
|
|
class WXDLLEXPORT wxServerBase: public wxObject
|
|
{
|
|
DECLARE_CLASS(wxServerBase)
|
|
|
|
public:
|
|
inline wxServerBase(void) {}
|
|
inline ~wxServerBase(void) {};
|
|
|
|
// Returns FALSE on error (e.g. port number is already in use)
|
|
virtual bool Create(const wxString& serverName) = 0;
|
|
|
|
// Callbacks to SERVER - override at will
|
|
virtual wxConnectionBase *OnAcceptConnection(const wxString& topic) = 0;
|
|
};
|
|
|
|
class WXDLLEXPORT wxClientBase: public wxObject
|
|
{
|
|
DECLARE_CLASS(wxClientBase)
|
|
|
|
public:
|
|
inline wxClientBase(void) {};
|
|
inline ~wxClientBase(void) {};
|
|
|
|
virtual bool ValidHost(const wxString& host) = 0;
|
|
|
|
// Call this to make a connection. Returns NULL if cannot.
|
|
virtual wxConnectionBase *MakeConnection(const wxString& host,
|
|
const wxString& server,
|
|
const wxString& topic) = 0;
|
|
|
|
// Callbacks to CLIENT - override at will
|
|
virtual wxConnectionBase *OnMakeConnection(void) = 0;
|
|
};
|
|
|
|
#endif
|
|
// _WX_IPCBASEH__
|