]>
Commit | Line | Data |
---|---|---|
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 | wxDELETE(m_server); | |
164 | event.Skip(); | |
165 | } | |
166 | ||
167 | void MyFrame::OnStart(wxCommandEvent& WXUNUSED(event)) | |
168 | { | |
169 | // Create a new server | |
170 | m_server = new MyServer; | |
171 | wxString servername = GetServername()->GetStringSelection(); | |
172 | if (m_server->Create(servername)) | |
173 | { | |
174 | wxLogMessage("Server %s started", servername); | |
175 | #if wxUSE_DDE_FOR_IPC | |
176 | wxLogMessage("Server uses DDE"); | |
177 | #else // !wxUSE_DDE_FOR_IPC | |
178 | wxLogMessage("Server uses TCP"); | |
179 | #endif // wxUSE_DDE_FOR_IPC/!wxUSE_DDE_FOR_IPC | |
180 | } | |
181 | else | |
182 | { | |
183 | wxLogMessage("Server %s failed to start", servername); | |
184 | wxDELETE(m_server); | |
185 | } | |
186 | UpdateUI(); | |
187 | } | |
188 | ||
189 | void MyFrame::OnServerName( wxCommandEvent& WXUNUSED(event) ) | |
190 | { | |
191 | if ( GetServername()->GetStringSelection() == "..." ) | |
192 | { | |
193 | wxString s = wxGetTextFromUser | |
194 | ( | |
195 | "Specify the name of the server", | |
196 | "Server Name", | |
197 | "", | |
198 | this | |
199 | ); | |
200 | ||
201 | if ( !s.empty() && s != IPC_SERVICE ) | |
202 | { | |
203 | GetServername()->Insert(s, 0); | |
204 | GetServername()->SetSelection(0); | |
205 | } | |
206 | } | |
207 | } | |
208 | ||
209 | void MyFrame::Disconnect() | |
210 | { | |
211 | m_server->Disconnect(); | |
212 | UpdateUI(); | |
213 | } | |
214 | ||
215 | void MyFrame::OnDisconnect(wxCommandEvent& WXUNUSED(event)) | |
216 | { | |
217 | Disconnect(); | |
218 | } | |
219 | ||
220 | void MyFrame::OnAdvise(wxCommandEvent& WXUNUSED(event)) | |
221 | { | |
222 | m_server->Advise(); | |
223 | } | |
224 | ||
225 | // ---------------------------------------------------------------------------- | |
226 | // MyServer | |
227 | // ---------------------------------------------------------------------------- | |
228 | ||
229 | MyServer::MyServer() : wxServer() | |
230 | { | |
231 | m_connection = NULL; | |
232 | } | |
233 | ||
234 | MyServer::~MyServer() | |
235 | { | |
236 | Disconnect(); | |
237 | } | |
238 | ||
239 | wxConnectionBase *MyServer::OnAcceptConnection(const wxString& topic) | |
240 | { | |
241 | wxLogMessage("OnAcceptConnection(\"%s\")", topic); | |
242 | ||
243 | if ( topic == IPC_TOPIC ) | |
244 | { | |
245 | m_connection = new MyConnection(); | |
246 | wxGetApp().GetFrame()->UpdateUI(); | |
247 | wxLogMessage("Connection accepted"); | |
248 | return m_connection; | |
249 | } | |
250 | //else: unknown topic | |
251 | ||
252 | wxLogMessage("Unknown topic, connection refused"); | |
253 | return NULL; | |
254 | } | |
255 | ||
256 | void MyServer::Disconnect() | |
257 | { | |
258 | if ( m_connection ) | |
259 | { | |
260 | wxDELETE(m_connection); | |
261 | wxGetApp().GetFrame()->UpdateUI(); | |
262 | wxLogMessage("Disconnected client"); | |
263 | } | |
264 | } | |
265 | ||
266 | void MyServer::Advise() | |
267 | { | |
268 | if ( CanAdvise() ) | |
269 | { | |
270 | const wxDateTime now = wxDateTime::Now(); | |
271 | ||
272 | m_connection->Advise(m_connection->m_advise, now.Format()); | |
273 | ||
274 | const wxString s = now.FormatTime() + " " + now.FormatDate(); | |
275 | m_connection->Advise(m_connection->m_advise, s.mb_str(), wxNO_LEN); | |
276 | ||
277 | #if wxUSE_DDE_FOR_IPC | |
278 | wxLogMessage("DDE Advise type argument cannot be wxIPC_PRIVATE. " | |
279 | "The client will receive it as wxIPC_TEXT, " | |
280 | " and receive the correct no of bytes, " | |
281 | "but not print a correct log entry."); | |
282 | #endif | |
283 | char bytes[3] = { '1', '2', '3' }; | |
284 | m_connection->Advise(m_connection->m_advise, bytes, 3, wxIPC_PRIVATE); | |
285 | } | |
286 | } | |
287 | ||
288 | // ---------------------------------------------------------------------------- | |
289 | // MyConnection | |
290 | // ---------------------------------------------------------------------------- | |
291 | ||
292 | bool | |
293 | MyConnection::OnExecute(const wxString& topic, | |
294 | const void *data, | |
295 | size_t size, | |
296 | wxIPCFormat format) | |
297 | { | |
298 | Log("OnExecute", topic, "", data, size, format); | |
299 | return true; | |
300 | } | |
301 | ||
302 | bool | |
303 | MyConnection::OnPoke(const wxString& topic, | |
304 | const wxString& item, | |
305 | const void *data, | |
306 | size_t size, | |
307 | wxIPCFormat format) | |
308 | { | |
309 | Log("OnPoke", topic, item, data, size, format); | |
310 | return wxConnection::OnPoke(topic, item, data, size, format); | |
311 | } | |
312 | ||
313 | const void * | |
314 | MyConnection::OnRequest(const wxString& topic, | |
315 | const wxString& item, | |
316 | size_t *size, | |
317 | wxIPCFormat format) | |
318 | { | |
319 | *size = 0; | |
320 | ||
321 | wxString s, | |
322 | afterDate; | |
323 | if ( item.StartsWith("Date", &afterDate) ) | |
324 | { | |
325 | const wxDateTime now = wxDateTime::Now(); | |
326 | ||
327 | if ( afterDate.empty() ) | |
328 | { | |
329 | s = now.Format(); | |
330 | *size = wxNO_LEN; | |
331 | } | |
332 | else if ( afterDate == "+len" ) | |
333 | { | |
334 | s = now.FormatTime() + " " + now.FormatDate(); | |
335 | *size = strlen(s.mb_str()) + 1; | |
336 | } | |
337 | } | |
338 | else if ( item == "bytes[3]" ) | |
339 | { | |
340 | s = "123"; | |
341 | *size = 3; | |
342 | } | |
343 | ||
344 | if ( !*size ) | |
345 | { | |
346 | wxLogMessage("Unknown request for \"%s\"", item); | |
347 | return NULL; | |
348 | } | |
349 | ||
350 | // store the data pointer to which we return in a member variable to ensure | |
351 | // that the pointer remains valid even after we return | |
352 | m_requestData = s.mb_str(); | |
353 | const void * const data = m_requestData; | |
354 | Log("OnRequest", topic, item, data, *size, format); | |
355 | return data; | |
356 | } | |
357 | ||
358 | bool MyConnection::OnStartAdvise(const wxString& topic, const wxString& item) | |
359 | { | |
360 | wxLogMessage("OnStartAdvise(\"%s\", \"%s\")", topic, item); | |
361 | wxLogMessage("Returning true"); | |
362 | m_advise = item; | |
363 | wxGetApp().GetFrame()->UpdateUI(); | |
364 | return true; | |
365 | } | |
366 | ||
367 | bool MyConnection::OnStopAdvise(const wxString& topic, const wxString& item) | |
368 | { | |
369 | wxLogMessage("OnStopAdvise(\"%s\",\"%s\")", topic, item); | |
370 | wxLogMessage("Returning true"); | |
371 | m_advise.clear(); | |
372 | wxGetApp().GetFrame()->UpdateUI(); | |
373 | return true; | |
374 | } | |
375 | ||
376 | bool | |
377 | MyConnection::DoAdvise(const wxString& item, | |
378 | const void *data, | |
379 | size_t size, | |
380 | wxIPCFormat format) | |
381 | { | |
382 | Log("Advise", "", item, data, size, format); | |
383 | return wxConnection::DoAdvise(item, data, size, format); | |
384 | } | |
385 | ||
386 | bool MyConnection::OnDisconnect() | |
387 | { | |
388 | wxLogMessage("OnDisconnect()"); | |
389 | wxGetApp().GetFrame()->Disconnect(); | |
390 | return true; | |
391 | } |