X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/50c549b98d8e61e19f59c61989af293bb58319f8..8a31648287be0ef976f133de2786b137f1e98340:/samples/ipc/server.cpp?ds=sidebyside diff --git a/samples/ipc/server.cpp b/samples/ipc/server.cpp index 691798278f..26b09f6791 100644 --- a/samples/ipc/server.cpp +++ b/samples/ipc/server.cpp @@ -32,8 +32,8 @@ // we're using TCP/IP or real DDE. #include "ipcsetup.h" -#if defined(__WXGTK__) || defined(__WXX11__) || defined(__WXMOTIF__) || defined(__WXMAC__) - #include "mondrian.xpm" +#if !defined(__WXMSW__) && !defined(__WXPM__) + #include "../sample.xpm" #endif #include "server.h" @@ -47,10 +47,10 @@ IMPLEMENT_APP(MyApp) BEGIN_EVENT_TABLE(MyFrame, wxFrame) - EVT_MENU (wxID_EXIT, MyFrame::OnExit) EVT_CLOSE( MyFrame::OnClose ) - EVT_BUTTON( ID_START, MyFrame::OnStart ) - EVT_CHOICE( ID_SERVERNAME, MyFrame::OnServerName ) + + EVT_BUTTON( ID_START, MyFrame::OnStart ) + EVT_CHOICE( ID_SERVERNAME, MyFrame::OnServerName ) EVT_BUTTON( ID_DISCONNECT, MyFrame::OnDisconnect ) EVT_BUTTON( ID_ADVISE, MyFrame::OnAdvise ) END_EVENT_TABLE() @@ -70,17 +70,12 @@ bool MyApp::OnInit() return false; // Create the main frame window - m_frame = new MyFrame(NULL, _T("Server")); + m_frame = new MyFrame(NULL, "Server"); m_frame->Show(true); return true; } -int MyApp::OnExit() -{ - return 0; -} - // ---------------------------------------------------------------------------- // MyFrame // ---------------------------------------------------------------------------- @@ -93,77 +88,69 @@ MyFrame::MyFrame(wxFrame *frame, const wxString& title) CreateStatusBar(); #endif // wxUSE_STATUSBAR - // Give it an icon - SetIcon(wxICON(mondrian)); - - // Make a menubar - wxMenu *file_menu = new wxMenu; - - file_menu->Append(wxID_EXIT, _T("&Quit\tCtrl-Q")); - - wxMenuBar *menu_bar = new wxMenuBar; + SetIcon(wxICON(sample)); - menu_bar->Append(file_menu, _T("&File")); - - // Associate the menu bar with the frame - SetMenuBar(menu_bar); - - // set a dialog background - SetBackgroundColour(wxSystemSettings::GetColour(wxSYS_COLOUR_BTNFACE)); - - // add the controls to the frame - wxBoxSizer *item0 = new wxBoxSizer( wxVERTICAL ); - - wxBoxSizer *item1 = new wxBoxSizer( wxHORIZONTAL ); + m_server = NULL; - wxFlexGridSizer *item2 = new wxFlexGridSizer( 2, 0, 0 ); - item2->AddGrowableCol( 1 ); + wxPanel * const panel = new wxPanel(this); - wxButton *item3 = new wxButton( this, ID_START, wxT("Start Server"), wxDefaultPosition, wxDefaultSize, 0 ); - item2->Add( item3, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + wxBoxSizer * const sizerMain = new wxBoxSizer( wxVERTICAL ); - wxString strs4[] = - { - IPC_SERVICE, _T("...") - }; - wxChoice *item4 = new wxChoice( this, ID_SERVERNAME, wxDefaultPosition, wxSize(100,-1), 2, strs4, 0 ); - item2->Add( item4, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + wxFlexGridSizer * const sizerCmds = new wxFlexGridSizer( 2, 0, 0 ); + sizerCmds->AddGrowableCol( 1 ); - wxButton *item5 = new wxButton( this, ID_DISCONNECT, wxT("Disconnect Client"), wxDefaultPosition, wxDefaultSize, 0 ); - item2->Add( item5, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + wxButton *btn; - item2->Add( 20, 20, 0, wxALIGN_CENTER|wxALL, 5 ); + btn = new wxButton(panel, ID_START, "&Start Server"); + sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); - wxButton *item6 = new wxButton( this, ID_ADVISE, wxT("Advise"), wxDefaultPosition, wxDefaultSize, 0 ); - item2->Add( item6, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + const wxString choices[] = { IPC_SERVICE, "..." }; + wxChoice * const choice = new wxChoice + ( + panel, + ID_SERVERNAME, + wxDefaultPosition, wxSize(100, -1), + WXSIZEOF(choices), choices + ); + sizerCmds->Add(choice, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); - item2->Add( 20, 20, 0, wxALIGN_CENTER|wxALL, 5 ); + btn = new wxButton(panel, ID_DISCONNECT, "&Disconnect Client"); + sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); + sizerCmds->AddSpacer(20); - item1->Add( item2, 1, wxALIGN_CENTER|wxALL, 5 ); + btn = new wxButton( panel, ID_ADVISE, "&Advise"); + sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); + sizerCmds->AddSpacer(20); - item0->Add( item1, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + sizerMain->Add(sizerCmds, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); - wxStaticBox *item8 = new wxStaticBox( this, -1, wxT("Server log") ); - wxStaticBoxSizer *item7 = new wxStaticBoxSizer( item8, wxVERTICAL ); + wxStaticBoxSizer * const + sizerLog = new wxStaticBoxSizer(wxVERTICAL, panel, "Server &log"); - wxTextCtrl *item9 = new wxTextCtrl( this, ID_LOG, wxT(""), wxDefaultPosition, wxSize(500,140), wxTE_MULTILINE ); - item7->Add( item9, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + wxTextCtrl * const textLog = new wxTextCtrl + ( + panel, + wxID_ANY, + "", + wxDefaultPosition, wxSize(500, 140), + wxTE_MULTILINE + ); + sizerLog->Add(textLog, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); - item0->Add( item7, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 ); + sizerMain->Add(sizerLog, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5); - SetSizer( item0 ); - item0->SetSizeHints( this ); + panel->SetSizer(sizerMain); + sizerMain->SetSizeHints(panel); + SetClientSize(panel->GetSize()); - // status - m_server = NULL; GetServername()->SetSelection(0); - wxLogTextCtrl *logWindow = new wxLogTextCtrl(GetLog()); + wxLogTextCtrl *logWindow = new wxLogTextCtrl(textLog); delete wxLog::SetActiveTarget(logWindow); - wxLogMessage(_T("Click on Start to start the server")); - Enable(); + wxLogMessage("Click on Start to start the server"); + UpdateUI(); } -void MyFrame::Enable() +void MyFrame::UpdateUI() { GetStart()->Enable(m_server == NULL); GetServername()->Enable(m_server == NULL); @@ -173,19 +160,10 @@ void MyFrame::Enable() void MyFrame::OnClose(wxCloseEvent& event) { - if (m_server) - { - delete m_server; - m_server = NULL; - } + wxDELETE(m_server); event.Skip(); } -void MyFrame::OnExit(wxCommandEvent& WXUNUSED(event)) -{ - Close(true); -} - void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event)) { // Create a new server @@ -193,29 +171,34 @@ void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event)) wxString servername = GetServername()->GetStringSelection(); if (m_server->Create(servername)) { - wxLogMessage(_T("Server %s started"), servername.c_str()); + wxLogMessage("Server %s started", servername); #if wxUSE_DDE_FOR_IPC - wxLogMessage(_T("Server uses DDE")); + wxLogMessage("Server uses DDE"); #else // !wxUSE_DDE_FOR_IPC - wxLogMessage(_T("Server uses TCP")); + wxLogMessage("Server uses TCP"); #endif // wxUSE_DDE_FOR_IPC/!wxUSE_DDE_FOR_IPC } else { - wxLogMessage(_T("Server %s failed to start"), servername.c_str()); - delete m_server; - m_server = NULL; + wxLogMessage("Server %s failed to start", servername); + wxDELETE(m_server); } - Enable(); + UpdateUI(); } void MyFrame::OnServerName( wxCommandEvent& WXUNUSED(event) ) { - if (GetServername()->GetStringSelection() == _T("...")) + if ( GetServername()->GetStringSelection() == "..." ) { - wxString s = wxGetTextFromUser(_T("Specify the name of the server"), - _T("Server Name"), _(""), this); - if (!s.IsEmpty() && s != IPC_SERVICE) + wxString s = wxGetTextFromUser + ( + "Specify the name of the server", + "Server Name", + "", + this + ); + + if ( !s.empty() && s != IPC_SERVICE ) { GetServername()->Insert(s, 0); GetServername()->SetSelection(0); @@ -226,12 +209,12 @@ void MyFrame::OnServerName( wxCommandEvent& WXUNUSED(event) ) void MyFrame::Disconnect() { m_server->Disconnect(); - Enable(); + UpdateUI(); } void MyFrame::OnDisconnect(wxCommandEvent& WXUNUSED(event)) { - Disconnect(); + Disconnect(); } void MyFrame::OnAdvise(wxCommandEvent& WXUNUSED(event)) @@ -255,48 +238,50 @@ MyServer::~MyServer() wxConnectionBase *MyServer::OnAcceptConnection(const wxString& topic) { - wxLogMessage(_T("OnAcceptConnection(\"%s\")"), topic.c_str()); + wxLogMessage("OnAcceptConnection(\"%s\")", topic); if ( topic == IPC_TOPIC ) { m_connection = new MyConnection(); - wxGetApp().GetFrame()->Enable(); - wxLogMessage(_T("Connection accepted")); + wxGetApp().GetFrame()->UpdateUI(); + wxLogMessage("Connection accepted"); return m_connection; } - // unknown topic + //else: unknown topic + + wxLogMessage("Unknown topic, connection refused"); return NULL; } void MyServer::Disconnect() { - if (m_connection) + if ( m_connection ) { - m_connection->Disconnect(); - delete m_connection; - m_connection = NULL; - wxGetApp().GetFrame()->Enable(); - wxLogMessage(_T("Disconnected client")); + wxDELETE(m_connection); + wxGetApp().GetFrame()->UpdateUI(); + wxLogMessage("Disconnected client"); } } void MyServer::Advise() { - if (CanAdvise()) + if ( CanAdvise() ) { - wxString s = wxDateTime::Now().Format(); - m_connection->Advise(m_connection->m_sAdvise, s); - s = wxDateTime::Now().FormatTime() + _T(" ") + wxDateTime::Now().FormatDate(); - m_connection->Advise(m_connection->m_sAdvise, (const char *)s.c_str(), s.Length() + 1); + const wxDateTime now = wxDateTime::Now(); + + m_connection->Advise(m_connection->m_advise, now.Format()); + + const wxString s = now.FormatTime() + " " + now.FormatDate(); + m_connection->Advise(m_connection->m_advise, s.mb_str(), wxNO_LEN); #if wxUSE_DDE_FOR_IPC - wxLogMessage(_T("DDE Advise type argument cannot be wxIPC_PRIVATE. The client will receive it as wxIPC_TEXT, and receive the correct no of bytes, but not print a correct log entry.")); + wxLogMessage("DDE Advise type argument cannot be wxIPC_PRIVATE. " + "The client will receive it as wxIPC_TEXT, " + " and receive the correct no of bytes, " + "but not print a correct log entry."); #endif - char bytes[3]; - bytes[0] = '1'; bytes[1] = '2'; bytes[2] = '3'; - m_connection->Advise(m_connection->m_sAdvise, bytes, 3, wxIPC_PRIVATE); - // this works, but the log treats it as a string now -// m_connection->Advise(m_connection->m_sAdvise, bytes, 3, wxIPC_TEXT ); + char bytes[3] = { '1', '2', '3' }; + m_connection->Advise(m_connection->m_advise, bytes, 3, wxIPC_PRIVATE); } } @@ -304,130 +289,103 @@ void MyServer::Advise() // MyConnection // ---------------------------------------------------------------------------- -MyConnection::MyConnection() - : wxConnection() -{ -} - -MyConnection::~MyConnection() -{ -} - -bool MyConnection::OnExecute(const wxString& topic, - const void *data, size_t size, wxIPCFormat format) +bool +MyConnection::OnExecute(const wxString& topic, + const void *data, + size_t size, + wxIPCFormat format) { - Log(_T("OnExecute"), topic, _T(""), data, size, format); + Log("OnExecute", topic, "", data, size, format); return true; } -bool MyConnection::OnPoke(const wxString& topic, - const wxString& item, const void *data, size_t size, wxIPCFormat format) +bool +MyConnection::OnPoke(const wxString& topic, + const wxString& item, + const void *data, + size_t size, + wxIPCFormat format) { - Log(_T("OnPoke"), topic, item, data, size, format); + Log("OnPoke", topic, item, data, size, format); return wxConnection::OnPoke(topic, item, data, size, format); } -const void *MyConnection::OnRequest(const wxString& topic, - const wxString& item, size_t *size, wxIPCFormat format) +const void * +MyConnection::OnRequest(const wxString& topic, + const wxString& item, + size_t *size, + wxIPCFormat format) { - const void *data; - if (item == _T("Date")) - { - m_sRequestDate = wxDateTime::Now().Format(); - data = m_sRequestDate.c_str(); - *size = wxNO_LEN; - } - else if (item == _T("Date+len")) + *size = 0; + + wxString s, + afterDate; + if ( item.StartsWith("Date", &afterDate) ) { - m_sRequestDate = wxDateTime::Now().FormatTime() + _T(" ") + wxDateTime::Now().FormatDate(); - data = m_sRequestDate.c_str(); - *size = m_sRequestDate.Length() + 1; - } - else if (item == _T("bytes[3]")) + const wxDateTime now = wxDateTime::Now(); + + if ( afterDate.empty() ) + { + s = now.Format(); + *size = wxNO_LEN; + } + else if ( afterDate == "+len" ) + { + s = now.FormatTime() + " " + now.FormatDate(); + *size = strlen(s.mb_str()) + 1; + } + } + else if ( item == "bytes[3]" ) { - data = m_achRequestBytes; - m_achRequestBytes[0] = '1'; m_achRequestBytes[1] = '2'; m_achRequestBytes[2] = '3'; + s = "123"; *size = 3; } - else + + if ( !*size ) { - data = NULL; - *size = 0; + wxLogMessage("Unknown request for \"%s\"", item); + return NULL; } - Log(_T("OnRequest"), topic, item, data, *size, format); + + // store the data pointer to which we return in a member variable to ensure + // that the pointer remains valid even after we return + m_requestData = s.mb_str(); + const void * const data = m_requestData; + Log("OnRequest", topic, item, data, *size, format); return data; } -bool MyConnection::OnStartAdvise(const wxString& topic, - const wxString& item) +bool MyConnection::OnStartAdvise(const wxString& topic, const wxString& item) { - wxLogMessage(_T("OnStartAdvise(\"%s\",\"%s\")"), topic.c_str(), item.c_str()); - wxLogMessage(_T("Returning true")); - m_sAdvise = item; - wxGetApp().GetFrame()->Enable(); + wxLogMessage("OnStartAdvise(\"%s\", \"%s\")", topic, item); + wxLogMessage("Returning true"); + m_advise = item; + wxGetApp().GetFrame()->UpdateUI(); return true; } -bool MyConnection::OnStopAdvise(const wxString& topic, - const wxString& item) +bool MyConnection::OnStopAdvise(const wxString& topic, const wxString& item) { - wxLogMessage(_T("OnStopAdvise(\"%s\",\"%s\")"), topic.c_str(), item.c_str()); - wxLogMessage(_T("Returning true")); - m_sAdvise.Empty(); - wxGetApp().GetFrame()->Enable(); + wxLogMessage("OnStopAdvise(\"%s\",\"%s\")", topic, item); + wxLogMessage("Returning true"); + m_advise.clear(); + wxGetApp().GetFrame()->UpdateUI(); return true; } -void MyConnection::Log(const wxString& command, const wxString& topic, - const wxString& item, const void *data, size_t 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(\"%s\","), command.c_str(), item.c_str()); - else if (item.IsEmpty()) - s.Printf(_T("%s(\"%s\","), command.c_str(), topic.c_str()); - else - s.Printf(_T("%s(\"%s\",\"%s\","), command.c_str(), topic.c_str(), item.c_str()); - - switch (format) - { - case wxIPC_TEXT: - case wxIPC_UTF8TEXT: -#if !wxUSE_UNICODE || wxUSE_UNICODE_UTF8 - wxLogMessage(_T("%s\"%s\",%d)"), s.c_str(), data, size); -#else - wxLogMessage(_T("%s\"%s\",%d)"), s.c_str(), wxConvUTF8.cMB2WC((const char*)data), size); -#endif - break; - case 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); - break; - case wxIPC_INVALID: - wxLogMessage(_T("%s[invalid data],%d)"), s.c_str(), size); - break; - default: - wxLogMessage(_T("%s[unknown data],%d)"), s.c_str(), size); - break; - } -} - -bool MyConnection::DoAdvise(const wxString& item, const void *data, size_t size, wxIPCFormat format) +bool +MyConnection::DoAdvise(const wxString& item, + const void *data, + size_t size, + wxIPCFormat format) { - Log(_T("Advise"), _T(""), item, data, size, format); + Log("Advise", "", item, data, size, format); return wxConnection::DoAdvise(item, data, size, format); } bool MyConnection::OnDisconnect() { - wxLogMessage(_T("OnDisconnect()")); + wxLogMessage("OnDisconnect()"); wxGetApp().GetFrame()->Disconnect(); return true; }