X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/81ba610721b385d27d8b4ccf7996ba9b32ea26e3..5b99d5d8eae1091046d3fd475c48fa43073e03b3:/samples/ipc/client.cpp diff --git a/samples/ipc/client.cpp b/samples/ipc/client.cpp index c405fce062..b13587b74a 100644 --- a/samples/ipc/client.cpp +++ b/samples/ipc/client.cpp @@ -76,6 +76,9 @@ END_EVENT_TABLE() // 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); @@ -218,7 +221,7 @@ void MyFrame::EnableControls() 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); @@ -261,7 +264,7 @@ void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event)) delete m_client; m_client = NULL; } - Enable(); + EnableControls(); } void MyFrame::OnServername( wxCommandEvent& WXUNUSED(event) ) @@ -315,7 +318,7 @@ void MyFrame::Disconnect() { delete m_client; m_client = NULL; - Enable(); + EnableControls(); } void MyFrame::OnStartAdvise(wxCommandEvent& WXUNUSED(event)) @@ -334,14 +337,13 @@ 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)); } } @@ -350,12 +352,12 @@ void MyFrame::OnPoke(wxCommandEvent& WXUNUSED(event)) 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); } } @@ -363,7 +365,7 @@ void MyFrame::OnRequest(wxCommandEvent& WXUNUSED(event)) { 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); @@ -399,7 +401,7 @@ void MyClient::Disconnect() m_connection->Disconnect(); delete m_connection; m_connection = NULL; - wxGetApp().GetFrame()->Enable(); + wxGetApp().GetFrame()->EnableControls(); wxLogMessage(_T("Client disconnected from server")); } } @@ -413,37 +415,8 @@ MyClient::~MyClient() // 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; @@ -456,24 +429,24 @@ bool MyConnection::OnDisconnect() 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"), wxEmptyString, wxEmptyString, (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"), wxEmptyString, 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"), wxEmptyString, item, data, size, format); - return wxConnection::Poke(item, data, size, format); + return wxConnection::DoPoke(item, data, size, format); }