#if wxUSE_SOCKETS && wxUSE_STREAMS
+#include "wx/sckstrm.h"
+
#ifndef WX_PRECOMP
+ #include "wx/stream.h"
#endif
-#include "wx/stream.h"
#include "wx/socket.h"
-#include "wx/sckstrm.h"
// ---------------------------------------------------------------------------
// wxSocketOutputStream
size_t wxSocketOutputStream::OnSysWrite(const void *buffer, size_t size)
{
- size_t ret = m_o_socket->Write((const char *)buffer, size).LastCount();
-
- m_lasterror = m_o_socket->Error() ? wxSTREAM_WRITE_ERROR : wxSTREAM_NO_ERROR;
-
+ const size_t ret = m_o_socket->Write(buffer, size).LastCount();
+ m_lasterror = m_o_socket->Error()
+ ? m_o_socket->IsClosed() ? wxSTREAM_EOF
+ : wxSTREAM_WRITE_ERROR
+ : wxSTREAM_NO_ERROR;
return ret;
}
size_t wxSocketInputStream::OnSysRead(void *buffer, size_t size)
{
- size_t ret = m_i_socket->Read((char *)buffer, size).LastCount();
-
- m_lasterror = m_i_socket->Error() ? wxSTREAM_READ_ERROR : wxSTREAM_NO_ERROR;
-
+ const size_t ret = m_i_socket->Read(buffer, size).LastCount();
+ m_lasterror = m_i_socket->Error()
+ ? m_i_socket->IsClosed() ? wxSTREAM_EOF
+ : wxSTREAM_READ_ERROR
+ : wxSTREAM_NO_ERROR;
return ret;
}
{
}
-#endif
- // wxUSE_STREAMS && wxUSE_SOCKETS
+#endif // wxUSE_STREAMS && wxUSE_SOCKETS