wxStreamBuffer::wxStreamBuffer(wxStreamBase& stream, BufMode mode)
: m_buffer_start(NULL), m_buffer_end(NULL), m_buffer_pos(NULL),
- m_buffer_size(0), m_fixed(TRUE), m_flushable(TRUE), m_stream(&stream),
+ m_buffer_size(0), m_wback(NULL), m_wbacksize(0), m_wbackcur(0),
+ m_fixed(TRUE), m_flushable(TRUE), m_stream(&stream),
m_mode(mode), m_destroybuf(FALSE), m_destroystream(FALSE)
{
}
wxStreamBuffer::wxStreamBuffer(BufMode mode)
: m_buffer_start(NULL), m_buffer_end(NULL), m_buffer_pos(NULL),
- m_buffer_size(0), m_fixed(TRUE), m_flushable(FALSE), m_stream(NULL),
+ m_buffer_size(0), m_wback(NULL), m_wbacksize(0), m_wbackcur(0),
+ m_fixed(TRUE), m_flushable(FALSE), m_stream(NULL),
m_mode(mode), m_destroybuf(FALSE), m_destroystream(TRUE)
{
m_stream = new wxStreamBase();
m_mode = buffer.m_mode;
m_destroybuf = FALSE;
m_destroystream = FALSE;
+ m_wback = NULL;
+ m_wbacksize = 0;
+ m_wbackcur = 0;
}
wxStreamBuffer::~wxStreamBuffer()
{
+ if (m_wback)
+ free(m_wback);
if (m_destroybuf)
wxDELETEA(m_buffer_start);
if (m_destroystream)
{
char *ptrback;
+ if (m_mode != read)
+ return 0;
+
ptrback = AllocSpaceWBack(bufsize);
if (!ptrback)
return 0;
void wxStreamBuffer::ResetBuffer()
{
+ m_stream->m_lasterror = wxStream_NOERROR;
+ m_stream->m_lastcount = 0;
if (m_mode == read)
m_buffer_pos = m_buffer_end;
else
if (!temp_b)
return NULL;
- return (char *)((size_t)m_wback+(m_wbacksize-needed_size));
+ m_wback = temp_b;
+
+ return (char *)(m_wback+(m_wbacksize-needed_size));
}
size_t wxStreamBuffer::GetWBack(char *buf, size_t bsize)
return;
}
- if (!GetDataLeft() && !FlushBuffer()) {
- CHECK_ERROR(wxStream_READ_ERR);
+ if (GetDataLeft() == 0 && !FlushBuffer()) {
+ CHECK_ERROR(wxStream_WRITE_ERR);
return;
}
{
wxASSERT(m_stream != NULL);
+ if (m_mode == write)
+ return 0;
+
// ------------------
// Buffering disabled
// ------------------
+ m_stream->m_lasterror = wxStream_NOERROR;
m_stream->m_lastcount = GetWBack((char *)buffer, size);
size -= m_stream->m_lastcount;
if (size == 0)
char buf[BUF_TEMP_SIZE];
size_t s = 0, bytes_read = BUF_TEMP_SIZE;
+ if (m_mode == write)
+ return 0;
+
while (bytes_read == BUF_TEMP_SIZE) {
bytes_read = Read(buf, bytes_read);
bytes_read = s_buf->Write(buf, bytes_read);
{
wxASSERT(m_stream != NULL);
+ if (m_mode == read)
+ return 0;
+
// ------------------
// Buffering disabled
// ------------------
+ m_stream->m_lasterror = wxStream_NOERROR;
if (!m_buffer_size)
return (m_stream->m_lastcount = m_stream->OnSysWrite(buffer, size));
size_t wxStreamBuffer::Write(wxStreamBuffer *sbuf)
{
char buf[BUF_TEMP_SIZE];
- size_t s = 0, bytes_count = BUF_TEMP_SIZE;
- size_t s_size;
+ size_t s = 0, bytes_count = BUF_TEMP_SIZE, b_count2;
+
+ if (m_mode == read)
+ return 0;
while (bytes_count == BUF_TEMP_SIZE) {
- s_size = (sbuf->GetDataLeft() < GetDataLeft()) ? sbuf->GetDataLeft() : GetDataLeft();
- if (s_size < bytes_count)
- bytes_count = s_size;
- bytes_count = sbuf->Read(buf, bytes_count);
- bytes_count = Write(buf, bytes_count);
+ b_count2 = sbuf->Read(buf, bytes_count);
+ bytes_count = Write(buf, b_count2);
+ if (b_count2 > bytes_count)
+ sbuf->WriteBack(buf+bytes_count, b_count2-bytes_count);
s += bytes_count;
}
return s;