#pragma hdrstop
#endif
-#if wxUSE_SOCKETS
+#if wxUSE_SOCKETS && wxUSE_STREAMS
#include <stdio.h>
#include <stdlib.h>
m_read = FALSE;
m_proxy_mode = FALSE;
- SetNotify(GSOCK_LOST_FLAG);
+ SetNotify(wxSOCKET_LOST_FLAG);
}
wxHTTP::~wxHTTP()
delete string;
node = node->Next();
}
+
+ if (m_addr) {
+ delete m_addr;
+ m_addr = NULL;
+ }
}
wxString wxHTTP::GetContentType()
wxString *str = (wxString *)head->Data();
wxString buf;
- buf.Printf(wxT("%s: %s\n\r"), head->GetKeyString(), str->GetData());
+ buf.Printf(wxT("%s: %s\r\n"), head->GetKeyString(), str->GetData());
const wxWX2MBbuf cbuf = buf.mb_str();
Write(cbuf, strlen(cbuf));
if (line.Length() == 0)
break;
- tokenzr.SetString(line, " :\t\n\r");
- if (!tokenzr.HasMoreTokens())
- return FALSE;
-
- wxString left_str = tokenzr.GetNextToken();
- wxString *str = new wxString(tokenzr.GetNextToken());
-
+ wxString left_str = line.BeforeFirst(':');
+ wxString *str = new wxString(line.AfterFirst(':').Strip(wxString::both));
left_str.MakeUpper();
m_headers.Append(left_str, (wxObject *) str);
}
SaveState();
- SetFlags(NONE);
+ SetFlags(wxSOCKET_NONE);
Notify(FALSE);
- wxSprintf(buf, wxT("%s %s HTTP/1.0\n\r"), tmp_buf, tmp_str.GetData());
+ wxSprintf(buf, wxT("%s %s HTTP/1.0\r\n"), tmp_buf, tmp_str.GetData());
const wxWX2MBbuf pathbuf = wxConvLibc.cWX2MB(buf);
Write(pathbuf, strlen(wxMBSTRINGCAST pathbuf));
SendHeaders();
- Write("\n\r", 2);
+ Write("\r\n", 2);
m_perr = GetLine(this, tmp_str);
if (m_perr != wxPROTO_NOERR) {
return ret_value;
}
-class wxHTTPStream : public wxSocketInputStream {
+class wxHTTPStream : public wxSocketInputStream
+{
public:
wxHTTP *m_http;
size_t m_httpsize;
bool wxHTTP::Abort(void)
{
- bool ret;
-
- ret = wxSocketClient::Close();
-
- return ret;
+ return wxSocketClient::Close();
}
wxInputStream *wxHTTP::GetInputStream(const wxString& path)
{
- wxHTTPStream *inp_stream = new wxHTTPStream(this);
+ wxHTTPStream *inp_stream;
+
wxString new_path;
m_perr = wxPROTO_CONNERR;
return NULL;
// We set m_connected back to FALSE so wxSocketBase will know what to do.
+#ifdef __WXMAC__
+ wxSocketClient::Connect(*m_addr , FALSE );
+ wxSocketClient::WaitOnConnect(10);
+
+ if (!wxSocketClient::IsConnected())
+ return NULL;
+#else
if (!wxProtocol::Connect(*m_addr))
return NULL;
+#endif
if (!BuildRequest(path, wxHTTP_GET))
return NULL;
+ inp_stream = new wxHTTPStream(this);
+
if (!GetHeader(wxT("Content-Length")).IsEmpty())
inp_stream->m_httpsize = wxAtoi(WXSTRINGCAST GetHeader(wxT("Content-Length")));
else
inp_stream->m_read_bytes = 0;
Notify(FALSE);
- SetFlags(SPEED | WAITALL);
+ SetFlags(wxSOCKET_BLOCK | wxSOCKET_WAITALL);
return inp_stream;
}