samples/ipc/server.cpp

   1 /////////////////////////////////////////////////////////////////////////////
   2 // Name:        server.cpp
   3 // Purpose:     IPC sample: server
   4 // Author:      Julian Smart
   5 // Modified by: Jurgen Doornik
   6 // Created:     25/01/99
   7 // RCS-ID:      $Id$
   8 // Copyright:   (c) Julian Smart
   9 // Licence:     wxWindows licence
  10 /////////////////////////////////////////////////////////////////////////////
  11
  12 // ============================================================================
  13 // declarations
  14 // ============================================================================
  15
  16 // ----------------------------------------------------------------------------
  17 // headers
  18 // ----------------------------------------------------------------------------
  19
  20 // For compilers that support precompilation, includes "wx.h".
  21 #include "wx/wxprec.h"
  22
  23 #ifdef __BORLANDC__
  24     #pragma hdrstop
  25 #endif
  26
  27 #ifndef WX_PRECOMP
  28     #include "wx/wx.h"
  29 #endif
  30
  31 // Settings common to both executables: determines whether
  32 // we're using TCP/IP or real DDE.
  33 #include "ipcsetup.h"
  34
  35 #if defined(__WXGTK__) || defined(__WXX11__) || defined(__WXMOTIF__) || defined(__WXMAC__)
  36     #include "mondrian.xpm"
  37 #endif
  38
  39 #include "server.h"
  40 #include "wx/textdlg.h"
  41 #include "wx/datetime.h"
  42
  43 // ----------------------------------------------------------------------------
  44 // wxWin macros
  45 // ----------------------------------------------------------------------------
  46
  47 IMPLEMENT_APP(MyApp)
  48
  49 BEGIN_EVENT_TABLE(MyFrame, wxFrame)
  50     EVT_MENU   (wxID_EXIT,         MyFrame::OnExit)
  51     EVT_CLOSE( MyFrame::OnClose )
  52     EVT_BUTTON( ID_START,         MyFrame::OnStart )
  53     EVT_CHOICE( ID_SERVERNAME,  MyFrame::OnServerName )
  54     EVT_BUTTON( ID_DISCONNECT,     MyFrame::OnDisconnect )
  55     EVT_BUTTON( ID_ADVISE,         MyFrame::OnAdvise )
  56 END_EVENT_TABLE()
  57
  58
  59 // ============================================================================
  60 // implementation
  61 // ============================================================================
  62
  63 // ----------------------------------------------------------------------------
  64 // MyApp
  65 // ----------------------------------------------------------------------------
  66
  67 bool MyApp::OnInit()
  68 {
  69     if ( !wxApp::OnInit() )
  70         return false;
  71
  72     // Create the main frame window
  73     m_frame = new MyFrame(NULL, _T("Server"));
  74     m_frame->Show(true);
  75
  76     return true;
  77 }
  78
  79 int MyApp::OnExit()
  80 {
  81     return 0;
  82 }
  83
  84 // ----------------------------------------------------------------------------
  85 // MyFrame
  86 // ----------------------------------------------------------------------------
  87
  88 // Define my frame constructor
  89 MyFrame::MyFrame(wxFrame *frame, const wxString& title)
  90        : wxFrame(frame, wxID_ANY, title, wxDefaultPosition, wxSize(400, 300))
  91 {
  92 #if wxUSE_STATUSBAR
  93     CreateStatusBar();
  94 #endif // wxUSE_STATUSBAR
  95
  96     // Give it an icon
  97     SetIcon(wxICON(mondrian));
  98
  99     // Make a menubar
 100     wxMenu *file_menu = new wxMenu;
 101
 102     file_menu->Append(wxID_EXIT, _T("&Quit\tCtrl-Q"));
 103
 104     wxMenuBar *menu_bar = new wxMenuBar;
 105
 106     menu_bar->Append(file_menu, _T("&File"));
 107
 108     // Associate the menu bar with the frame
 109     SetMenuBar(menu_bar);
 110
 111     // set a dialog background
 112     SetBackgroundColour(wxSystemSettings::GetColour(wxSYS_COLOUR_BTNFACE));
 113
 114     // add the controls to the frame
 115     wxBoxSizer *item0 = new wxBoxSizer( wxVERTICAL );
 116
 117     wxBoxSizer *item1 = new wxBoxSizer( wxHORIZONTAL );
 118
 119     wxFlexGridSizer *item2 = new wxFlexGridSizer( 2, 0, 0 );
 120     item2->AddGrowableCol( 1 );
 121
 122     wxButton *item3 = new wxButton( this, ID_START, wxT("Start Server"), wxDefaultPosition, wxDefaultSize, 0 );
 123     item2->Add( item3, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 124
 125     wxString strs4[] =
 126     {
 127         IPC_SERVICE, _T("...")
 128     };
 129     wxChoice *item4 = new wxChoice( this, ID_SERVERNAME, wxDefaultPosition, wxSize(100,-1), 2, strs4, 0 );
 130     item2->Add( item4, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 131
 132     wxButton *item5 = new wxButton( this, ID_DISCONNECT, wxT("Disconnect Client"), wxDefaultPosition, wxDefaultSize, 0 );
 133     item2->Add( item5, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 134
 135     item2->Add( 20, 20, 0, wxALIGN_CENTER|wxALL, 5 );
 136
 137     wxButton *item6 = new wxButton( this, ID_ADVISE, wxT("Advise"), wxDefaultPosition, wxDefaultSize, 0 );
 138     item2->Add( item6, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 139
 140     item2->Add( 20, 20, 0, wxALIGN_CENTER|wxALL, 5 );
 141
 142     item1->Add( item2, 1, wxALIGN_CENTER|wxALL, 5 );
 143
 144     item0->Add( item1, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 145
 146     wxStaticBox *item8 = new wxStaticBox( this, -1, wxT("Server log") );
 147     wxStaticBoxSizer *item7 = new wxStaticBoxSizer( item8, wxVERTICAL );
 148
 149     wxTextCtrl *item9 = new wxTextCtrl( this, ID_LOG, wxT(""), wxDefaultPosition, wxSize(500,140), wxTE_MULTILINE );
 150     item7->Add( item9, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 151
 152     item0->Add( item7, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5 );
 153
 154     SetSizer( item0 );
 155     item0->SetSizeHints( this );
 156
 157     // status
 158     m_server = NULL;
 159     GetServername()->SetSelection(0);
 160     wxLogTextCtrl *logWindow = new wxLogTextCtrl(GetLog());
 161     delete wxLog::SetActiveTarget(logWindow);
 162     wxLogMessage(_T("Click on Start to start the server"));
 163     Enable();
 164 }
 165
 166 void MyFrame::Enable()
 167 {
 168     GetStart()->Enable(m_server == NULL);
 169     GetServername()->Enable(m_server == NULL);
 170     GetAdvise()->Enable(m_server && m_server->CanAdvise());
 171     GetDisconnect()->Enable(m_server && m_server->IsConnected());
 172 }
 173
 174 void MyFrame::OnClose(wxCloseEvent& event)
 175 {
 176     if (m_server)
 177     {
 178         delete m_server;
 179         m_server = NULL;
 180     }
 181     event.Skip();
 182 }
 183
 184 void MyFrame::OnExit(wxCommandEvent& WXUNUSED(event))
 185 {
 186     Close(true);
 187 }
 188
 189 void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event))
 190 {
 191     // Create a new server
 192     m_server = new MyServer;
 193     wxString servername = GetServername()->GetStringSelection();
 194     if (m_server->Create(servername))
 195     {
 196         wxLogMessage(_T("Server %s started"), servername.c_str());
 197   #if wxUSE_DDE_FOR_IPC
 198         wxLogMessage(_T("Server uses DDE"));
 199   #else // !wxUSE_DDE_FOR_IPC
 200         wxLogMessage(_T("Server uses TCP"));
 201   #endif // wxUSE_DDE_FOR_IPC/!wxUSE_DDE_FOR_IPC
 202     }
 203     else
 204     {
 205         wxLogMessage(_T("Server %s failed to start"), servername.c_str());
 206         delete m_server;
 207         m_server = NULL;
 208     }
 209     Enable();
 210 }
 211
 212 void MyFrame::OnServerName( wxCommandEvent& WXUNUSED(event) )
 213 {
 214     if (GetServername()->GetStringSelection() == _T("..."))
 215     {
 216         wxString s = wxGetTextFromUser(_T("Specify the name of the server"),
 217             _T("Server Name"), _(""), this);
 218         if (!s.IsEmpty() && s != IPC_SERVICE)
 219         {
 220             GetServername()->Insert(s, 0);
 221             GetServername()->SetSelection(0);
 222         }
 223     }
 224 }
 225
 226 void MyFrame::Disconnect()
 227 {
 228     m_server->Disconnect();
 229     Enable();
 230 }
 231
 232 void MyFrame::OnDisconnect(wxCommandEvent& WXUNUSED(event))
 233 {
 234     Disconnect();
 235 }
 236
 237 void MyFrame::OnAdvise(wxCommandEvent& WXUNUSED(event))
 238 {
 239     m_server->Advise();
 240 }
 241
 242 // ----------------------------------------------------------------------------
 243 // MyServer
 244 // ----------------------------------------------------------------------------
 245
 246 MyServer::MyServer() : wxServer()
 247 {
 248     m_connection = NULL;
 249 }
 250
 251 MyServer::~MyServer()
 252 {
 253     Disconnect();
 254 }
 255
 256 wxConnectionBase *MyServer::OnAcceptConnection(const wxString& topic)
 257 {
 258     wxLogMessage(_T("OnAcceptConnection(\"%s\")"), topic.c_str());
 259
 260     if ( topic == IPC_TOPIC )
 261     {
 262         m_connection = new MyConnection();
 263         wxGetApp().GetFrame()->Enable();
 264         wxLogMessage(_T("Connection accepted"));
 265         return m_connection;
 266     }
 267     // unknown topic
 268     return NULL;
 269 }
 270
 271 void MyServer::Disconnect()
 272 {
 273     if (m_connection)
 274     {
 275         m_connection->Disconnect();
 276         delete m_connection;
 277         m_connection = NULL;
 278         wxGetApp().GetFrame()->Enable();
 279         wxLogMessage(_T("Disconnected client"));
 280     }
 281 }
 282
 283 void MyServer::Advise()
 284 {
 285     if (CanAdvise())
 286     {
 287         wxString s = wxDateTime::Now().Format();
 288         m_connection->Advise(m_connection->m_sAdvise, s);
 289         s = wxDateTime::Now().FormatTime() + _T(" ") + wxDateTime::Now().FormatDate();
 290         m_connection->Advise(m_connection->m_sAdvise, (const char *)s.c_str(), s.Length() + 1);
 291
 292 #if wxUSE_DDE_FOR_IPC
 293         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."));
 294 #endif
 295         char bytes[3];
 296         bytes[0] = '1'; bytes[1] = '2'; bytes[2] = '3';
 297         m_connection->Advise(m_connection->m_sAdvise, bytes, 3, wxIPC_PRIVATE);
 298         // this works, but the log treats it as a string now
 299 //        m_connection->Advise(m_connection->m_sAdvise, bytes, 3, wxIPC_TEXT );
 300     }
 301 }
 302
 303 // ----------------------------------------------------------------------------
 304 // MyConnection
 305 // ----------------------------------------------------------------------------
 306
 307 MyConnection::MyConnection()
 308             : wxConnection()
 309 {
 310 }
 311
 312 MyConnection::~MyConnection()
 313 {
 314 }
 315
 316 bool MyConnection::OnExecute(const wxString& topic,
 317     const void *data, size_t size, wxIPCFormat format)
 318 {
 319     Log(_T("OnExecute"), topic, _T(""), data, size, format);
 320     return true;
 321 }
 322
 323 bool MyConnection::OnPoke(const wxString& topic,
 324     const wxString& item, const void *data, size_t size, wxIPCFormat format)
 325 {
 326     Log(_T("OnPoke"), topic, item, data, size, format);
 327     return wxConnection::OnPoke(topic, item, data, size, format);
 328 }
 329
 330 const void *MyConnection::OnRequest(const wxString& topic,
 331     const wxString& item, size_t *size, wxIPCFormat format)
 332 {
 333     const void *data;
 334     if (item == _T("Date"))
 335     {
 336         m_sRequestDate = wxDateTime::Now().Format();
 337         data = m_sRequestDate.c_str();
 338         *size = wxNO_LEN;
 339     }
 340     else if (item == _T("Date+len"))
 341     {
 342         m_sRequestDate = wxDateTime::Now().FormatTime() + _T(" ") + wxDateTime::Now().FormatDate();
 343         data = m_sRequestDate.c_str();
 344         *size = m_sRequestDate.Length() + 1;
 345     }
 346     else if (item == _T("bytes[3]"))
 347     {
 348         data = m_achRequestBytes;
 349         m_achRequestBytes[0] = '1'; m_achRequestBytes[1] = '2'; m_achRequestBytes[2] = '3';
 350         *size = 3;
 351     }
 352     else
 353     {
 354         data = NULL;
 355         *size = 0;
 356     }
 357     Log(_T("OnRequest"), topic, item, data, *size, format);
 358     return data;
 359 }
 360
 361 bool MyConnection::OnStartAdvise(const wxString& topic,
 362                                  const wxString& item)
 363 {
 364     wxLogMessage(_T("OnStartAdvise(\"%s\",\"%s\")"), topic.c_str(), item.c_str());
 365     wxLogMessage(_T("Returning true"));
 366     m_sAdvise = item;
 367     wxGetApp().GetFrame()->Enable();
 368     return true;
 369 }
 370
 371 bool MyConnection::OnStopAdvise(const wxString& topic,
 372                                  const wxString& item)
 373 {
 374     wxLogMessage(_T("OnStopAdvise(\"%s\",\"%s\")"), topic.c_str(), item.c_str());
 375     wxLogMessage(_T("Returning true"));
 376     m_sAdvise.Empty();
 377     wxGetApp().GetFrame()->Enable();
 378     return true;
 379 }
 380
 381 void MyConnection::Log(const wxString& command, const wxString& topic,
 382     const wxString& item, const void *data, size_t size, wxIPCFormat format)
 383 {
 384     wxString s;
 385     if (topic.IsEmpty() && item.IsEmpty())
 386         s.Printf(_T("%s("), command.c_str());
 387     else if (topic.IsEmpty())
 388         s.Printf(_T("%s(\"%s\","), command.c_str(), item.c_str());
 389     else if (item.IsEmpty())
 390         s.Printf(_T("%s(\"%s\","), command.c_str(), topic.c_str());
 391     else
 392         s.Printf(_T("%s(\"%s\",\"%s\","), command.c_str(), topic.c_str(), item.c_str());
 393
 394     switch (format)
 395     {
 396       case wxIPC_TEXT:
 397       case wxIPC_UTF8TEXT:
 398 #if !wxUSE_UNICODE || wxUSE_UNICODE_UTF8
 399         wxLogMessage(_T("%s\"%s\",%d)"), s.c_str(), data, size);
 400 #else
 401         wxLogMessage(_T("%s\"%s\",%d)"), s.c_str(), wxConvUTF8.cMB2WC((const char*)data), size);
 402 #endif
 403         break;
 404       case wxIPC_PRIVATE:
 405         if (size == 3)
 406         {
 407             char *bytes = (char *)data;
 408             wxLogMessage(_T("%s'%c%c%c',%d)"), s.c_str(), bytes[0], bytes[1], bytes[2], size);
 409         }
 410         else
 411             wxLogMessage(_T("%s...,%d)"), s.c_str(), size);
 412         break;
 413       case wxIPC_INVALID:
 414         wxLogMessage(_T("%s[invalid data],%d)"), s.c_str(), size);
 415         break;
 416       default:
 417         wxLogMessage(_T("%s[unknown data],%d)"), s.c_str(), size);
 418         break;
 419     }
 420 }
 421
 422 bool MyConnection::DoAdvise(const wxString& item, const void *data, size_t size, wxIPCFormat format)
 423 {
 424     Log(_T("Advise"), _T(""), item, data, size, format);
 425     return wxConnection::DoAdvise(item, data, size, format);
 426 }
 427
 428 bool MyConnection::OnDisconnect()
 429 {
 430     wxLogMessage(_T("OnDisconnect()"));
 431     wxGetApp().GetFrame()->Disconnect();
 432     return true;
 433 }