#include "wx/wxprec.h"
#ifdef __BORLANDC__
-#pragma hdrstop
+ #pragma hdrstop
#endif
-#if wxUSE_SOCKETS
-
#ifndef WX_PRECOMP
+ #include "wx/defs.h"
#endif
+#if wxUSE_SOCKETS && wxUSE_STREAMS
+
#include "wx/stream.h"
#include "wx/socket.h"
#include "wx/sckstrm.h"
{
}
-wxOutputStream& wxSocketOutputStream::Write(const void *buffer, size_t size)
-{
- m_lastcount = m_o_socket->Write((const char *)buffer, size).LastCount();
- return *this;
-}
-
size_t wxSocketOutputStream::OnSysWrite(const void *buffer, size_t size)
{
- return m_o_socket->Write((const char *)buffer, size).LastCount();
+ size_t ret;
+
+ ret = m_o_socket->Write((const char *)buffer, size).LastCount();
+ switch (m_o_socket->LastError()) {
+ case GSOCK_NOERROR:
+ m_lasterror = wxStream_NOERROR;
+ break;
+ default:
+ m_lasterror = wxStream_READ_ERR;
+ break;
+ }
+ return ret;
+
}
// ---------------------------------------------------------------------------
{
}
-wxInputStream& wxSocketInputStream::Read(void *buffer, size_t size)
-{
- m_lastcount = m_i_socket->Read((char *)buffer, size).LastCount();
- return *this;
-}
-
size_t wxSocketInputStream::OnSysRead(void *buffer, size_t size)
{
- return m_i_socket->Read((char *)buffer, size).LastCount();
+ size_t ret;
+
+ ret = m_i_socket->Read((char *)buffer, size).LastCount();
+ switch (m_i_socket->LastError()) {
+ case GSOCK_NOERROR:
+ m_lasterror = wxStream_NOERROR;
+ break;
+ default:
+ m_lasterror = wxStream_WRITE_ERR;
+ break;
+ }
+ return ret;
}
// ---------------------------------------------------------------------------
}
#endif
+ // wxUSE_STREAMS && wxUSE_SOCKETS