X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/fcc6dddd1f1da49f94767ff148eaa3f1d3ca9367..7c1cb261228c78cac34ee9f0b08e2674b07c37ee:/src/common/protocol.cpp diff --git a/src/common/protocol.cpp b/src/common/protocol.cpp index b9cbcb8634..542752e318 100644 --- a/src/common/protocol.cpp +++ b/src/common/protocol.cpp @@ -17,15 +17,14 @@ #include "wx/wxprec.h" #ifdef __BORLANDC__ -#pragma hdrstop -#endif - -#ifndef WX_PRECOMP -#include + #pragma hdrstop #endif #include "wx/protocol/protocol.h" #include "wx/url.h" +#include "wx/module.h" + +#include ///////////////////////////////////////////////////////////////// // wxProtoInfo @@ -37,7 +36,7 @@ * -------------------------------------------------------------- */ -wxProtoInfo::wxProtoInfo(const char *name, const char *serv, +wxProtoInfo::wxProtoInfo(const wxChar *name, const wxChar *serv, const bool need_host1, wxClassInfo *info) { m_protoname = name; @@ -52,18 +51,26 @@ wxProtoInfo::wxProtoInfo(const char *name, const char *serv, // wxProtocol /////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////// +#if wxUSE_SOCKETS IMPLEMENT_ABSTRACT_CLASS(wxProtocol, wxSocketClient) +#else +IMPLEMENT_ABSTRACT_CLASS(wxProtocol, wxObject) +#endif wxProtocol::wxProtocol() +#if wxUSE_SOCKETS : wxSocketClient() +#endif { } +#if wxUSE_SOCKETS bool wxProtocol::Reconnect() { wxIPV4address addr; - if (!GetPeer(addr)) { + if (!GetPeer(addr)) + { Close(); return FALSE; } @@ -71,6 +78,7 @@ bool wxProtocol::Reconnect() return FALSE; if (!Connect(addr)) return FALSE; + return TRUE; } @@ -82,7 +90,7 @@ wxProtocolError GetLine(wxSocketBase *sock, wxString& result) { bool found; avail = sock->Read(tmp_buf, PROTO_BSIZE).LastCount(); - if (sock->LastError() != 0 || avail == 0) + if (sock->Error() || avail == 0) return wxPROTO_NETERR; memcpy(tmp_str, tmp_buf, avail); @@ -104,7 +112,47 @@ wxProtocolError GetLine(wxSocketBase *sock, wxString& result) { result = result.Left(result.Length()-1); size = ret-tmp_str+1; - sock->CreatePushbackBefore(&tmp_buf[size], avail-size); + sock->Unread(&tmp_buf[size], avail-size); return wxPROTO_NOERR; #undef PROTO_BSIZE } +#endif + +// ---------------------------------------------------------------------- +// Module +// ---------------------------------------------------------------------- + +class wxProtocolModule: public wxModule { + DECLARE_DYNAMIC_CLASS(wxProtocolModule) +public: + wxProtocolModule() {} + bool OnInit(); + void OnExit(); +}; + +IMPLEMENT_DYNAMIC_CLASS(wxProtocolModule, wxModule) + +bool wxProtocolModule::OnInit() +{ +#if wxUSE_SOCKETS + char *env_http_prox; + + wxURL::g_proxy = NULL; + // Initialize the proxy when HTTP_PROXY is defined + env_http_prox = getenv("HTTP_PROXY"); + if (env_http_prox) + wxURL::SetDefaultProxy(env_http_prox); +#endif + + return TRUE; +} + +void wxProtocolModule::OnExit() +{ +#if wxUSE_SOCKETS + if (wxURL::g_proxy) + delete wxURL::g_proxy; + wxURL::g_proxy = NULL; +#endif +} +