Revision 5e0a226b69ca527445706fcba03a42877ba71c8e authored by Paweł Kołodziejski on 28 July 2007, 22:10:30 UTC, committed by Paweł Kołodziejski on 28 July 2007, 22:10:30 UTC
svn-id: r28279
1 parent df41a5f
stream.cpp
/* ScummVM - Graphic Adventure Engine
*
* ScummVM is the legal property of its developers, whose names
* are too numerous to list here. Please refer to the COPYRIGHT
* file distributed with this source distribution.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version 2
* of the License, or (at your option) any later version.
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
*
* $URL$
* $Id$
*
*/
#include "common/stdafx.h"
#include "common/stream.h"
#include "common/str.h"
#include "common/util.h"
namespace Common {
void WriteStream::writeString(const String &str) {
write(str.c_str(), str.size());
}
MemoryReadStream *ReadStream::readStream(uint32 dataSize) {
void *buf = malloc(dataSize);
dataSize = read(buf, dataSize);
assert(dataSize > 0);
return new MemoryReadStream((byte *)buf, dataSize, true);
}
uint32 MemoryReadStream::read(void *dataPtr, uint32 dataSize) {
// Read at most as many bytes as are still available...
if (dataSize > _size - _pos)
dataSize = _size - _pos;
memcpy(dataPtr, _ptr, dataSize);
if (_encbyte) {
byte *p = (byte *)dataPtr;
byte *end = p + dataSize;
while (p < end)
*p++ ^= _encbyte;
}
_ptr += dataSize;
_pos += dataSize;
return dataSize;
}
void MemoryReadStream::seek(int32 offs, int whence) {
// Pre-Condition
assert(_pos <= _size);
switch (whence) {
case SEEK_END:
// SEEK_END works just like SEEK_SET, only 'reversed',
// i.e. from the end.
offs = _size - offs;
// Fall through
case SEEK_SET:
_ptr = _ptrOrig + offs;
_pos = offs;
break;
case SEEK_CUR:
_ptr += offs;
_pos += offs;
break;
}
// Post-Condition
assert(_pos <= _size);
}
#define LF 0x0A
#define CR 0x0D
char *SeekableReadStream::readLine(char *buf, size_t bufSize) {
assert(buf && bufSize > 0);
char *p = buf;
size_t len = 0;
char c;
if (buf == 0 || bufSize == 0 || eos()) {
return 0;
}
// We don't include the newline character(s) in the buffer, and we
// always terminate it - we never read more than len-1 characters.
// EOF is treated as a line break, unless it was the first character
// that was read.
// 0 is treated as a line break, even though it should never occur in
// a text file.
// DOS and Windows use CRLF line breaks
// Unix and OS X use LF line breaks
// Macintosh before OS X uses CR line breaks
c = readByte();
if (eos() || ioFailed()) {
return 0;
}
while (!eos() && len + 1 < bufSize) {
if (ioFailed())
return 0;
if (c == 0 || c == LF)
break;
if (c == CR) {
c = readByte();
if (c != LF && !eos())
seek(-1, SEEK_CUR);
break;
}
*p++ = c;
len++;
c = readByte();
}
// This should fix a bug while using readLine with Common::File
// it seems that it sets the eos flag after an invalid read
// and at the same time the ioFailed flag
// the config file parser fails out of that reason for the new themes
if (eos()) {
clearIOFailed();
}
*p = 0;
return buf;
}
uint32 SubReadStream::read(void *dataPtr, uint32 dataSize) {
dataSize = MIN(dataSize, _end - _pos);
dataSize = _parentStream->read(dataPtr, dataSize);
_pos += dataSize;
return dataSize;
}
SeekableSubReadStream::SeekableSubReadStream(SeekableReadStream *parentStream, uint32 begin, uint32 end, bool disposeParentStream)
: SubReadStream(parentStream, end, disposeParentStream),
_parentStream(parentStream),
_begin(begin) {
assert(_begin <= _end);
_pos = _begin;
_parentStream->seek(_pos);
}
void SeekableSubReadStream::seek(int32 offset, int whence) {
assert(_pos >= _begin);
assert(_pos <= _end);
switch(whence) {
case SEEK_END:
offset = size() - offset;
// fallthrough
case SEEK_SET:
_pos = _begin + offset;
break;
case SEEK_CUR:
_pos += offset;
}
assert(_pos >= _begin);
assert(_pos <= _end);
_parentStream->seek(_pos);
}
} // End of namespace Common
![swh spinner](/static/img/swh-spinner.gif)
Computing file changes ...