barrier/io/CBufferedInputStream.h

52 lines
1.2 KiB
C
Raw Normal View History

2001-10-06 14:13:28 +00:00
#ifndef CBUFFEREDINPUTSTREAM_H
#define CBUFFEREDINPUTSTREAM_H
#include "CStreamBuffer.h"
#include "CCondVar.h"
#include "IInputStream.h"
class CMutex;
class IJob;
class CBufferedInputStream : public IInputStream {
public:
CBufferedInputStream(CMutex*, IJob* adoptedCloseCB);
~CBufferedInputStream();
// the caller is expected to lock the mutex before calling
// methods unless otherwise noted.
// manipulators
// write() appends n bytes to the buffer
void write(const void*, UInt32 n);
2001-10-06 14:13:28 +00:00
// causes read() to always return immediately. if there is no
// more data then it returns 0. further writes are discarded.
void hangup();
2001-10-06 14:13:28 +00:00
// same as read() but caller must lock the mutex
UInt32 readNoLock(void*, UInt32 count);
2001-10-06 14:13:28 +00:00
// accessors
// same as getSize() but caller must lock the mutex
UInt32 getSizeNoLock() const;
2001-10-06 14:13:28 +00:00
// IInputStream overrides
// these all lock the mutex for their duration
virtual void close();
virtual UInt32 read(void*, UInt32 count);
virtual UInt32 getSize() const;
2001-10-06 14:13:28 +00:00
private:
CMutex* m_mutex;
CCondVar<bool> m_empty;
IJob* m_closeCB;
CStreamBuffer m_buffer;
bool m_closed;
bool m_hungup;
};
#endif