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(__WXMSW__) && !defined(__WXPM__)
  36     #include "../sample.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_CLOSE( MyFrame::OnClose )
  51
  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, "Server");
  74     m_frame->Show(true);
  75
  76     return true;
  77 }
  78
  79 // ----------------------------------------------------------------------------
  80 // MyFrame
  81 // ----------------------------------------------------------------------------
  82
  83 // Define my frame constructor
  84 MyFrame::MyFrame(wxFrame *frame, const wxString& title)
  85        : wxFrame(frame, wxID_ANY, title, wxDefaultPosition, wxSize(400, 300))
  86 {
  87 #if wxUSE_STATUSBAR
  88     CreateStatusBar();
  89 #endif // wxUSE_STATUSBAR
  90
  91     SetIcon(wxICON(sample));
  92
  93     m_server = NULL;
  94
  95     wxPanel * const panel = new wxPanel(this);
  96
  97     wxBoxSizer * const sizerMain = new wxBoxSizer( wxVERTICAL );
  98
  99     wxFlexGridSizer * const sizerCmds = new wxFlexGridSizer( 2, 0, 0 );
 100     sizerCmds->AddGrowableCol( 1 );
 101
 102     wxButton *btn;
 103
 104     btn = new wxButton(panel, ID_START, "&Start Server");
 105     sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 106
 107     const wxString choices[] = { IPC_SERVICE, "..." };
 108     wxChoice * const choice = new wxChoice
 109                                   (
 110                                     panel,
 111                                     ID_SERVERNAME,
 112                                     wxDefaultPosition, wxSize(100, -1),
 113                                     WXSIZEOF(choices), choices
 114                                   );
 115     sizerCmds->Add(choice, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 116
 117     btn = new wxButton(panel, ID_DISCONNECT, "&Disconnect Client");
 118     sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 119     sizerCmds->AddSpacer(20);
 120
 121     btn = new wxButton( panel, ID_ADVISE, "&Advise");
 122     sizerCmds->Add(btn, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 123     sizerCmds->AddSpacer(20);
 124
 125     sizerMain->Add(sizerCmds, 0, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 126
 127     wxStaticBoxSizer * const
 128         sizerLog = new wxStaticBoxSizer(wxVERTICAL, panel, "Server &log");
 129
 130     wxTextCtrl * const textLog = new wxTextCtrl
 131                                  (
 132                                     panel,
 133                                     wxID_ANY,
 134                                     "",
 135                                     wxDefaultPosition, wxSize(500, 140),
 136                                     wxTE_MULTILINE
 137                                  );
 138     sizerLog->Add(textLog, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 139
 140     sizerMain->Add(sizerLog, 1, wxGROW|wxALIGN_CENTER_VERTICAL|wxALL, 5);
 141
 142     panel->SetSizer(sizerMain);
 143     sizerMain->SetSizeHints(panel);
 144     SetClientSize(panel->GetSize());
 145
 146     GetServername()->SetSelection(0);
 147     wxLogTextCtrl *logWindow = new wxLogTextCtrl(textLog);
 148     delete wxLog::SetActiveTarget(logWindow);
 149     wxLogMessage("Click on Start to start the server");
 150     UpdateUI();
 151 }
 152
 153 void MyFrame::UpdateUI()
 154 {
 155     GetStart()->Enable(m_server == NULL);
 156     GetServername()->Enable(m_server == NULL);
 157     GetAdvise()->Enable(m_server && m_server->CanAdvise());
 158     GetDisconnect()->Enable(m_server && m_server->IsConnected());
 159 }
 160
 161 void MyFrame::OnClose(wxCloseEvent& event)
 162 {
 163     if (m_server)
 164     {
 165         delete m_server;
 166         m_server = NULL;
 167     }
 168     event.Skip();
 169 }
 170
 171 void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event))
 172 {
 173     // Create a new server
 174     m_server = new MyServer;
 175     wxString servername = GetServername()->GetStringSelection();
 176     if (m_server->Create(servername))
 177     {
 178         wxLogMessage("Server %s started", servername);
 179   #if wxUSE_DDE_FOR_IPC
 180         wxLogMessage("Server uses DDE");
 181   #else // !wxUSE_DDE_FOR_IPC
 182         wxLogMessage("Server uses TCP");
 183   #endif // wxUSE_DDE_FOR_IPC/!wxUSE_DDE_FOR_IPC
 184     }
 185     else
 186     {
 187         wxLogMessage("Server %s failed to start", servername);
 188         delete m_server;
 189         m_server = NULL;
 190     }
 191     UpdateUI();
 192 }
 193
 194 void MyFrame::OnServerName( wxCommandEvent& WXUNUSED(event) )
 195 {
 196     if ( GetServername()->GetStringSelection() == "..." )
 197     {
 198         wxString s = wxGetTextFromUser
 199                      (
 200                         "Specify the name of the server",
 201                         "Server Name",
 202                         "",
 203                         this
 204                      );
 205
 206         if ( !s.empty() && s != IPC_SERVICE )
 207         {
 208             GetServername()->Insert(s, 0);
 209             GetServername()->SetSelection(0);
 210         }
 211     }
 212 }
 213
 214 void MyFrame::Disconnect()
 215 {
 216     m_server->Disconnect();
 217     UpdateUI();
 218 }
 219
 220 void MyFrame::OnDisconnect(wxCommandEvent& WXUNUSED(event))
 221 {
 222     Disconnect();
 223 }
 224
 225 void MyFrame::OnAdvise(wxCommandEvent& WXUNUSED(event))
 226 {
 227     m_server->Advise();
 228 }
 229
 230 // ----------------------------------------------------------------------------
 231 // MyServer
 232 // ----------------------------------------------------------------------------
 233
 234 MyServer::MyServer() : wxServer()
 235 {
 236     m_connection = NULL;
 237 }
 238
 239 MyServer::~MyServer()
 240 {
 241     Disconnect();
 242 }
 243
 244 wxConnectionBase *MyServer::OnAcceptConnection(const wxString& topic)
 245 {
 246     wxLogMessage("OnAcceptConnection(\"%s\")", topic);
 247
 248     if ( topic == IPC_TOPIC )
 249     {
 250         m_connection = new MyConnection();
 251         wxGetApp().GetFrame()->UpdateUI();
 252         wxLogMessage("Connection accepted");
 253         return m_connection;
 254     }
 255     //else: unknown topic
 256
 257     wxLogMessage("Unknown topic, connection refused");
 258     return NULL;
 259 }
 260
 261 void MyServer::Disconnect()
 262 {
 263     if ( m_connection )
 264     {
 265         delete m_connection;
 266         m_connection = NULL;
 267         wxGetApp().GetFrame()->UpdateUI();
 268         wxLogMessage("Disconnected client");
 269     }
 270 }
 271
 272 void MyServer::Advise()
 273 {
 274     if ( CanAdvise() )
 275     {
 276         const wxDateTime now = wxDateTime::Now();
 277
 278         m_connection->Advise(m_connection->m_advise, now.Format());
 279
 280         const wxString s = now.FormatTime() + " " + now.FormatDate();
 281         m_connection->Advise(m_connection->m_advise, s.mb_str(), wxNO_LEN);
 282
 283 #if wxUSE_DDE_FOR_IPC
 284         wxLogMessage("DDE Advise type argument cannot be wxIPC_PRIVATE. "
 285                      "The client will receive it as wxIPC_TEXT, "
 286                      " and receive the correct no of bytes, "
 287                      "but not print a correct log entry.");
 288 #endif
 289         char bytes[3] = { '1', '2', '3' };
 290         m_connection->Advise(m_connection->m_advise, bytes, 3, wxIPC_PRIVATE);
 291     }
 292 }
 293
 294 // ----------------------------------------------------------------------------
 295 // MyConnection
 296 // ----------------------------------------------------------------------------
 297
 298 bool
 299 MyConnection::OnExecute(const wxString& topic,
 300                         const void *data,
 301                         size_t size,
 302                         wxIPCFormat format)
 303 {
 304     Log("OnExecute", topic, "", data, size, format);
 305     return true;
 306 }
 307
 308 bool
 309 MyConnection::OnPoke(const wxString& topic,
 310                      const wxString& item,
 311                      const void *data,
 312                      size_t size,
 313                      wxIPCFormat format)
 314 {
 315     Log("OnPoke", topic, item, data, size, format);
 316     return wxConnection::OnPoke(topic, item, data, size, format);
 317 }
 318
 319 const void *
 320 MyConnection::OnRequest(const wxString& topic,
 321                         const wxString& item,
 322                         size_t *size,
 323                         wxIPCFormat format)
 324 {
 325     *size = 0;
 326
 327     wxString afterDate;
 328     if ( item.StartsWith("Date", &afterDate) )
 329     {
 330         const wxDateTime now = wxDateTime::Now();
 331
 332         if ( afterDate.empty() )
 333         {
 334             m_requestData = now.Format();
 335             *size = wxNO_LEN;
 336         }
 337         else if ( afterDate == "+len" )
 338         {
 339             m_requestData = now.FormatTime() + " " + now.FormatDate();
 340             *size = strlen(m_requestData.mb_str()) + 1;
 341         }
 342     }
 343     else if ( item == "bytes[3]" )
 344     {
 345         m_requestData = "123";
 346         *size = 3;
 347     }
 348
 349     if ( !*size )
 350     {
 351         wxLogMessage("Unknown request for \"%s\"", item);
 352         return NULL;
 353     }
 354
 355     const void * const data = m_requestData.mb_str();
 356     Log("OnRequest", topic, item, data, *size, format);
 357     return data;
 358 }
 359
 360 bool MyConnection::OnStartAdvise(const wxString& topic, const wxString& item)
 361 {
 362     wxLogMessage("OnStartAdvise(\"%s\", \"%s\")", topic, item);
 363     wxLogMessage("Returning true");
 364     m_advise = item;
 365     wxGetApp().GetFrame()->UpdateUI();
 366     return true;
 367 }
 368
 369 bool MyConnection::OnStopAdvise(const wxString& topic, const wxString& item)
 370 {
 371     wxLogMessage("OnStopAdvise(\"%s\",\"%s\")", topic, item);
 372     wxLogMessage("Returning true");
 373     m_advise.clear();
 374     wxGetApp().GetFrame()->UpdateUI();
 375     return true;
 376 }
 377
 378 bool
 379 MyConnection::DoAdvise(const wxString& item,
 380                        const void *data,
 381                        size_t size,
 382                        wxIPCFormat format)
 383 {
 384     Log("Advise", "", item, data, size, format);
 385     return wxConnection::DoAdvise(item, data, size, format);
 386 }
 387
 388 bool MyConnection::OnDisconnect()
 389 {
 390     wxLogMessage("OnDisconnect()");
 391     wxGetApp().GetFrame()->Disconnect();
 392     return true;
 393 }