stream_reader_buffered

#include <stream_buffer_helper.h>

Inheritance diagram for stream_reader_buffered:

Public Member Functions
	stream_reader_buffered (stream_reader *p_base, t_size p_buffer)
t_size	read (void *p_buffer, t_size p_bytes, abort_callback &p_abort)

Private Attributes
stream_reader *	m_base
pfc::array_t< char >	m_buffer
const char *	m_bufferPtr
size_t	m_bufferRemaining

Detailed Description

Definition at line 1 of file stream_buffer_helper.h.

Constructor & Destructor Documentation

stream_reader_buffered::stream_reader_buffered	(	stream_reader *	p_base,
		t_size	p_buffer
	)

Definition at line 3 of file stream_buffer_helper.cpp.

                                                                                     : m_base(p_base)
{
    m_buffer.set_size_in_range(pfc::min_t<size_t>(1024, p_buffer), p_buffer);
    m_bufferRemaining = 0;
}

Member Function Documentation

t_size stream_reader_buffered::read	(	void *	p_buffer,
		t_size	p_bytes,
		abort_callback &	p_abort
	)

Definition at line 9 of file stream_buffer_helper.cpp.

                                                                                           {
    if (p_bytes <= m_bufferRemaining) {
        memcpy( p_buffer, m_bufferPtr, p_bytes );
        m_bufferRemaining -= p_bytes;
        m_bufferPtr += p_bytes;
        return p_bytes;
    }
    
    p_abort.check();
    char * output = (char*) p_buffer;
    t_size output_ptr = 0;

    while(output_ptr < p_bytes) {
        {
            t_size delta = pfc::min_t(p_bytes - output_ptr, m_bufferRemaining);
            if (delta > 0)
            {
                memcpy(output + output_ptr, m_bufferPtr, delta);
                output_ptr += delta;
                m_bufferPtr += delta;
                m_bufferRemaining -= delta;
            }
        }

        if (m_bufferRemaining == 0)
        {
            t_size bytes_read;
            bytes_read = m_base->read(m_buffer.get_ptr(), m_buffer.get_size(), p_abort);
            m_bufferPtr = m_buffer.get_ptr();
            m_bufferRemaining = bytes_read;

            if (m_bufferRemaining == 0) break;
        }
        
    }       

    return output_ptr;
}

Field Documentation

stream_reader* stream_reader_buffered::m_base

private

Definition at line 7 of file stream_buffer_helper.h.

pfc::array_t<char> stream_reader_buffered::m_buffer

private

Definition at line 8 of file stream_buffer_helper.h.

const char* stream_reader_buffered::m_bufferPtr

private

Definition at line 9 of file stream_buffer_helper.h.

size_t stream_reader_buffered::m_bufferRemaining

private

Definition at line 10 of file stream_buffer_helper.h.

---

The documentation for this class was generated from the following files:

• foobar2000/helpers/stream_buffer_helper.h
• foobar2000/helpers/stream_buffer_helper.cpp