ServerClient.cpp

Go to the documentation of this file.

/*******************************************************************/
extern void ShowFrame();
 
#include <wx/snglinst.h>
#include <wx/ipc.h>
 
// the default service name
#define IPC_SERVICE "4655"
 
// the hostname
#define IPC_HOST "localhost"
 
// the IPC topic
#define IPC_TOPIC "HATCHKEEPER_80"
 
class HatchConnection : public wxConnection
{
public:
    virtual bool OnExecute(const wxString& topic, const void *data, size_t size, wxIPCFormat format) wxOVERRIDE;
    virtual bool DoExecute(const void *data, size_t size, wxIPCFormat format) wxOVERRIDE;
    //virtual bool OnDisconnect() wxOVERRIDE;
};
 
bool HatchConnection::OnExecute(const wxString& topic,const void *data,size_t size,wxIPCFormat format)
{
    //Log("OnExecute", topic, "", data, size, format);
    ShowFrame();
    return true;
}
 
bool HatchConnection::DoExecute(const void *data, size_t size, wxIPCFormat format)
{
    //Log(wxT("Execute"), wxEmptyString, wxEmptyString, data, size, format);
    bool a = wxConnection::DoExecute(data, size, format);
    if (!a) {
        wxLogMessage(wxT("Execute failed!"));
    }
    return a;
}
 
class HatchServer : public wxServer
{
public:
    HatchServer();
    
    void Disconnect();
    bool IsConnected() { return h_connection != NULL; }
    HatchConnection *GetConnection() { return h_connection; }
 
    virtual wxConnectionBase *OnAcceptConnection(const wxString& topic);
 
protected:
    HatchConnection *h_connection;
};
 
HatchServer::HatchServer() : wxServer() {h_connection = NULL;}
 
void HatchServer::Disconnect()
{
    if ( h_connection )
        wxDELETE(h_connection);
}
 
wxConnectionBase *HatchServer::OnAcceptConnection(const wxString& topic)
{   
    //Check For Valid Connection
    if ( topic == IPC_TOPIC ) {
        h_connection = new HatchConnection();
        //wxLogMessage("Connection accepted");
        return h_connection;
    }
    
    //Else
    wxLogMessage("Unknown topic, connection refused");
    return NULL;
}
 
 
class HatchClient: public wxClient
{
public:
    HatchClient();
    bool Connect(const wxString& sHost, const wxString& sService, const wxString& sTopic);
    void Disconnect();
    wxConnectionBase *OnMakeConnection() wxOVERRIDE;
    bool IsConnected() { return h_connection != NULL; };
    HatchConnection *GetConnection() { return h_connection; };
 
protected:
    HatchConnection     *h_connection;
};
 
HatchClient::HatchClient() : wxClient(){h_connection = NULL;}
 
bool HatchClient::Connect(const wxString& sHost, const wxString& sService, const wxString& sTopic)
{
    // suppress the log messages from MakeConnection()
    wxLogNull nolog;
 
    h_connection = (HatchConnection *)MakeConnection(sHost, sService, sTopic);
    return h_connection != NULL;
}
 
wxConnectionBase *HatchClient::OnMakeConnection()
{
    return new HatchConnection;
}
 
void HatchClient::Disconnect()
{
    if (h_connection) {
        h_connection->Disconnect();
        wxDELETE(h_connection);
    }
}
 
//Declare global Server and Client
HatchServer *h_server; 
HatchClient *h_client;
wxSingleInstanceChecker *h_checker;