80 lines
1.3 KiB
C++
80 lines
1.3 KiB
C++
#include "CBufferedOutputStream.h"
|
|
#include "CLock.h"
|
|
#include "CMutex.h"
|
|
#include "CThread.h"
|
|
#include "IJob.h"
|
|
#include "XIO.h"
|
|
#include <assert.h>
|
|
|
|
//
|
|
// CBufferedOutputStream
|
|
//
|
|
|
|
CBufferedOutputStream::CBufferedOutputStream(CMutex* mutex, IJob* closeCB) :
|
|
m_mutex(mutex),
|
|
m_closeCB(closeCB),
|
|
m_closed(false)
|
|
{
|
|
assert(m_mutex != NULL);
|
|
}
|
|
|
|
CBufferedOutputStream::~CBufferedOutputStream()
|
|
{
|
|
delete m_closeCB;
|
|
}
|
|
|
|
const void* CBufferedOutputStream::peek(UInt32 n) throw()
|
|
{
|
|
return m_buffer.peek(n);
|
|
}
|
|
|
|
void CBufferedOutputStream::pop(UInt32 n) throw()
|
|
{
|
|
m_buffer.pop(n);
|
|
}
|
|
|
|
UInt32 CBufferedOutputStream::getSize() const throw()
|
|
{
|
|
return m_buffer.getSize();
|
|
}
|
|
|
|
void CBufferedOutputStream::close() throw(XIO)
|
|
{
|
|
CLock lock(m_mutex);
|
|
if (m_closed) {
|
|
throw XIOClosed();
|
|
}
|
|
|
|
m_closed = true;
|
|
if (m_closeCB) {
|
|
m_closeCB->run();
|
|
}
|
|
}
|
|
|
|
UInt32 CBufferedOutputStream::write(
|
|
const void* data, UInt32 n) throw(XIO)
|
|
{
|
|
CLock lock(m_mutex);
|
|
if (m_closed) {
|
|
throw XIOClosed();
|
|
}
|
|
|
|
m_buffer.write(data, n);
|
|
return n;
|
|
}
|
|
|
|
void CBufferedOutputStream::flush() throw(XIO)
|
|
{
|
|
// wait until all data is written
|
|
while (getSizeWithLock() > 0) {
|
|
CThread::sleep(0.05);
|
|
}
|
|
}
|
|
|
|
UInt32 CBufferedOutputStream::getSizeWithLock() const throw()
|
|
{
|
|
CLock lock(m_mutex);
|
|
return m_buffer.getSize();
|
|
}
|
|
|