// main frame
bool MyApp::OnInit()
{
+ if ( !wxApp::OnInit() )
+ return false;
+
// Create the main frame window
m_frame = new MyFrame(NULL, _T("Client"));
m_frame->Show(true);
SetBackgroundColour(wxSystemSettings::GetColour(wxSYS_COLOUR_BTNFACE));
// add the controls to the frame
- wxString strs4[] =
+ wxString strs4[] =
{
IPC_SERVICE, _T("...")
};
- wxString strs5[] =
+ wxString strs5[] =
{
IPC_HOST, _T("...")
};
- wxString strs6[] =
+ wxString strs6[] =
{
IPC_TOPIC, _T("...")
};
wxStaticBox *item14 = new wxStaticBox( this, -1, wxT("Client log") );
wxStaticBoxSizer *item13 = new wxStaticBoxSizer( item14, wxVERTICAL );
- wxTextCtrl *item15 = new wxTextCtrl( this, ID_LOG, wxT(""), wxDefaultPosition, wxSize(500,140), wxTE_MULTILINE );
+ wxTextCtrl *item15 = new wxTextCtrl( this, ID_LOG, wxEmptyString, wxDefaultPosition, wxSize(500,140), wxTE_MULTILINE );
item13->Add( item15, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
item0->Add( item13, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
wxLogTextCtrl *logWindow = new wxLogTextCtrl(GetLog());
delete wxLog::SetActiveTarget(logWindow);
wxLogMessage(_T("Click on Connect to connect to the server"));
- Enable();
+ EnableControls();
}
-void MyFrame::Enable()
+void MyFrame::EnableControls()
{
GetStart()->Enable(m_client == NULL);
GetServername()->Enable(m_client == NULL);
GetHostname()->Enable(m_client == NULL);
GetTopic()->Enable(m_client == NULL);
- const bool isConnected = m_client->IsConnected();
+ const bool isConnected = (m_client != NULL && m_client->IsConnected());
GetDisconnect()->Enable(m_client != NULL && isConnected);
GetStartAdvise()->Enable(m_client != NULL && isConnected);
GetStopAdvise()->Enable(m_client != NULL && isConnected);
delete m_client;
m_client = NULL;
}
- Enable();
+ EnableControls();
}
void MyFrame::OnServername( wxCommandEvent& WXUNUSED(event) )
if (GetServername()->GetStringSelection() == _T("..."))
{
wxString s = wxGetTextFromUser(_T("Specify the name of the server"),
- _T("Server Name"), _(""), this);
+ _T("Server Name"), wxEmptyString, this);
if (!s.IsEmpty() && s != IPC_SERVICE)
{
GetServername()->Insert(s, 0);
if (GetHostname()->GetStringSelection() == _T("..."))
{
wxString s = wxGetTextFromUser(_T("Specify the name of the host (ignored under DDE)"),
- _T("Host Name"), _(""), this);
+ _T("Host Name"), wxEmptyString, this);
if (!s.IsEmpty() && s != IPC_HOST)
{
GetHostname()->Insert(s, 0);
if (GetTopic()->GetStringSelection() == _T("..."))
{
wxString s = wxGetTextFromUser(_T("Specify the name of the topic"),
- _T("Topic Name"), _(""), this);
+ _T("Topic Name"), wxEmptyString, this);
if (!s.IsEmpty() && s != IPC_TOPIC)
{
GetTopic()->Insert(s, 0);
void MyFrame::OnDisconnect(wxCommandEvent& WXUNUSED(event))
{
- Disconnect();
+ Disconnect();
}
void MyFrame::Disconnect()
{
- delete m_client;
+ delete m_client;
m_client = NULL;
- Enable();
+ EnableControls();
}
void MyFrame::OnStartAdvise(wxCommandEvent& WXUNUSED(event))
{
- m_client->GetConnection()->StartAdvise(_T("something"));
+ m_client->GetConnection()->StartAdvise(_T("something"));
}
void MyFrame::OnStopAdvise(wxCommandEvent& WXUNUSED(event))
{
- m_client->GetConnection()->StopAdvise(_T("something"));
+ m_client->GetConnection()->StopAdvise(_T("something"));
}
void MyFrame::OnExecute(wxCommandEvent& WXUNUSED(event))
{
wxString s = _T("Date");
- m_client->GetConnection()->Execute((wxChar *)s.c_str());
- m_client->GetConnection()->Execute((wxChar *)s.c_str(), (s.Length() + 1) * sizeof(wxChar));
-#if wxUSE_DDE_FOR_IPC
- wxLogMessage(_T("DDE Execute can only be used to send text strings, not arbitrary data.\nThe type argument will be ignored, text truncated, converted to Unicode and null terminated."));
-#endif
+ m_client->GetConnection()->Execute(s);
+ m_client->GetConnection()->Execute((const char *)s.c_str(), s.length() + 1);
char bytes[3];
- bytes[0] = '1'; bytes[1] = '2'; bytes[2] = '3';
- m_client->GetConnection()->Execute((wxChar *)bytes, 3, wxIPC_PRIVATE);
+ bytes[0] = '1';
+ bytes[1] = '2';
+ bytes[2] = '3';
+ m_client->GetConnection()->Execute(bytes, WXSIZEOF(bytes));
}
}
if (m_client->IsConnected())
{
wxString s = wxDateTime::Now().Format();
- m_client->GetConnection()->Poke(_T("Date"), (wxChar *)s.c_str());
+ m_client->GetConnection()->Poke(_T("Date"), s);
s = wxDateTime::Now().FormatTime() + _T(" ") + wxDateTime::Now().FormatDate();
- m_client->GetConnection()->Poke(_T("Date"), (wxChar *)s.c_str(), (s.Length() + 1) * sizeof(wxChar));
+ m_client->GetConnection()->Poke(_T("Date"), (const char *)s.c_str(), s.length() + 1);
char bytes[3];
bytes[0] = '1'; bytes[1] = '2'; bytes[2] = '3';
- m_client->GetConnection()->Poke(_T("bytes[3]"), (wxChar *)bytes, 3, wxIPC_PRIVATE);
+ m_client->GetConnection()->Poke(_T("bytes[3]"), bytes, 3, wxIPC_PRIVATE);
}
}
{
if (m_client->IsConnected())
{
- int size;
+ size_t size;
m_client->GetConnection()->Request(_T("Date"));
m_client->GetConnection()->Request(_T("Date+len"), &size);
m_client->GetConnection()->Request(_T("bytes[3]"), &size, wxIPC_PRIVATE);
{
// suppress the log messages from MakeConnection()
wxLogNull nolog;
-
+
m_connection = (MyConnection *)MakeConnection(sHost, sService, sTopic);
return m_connection != NULL;
}
m_connection->Disconnect();
delete m_connection;
m_connection = NULL;
- wxGetApp().GetFrame()->Enable();
+ wxGetApp().GetFrame()->EnableControls();
wxLogMessage(_T("Client disconnected from server"));
}
}
// MyConnection
// ----------------------------------------------------------------------------
-void MyConnection::Log(const wxString& command, const wxString& topic,
- const wxString& item, wxChar *data, int size, wxIPCFormat format)
-{
- wxString s;
- if (topic.IsEmpty() && item.IsEmpty())
- s.Printf(_T("%s("), command.c_str());
- else if (topic.IsEmpty())
- s.Printf(_T("%s(item=\"%s\","), command.c_str(), item.c_str());
- else if (item.IsEmpty())
- s.Printf(_T("%s(topic=\"%s\","), command.c_str(), topic.c_str());
- else
- s.Printf(_T("%s(topic=\"%s\",item=\"%s\","), command.c_str(), topic.c_str(), item.c_str());
-
- if (format == wxIPC_TEXT || format == wxIPC_UNICODETEXT)
- wxLogMessage(_T("%s\"%s\",%d)"), s.c_str(), data, size);
- else if (format == wxIPC_PRIVATE)
- {
- if (size == 3)
- {
- char *bytes = (char *)data;
- wxLogMessage(_T("%s'%c%c%c',%d)"), s.c_str(), bytes[0], bytes[1], bytes[2], size);
- }
- else
- wxLogMessage(_T("%s...,%d)"), s.c_str(), size);
- }
- else if (format == wxIPC_INVALID)
- wxLogMessage(_T("%s[invalid data],%d)"), s.c_str(), size);
-}
-
-bool MyConnection::OnAdvise(const wxString& topic, const wxString& item, wxChar *data,
- int size, wxIPCFormat format)
+bool MyConnection::OnAdvise(const wxString& topic, const wxString& item, const void *data,
+ size_t size, wxIPCFormat format)
{
Log(_T("OnAdvise"), topic, item, data, size, format);
return true;
return true;
}
-bool MyConnection::Execute(const wxChar *data, int size, wxIPCFormat format)
+bool MyConnection::DoExecute(const void *data, size_t size, wxIPCFormat format)
{
- Log(_T("Execute"), _T(""), _T(""), (wxChar *)data, size, format);
- bool retval = wxConnection::Execute(data, size, format);
+ Log(_T("Execute"), wxEmptyString, wxEmptyString, data, size, format);
+ bool retval = wxConnection::DoExecute(data, size, format);
if (!retval)
wxLogMessage(_T("Execute failed!"));
return retval;
}
-wxChar *MyConnection::Request(const wxString& item, int *size, wxIPCFormat format)
+const void *MyConnection::Request(const wxString& item, size_t *size, wxIPCFormat format)
{
- wxChar *data = wxConnection::Request(item, size, format);
- Log(_T("Request"), _T(""), item, data, size ? *size : -1, format);
+ const void *data = wxConnection::Request(item, size, format);
+ Log(_T("Request"), wxEmptyString, item, data, size ? *size : wxNO_LEN, format);
return data;
}
-bool MyConnection::Poke(const wxString& item, wxChar *data, int size, wxIPCFormat format)
+bool MyConnection::DoPoke(const wxString& item, const void *data, size_t size, wxIPCFormat format)
{
- Log(_T("Poke"), _T(""), item, data, size, format);
- return wxConnection::Poke(item, data, size, format);
+ Log(_T("Poke"), wxEmptyString, item, data, size, format);
+ return wxConnection::DoPoke(item, data, size, format);
}
-