X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/69d16e3ef87c21364456307b5df88c2f4962b63d..c48792de4abe190910c0cb212c5df44d2ef87a7e:/samples/sockets/client.cpp diff --git a/samples/sockets/client.cpp b/samples/sockets/client.cpp index 2240786c19..ec02f7eada 100644 --- a/samples/sockets/client.cpp +++ b/samples/sockets/client.cpp @@ -43,7 +43,7 @@ // -------------------------------------------------------------------------- // the application icon -#if defined(__WXGTK__) || defined(__WXMOTIF__) +#if defined(__WXGTK__) || defined(__WXMOTIF__) || defined(__WXMAC__) # include "mondrian.xpm" #endif @@ -79,7 +79,7 @@ public: // event handlers for Protocols menu void OnTestURL(wxCommandEvent& event); - // event handlers for DatagramSocket menu + // event handlers for DatagramSocket menu (stub) void OnDatagram(wxCommandEvent& event); // socket event handler @@ -90,7 +90,6 @@ public: private: wxSocketClient *m_sock; - wxPanel *m_panel; wxTextCtrl *m_text; wxMenu *m_menuFile; wxMenu *m_menuSocket; @@ -209,16 +208,17 @@ MyFrame::MyFrame() : wxFrame((wxFrame *)NULL, -1, // Status bar CreateStatusBar(2); - // Make a panel with a textctrl in it - m_panel = new wxPanel(this, -1, wxPoint(0, 0), GetClientSize()); - m_text = new wxTextCtrl(m_panel, -1, + // Make a textctrl for logging + m_text = new wxTextCtrl(this, -1, _("Welcome to wxSocket demo: Client\n" "Client ready\n"), - wxPoint(0, 0), m_panel->GetClientSize(), + wxDefaultPosition, wxDefaultSize, wxTE_MULTILINE | wxTE_READONLY); // Create the socket m_sock = new wxSocketClient(); + + // Setup the event handler and subscribe to most events m_sock->SetEventHandler(*this, SOCKET_ID); m_sock->SetNotify(wxSOCKET_CONNECTION_FLAG | wxSOCKET_INPUT_FLAG | @@ -231,6 +231,7 @@ MyFrame::MyFrame() : wxFrame((wxFrame *)NULL, -1, MyFrame::~MyFrame() { + // No delayed deletion here, as the frame is dying anyway delete m_sock; } @@ -286,26 +287,35 @@ void MyFrame::OnOpenConnection(wxCommandEvent& WXUNUSED(event)) // // WaitOnConnect() itself never blocks the GUI (this might change // in the future to honour the wxSOCKET_BLOCK flag). This call will - // return TRUE if the connection request completed succesfully, or - // FALSE otherwise, which in turn might mean: - // a) that the specified timeout ellapsed, or - // b) that the connection request failed. + // return FALSE on timeout, or TRUE if the connection request + // completes, which in turn might mean: + // + // a) That the connection was successfully established + // b) That the connection request failed (for example, because + // it was refused by the peer. + // // Use IsConnected() to distinguish between these two. // // So, in a brief, you should do one of the following things: // // For blocking Connect: // - // bool success = Connect(addr, TRUE); + // bool success = client->Connect(addr, TRUE); // // For nonblocking Connect: // - // Connect(addr, FALSE); - // WaitOnConnect(seconds, millis); - // success = IsConnected(); + // client->Connect(addr, FALSE); + // + // bool waitmore = TRUE; + // while (! client->WaitOnConnect(seconds, millis) && waitmore ) + // { + // // possibly give some feedback to the user, + // // update waitmore if needed. + // } + // bool success = client->IsConnected(); // // And that's all :-) - // + m_text->AppendText(_("\nTrying to connect (timeout = 10 sec) ...\n")); m_sock->Connect(addr, FALSE); m_sock->WaitOnConnect(10); @@ -335,7 +345,7 @@ void MyFrame::OnTest1(wxCommandEvent& WXUNUSED(event)) m_text->AppendText(_("\n=== Test 1 begins ===\n")); // Tell the server which test we are running - char c = 0xBE; + unsigned char c = 0xBE; m_sock->Write(&c, 1); // Send some data and read it back. We know the size of the @@ -349,7 +359,7 @@ void MyFrame::OnTest1(wxCommandEvent& WXUNUSED(event)) // value larger than a byte "as is" across the network, or // you might be in trouble! Ever heard about big and little // endian computers?) - // + m_sock->SetFlags(wxSOCKET_WAITALL); buf1 = _("Test string (less than 256 chars!)"); @@ -357,7 +367,7 @@ void MyFrame::OnTest1(wxCommandEvent& WXUNUSED(event)) buf2 = new char[len]; m_text->AppendText(_("Sending a test buffer to the server ...")); - m_sock->Write((char *)&len, 1); + m_sock->Write(&len, 1); m_sock->Write(buf1, len); m_text->AppendText(m_sock->Error() ? _("failed !\n") : _("done\n")); @@ -396,7 +406,7 @@ void MyFrame::OnTest2(wxCommandEvent& WXUNUSED(event)) m_text->AppendText(_("\n=== Test 2 begins ===\n")); // Tell the server which test we are running - char c = 0xCE; + unsigned char c = 0xCE; m_sock->Write(&c, 1); // Here we use ReadMsg and WriteMsg to send messages with @@ -405,7 +415,7 @@ void MyFrame::OnTest2(wxCommandEvent& WXUNUSED(event)) // // We need to set no flags here (ReadMsg and WriteMsg are // not affected by flags) - // + m_sock->SetFlags(wxSOCKET_WAITALL); wxString s = wxGetTextFromUser( @@ -465,14 +475,14 @@ void MyFrame::OnTest3(wxCommandEvent& WXUNUSED(event)) m_text->AppendText(_("\n=== Test 3 begins ===\n")); // Tell the server which test we are running - char c = 0xDE; + unsigned char c = 0xDE; m_sock->Write(&c, 1); // This test also is similar to the first one but it sends a // large buffer so that wxSocket is actually forced to split // it into pieces and take care of sending everything before // returning. - // + m_sock->SetFlags(wxSOCKET_WAITALL); // Note that len is in kbytes here! @@ -484,7 +494,7 @@ void MyFrame::OnTest3(wxCommandEvent& WXUNUSED(event)) buf1[i] = (char)(i % 256); m_text->AppendText(_("Sending a large buffer (32K) to the server ...")); - m_sock->Write((char *)&len, 1); + m_sock->Write(&len, 1); m_sock->Write(buf1, len * 1024); m_text->AppendText(m_sock->Error() ? _("failed !\n") : _("done\n")); @@ -518,6 +528,9 @@ void MyFrame::OnCloseConnection(wxCommandEvent& WXUNUSED(event)) void MyFrame::OnDatagram(wxCommandEvent& WXUNUSED(event)) { + m_text->AppendText(_("\n=== Datagram test begins ===\n")); + m_text->AppendText(_("Sorry, not implemented\n")); + m_text->AppendText(_("=== Datagram test ends ===\n")); } void MyFrame::OnTestURL(wxCommandEvent& WXUNUSED(event)) @@ -529,10 +542,16 @@ void MyFrame::OnTestURL(wxCommandEvent& WXUNUSED(event)) m_text->AppendText(_("\n=== URL test begins ===\n")); wxString urlname = wxGetTextFromUser(_("Enter an URL to get"), _("URL:"), - _("http://localhost")); + _T("http://localhost")); // Parse the URL wxURL url(urlname); + if (url.GetError() != wxURL_NOERR) + { + m_text->AppendText(_("Error: couldn't parse URL\n")); + m_text->AppendText(_("=== URL test ends ===\n")); + return; + } // Try to get the input stream (connects to the given URL) m_text->AppendText(_("Trying to establish connection...\n")); @@ -557,6 +576,13 @@ void MyFrame::OnTestURL(wxCommandEvent& WXUNUSED(event)) // Get the data wxFileOutputStream sout(wxString("test.url")); + if (!sout.Ok()) + { + m_text->AppendText(_("Error: couldn't open file for output\n")); + m_text->AppendText(_("=== URL test ends ===\n")); + return; + } + data->Read(sout); m_text->AppendText(_("Results written to file: test.url\n")); m_text->AppendText(_("Done.\n")); @@ -569,7 +595,7 @@ void MyFrame::OnSocketEvent(wxSocketEvent& event) { wxString s = _("OnSocketEvent: "); - switch(event.SocketEvent()) + switch(event.GetSocketEvent()) { case wxSOCKET_INPUT : s.Append(_("wxSOCKET_INPUT\n")); break; case wxSOCKET_LOST : s.Append(_("wxSOCKET_LOST\n")); break;