1 files changed, 108 insertions, 6 deletions
diff --git a/engines/gargoyle/stream.cpp b/engines/gargoyle/stream.cpp
index a08579a97d..c447646638 100644
--- a/engines/gargoyle/stream.cpp
+++ b/engines/gargoyle/stream.cpp
@@ -21,19 +21,121 @@
  */
 
 #include "gargoyle/stream.h"
+#include "gargoyle/windows.h"
 
 namespace Gargoyle {
 
-uint32 WindowStream::write(const void *dataPtr, uint32 dataSize) {
-	// TODO
-	return dataSize;
+Stream::Stream(bool readable, bool writable, uint32 rock, bool unicode) :
+		_readable(readable), _writable(writable), _readCount(0), _writeCount(0),
+		_prev(nullptr), _next(nullptr), _rock(0) {
 }
 
-bool WindowStream::flush() {
-	// TODO
-	return true;
+Stream *Stream::getNext(uint32 *rock) const {
+	Stream *stream = _next;
+	if (rock)
+		*rock = stream ? stream->_rock : 0;
+	return stream;
 }
 
+void Stream::fillResult(StreamResult *result) {
+	if (result) {
+		result->_readCount = _readCount;
+		result->_writeCount = _writeCount;
+	}
+}
+
+void Stream::close(StreamResult *result) {
+	fillResult(result);
+
+}
+
+/*--------------------------------------------------------------------------*/
+
+void WindowStream::writeChar(unsigned char ch) {
+
+}
+
+void WindowStream::writeCharUni(uint32 ch) {
+
+}
+
+/*--------------------------------------------------------------------------*/
+
+MemoryStream::MemoryStream(void *buf, size_t buflen, FileMode mode, uint32 rock, bool unicode) :
+		Stream(mode != filemode_Write, mode != filemode_Read, rock, unicode),
+		_buf(buf), _buflen(buflen), _bufptr(buf) {
+	assert(_buf && _buflen);
+	assert(mode == filemode_Read || mode == filemode_Write || mode == filemode_ReadWrite);
+
+	if (unicode)
+		_bufend = (uint32 *)buf + buflen;
+	else
+		_bufend = (byte *)buf + buflen;
+	_bufeof = mode == filemode_Write ? _buf : _bufend;
+}
+
+void MemoryStream::writeChar(unsigned char ch) {
+
+}
+
+void MemoryStream::writeCharUni(uint32 ch) {
+
+}
+
+/*--------------------------------------------------------------------------*/
+
+/*--------------------------------------------------------------------------*/
+
+/*--------------------------------------------------------------------------*/
+
+Streams::Streams() : _streamList(nullptr) {}
+
+Streams::~Streams() {
+	while (_streamList)
+		deleteStream(_streamList);
+}
+
+WindowStream *Streams::addWindowStream(Window *window) {
+	WindowStream *stream = new WindowStream(window);
+	addStream(stream);
+	return stream;
+}
+
+MemoryStream *Streams::addMemoryStream(void *buf, size_t buflen, FileMode mode, uint32 rock, bool unicode) {
+	MemoryStream *stream = new MemoryStream(buf, buflen, mode, rock, unicode);
+	addStream(stream);
+	return stream;
+}
+
+void Streams::addStream(Stream *stream) {
+	stream->_next = _streamList;
+	_streamList = stream;
+	if (stream->_next)
+		stream->_next->_prev = stream;
+}
+
+void Streams::deleteStream(Stream *stream) {
+	Stream *prev = stream->_prev;
+	Stream *next = stream->_next;
+
+	if (prev)
+		prev->_next = next;
+	else
+		_streamList = next;
+	if (next)
+		next->_prev = prev;
+
+	delete stream;
+}
+
+Stream *Streams::getFirst(uint32 *rock) {
+	if (rock)
+		*rock = _streamList ? _streamList->_rock : 0;
+	return _streamList;
+}
+
+/*--------------------------------------------------------------------------*/
+
 size_t strlen_uni(const uint32 *s) {
 	size_t len = 0;
 	while (*s++)