/* 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/endian.h" #include "common/system.h" #include "graphics/dither.h" #include "gob/coktelvideo.h" #include "gob/indeo3.h" namespace Gob { Imd::Imd() { clear(false); } Imd::~Imd() { clear(); } bool Imd::load(Common::SeekableReadStream &stream) { unload(); _stream = &stream; // Version uint16 handle = _stream->readUint16LE(); _version = _stream->readByte(); // Version checking if ((handle != 0) || (_version < 2)) { warning("IMD Version incorrect (%d,%X)", handle, _version); unload(); return false; } // Rest header _features = _stream->readByte(); _framesCount = _stream->readUint16LE(); _x = _stream->readSint16LE(); _y = _stream->readSint16LE(); _width = _stream->readSint16LE(); _height = _stream->readSint16LE(); _flags = _stream->readUint16LE(); _firstFramePos = _stream->readUint16LE(); // IMDs always have video _features |= kFeaturesVideo; // IMDs always have palettes _features |= kFeaturesPalette; // Palette _stream->read((byte *) _palette, 768); // Standard coordinates if (_version >= 3) { _stdX = _stream->readUint16LE(); if (_stdX > 1) { warning("IMD: More than one standard coordinate quad found (%d)", _stdX); unload(); return false; } if (_stdX != 0) { _stdX = _stream->readSint16LE(); _stdY = _stream->readSint16LE(); _stdWidth = _stream->readSint16LE(); _stdHeight = _stream->readSint16LE(); _features |= kFeaturesStdCoords; } else _stdX = -1; } else _stdX = -1; // Offset to frame positions table uint32 framesPosPos = 0; if (_version >= 4) { framesPosPos = _stream->readUint32LE(); if (framesPosPos != 0) { _framesPos = new uint32[_framesCount]; assert(_framesPos); _features |= kFeaturesFramesPos; } } // Offset to frame coordinates uint32 framesCoordsPos = 0; if (_features & kFeaturesFrameCoords) framesCoordsPos = _stream->readUint32LE(); // Sound if (_features & kFeaturesSound) { _soundFreq = _stream->readSint16LE(); _soundSliceSize = _stream->readSint16LE(); _soundSlicesCount = _stream->readSint16LE(); if (_soundFreq < 0) _soundFreq = -_soundFreq; if (_soundSlicesCount < 0) _soundSlicesCount = -_soundSlicesCount - 1; if (_soundSlicesCount > 40) { warning("IMD: More than 40 sound slices found (%d)", _soundSlicesCount); unload(); return false; } _soundSliceLength = (uint32) (((double) (1000 << 16)) / ((double) _soundFreq / (double) _soundSliceSize)); _frameLength = _soundSliceLength >> 16; _soundStage = 1; _hasSound = true; _audioStream = Audio::makeAppendableAudioStream(_soundFreq, 0); } else _frameLength = 1000 / _frameRate; // Sizes of the frame data and extra video buffer if (_features & kFeaturesDataSize) { _frameDataSize = _stream->readUint16LE(); if (_frameDataSize == 0) { _frameDataSize = _stream->readUint32LE(); _vidBufferSize = _stream->readUint32LE(); } else _vidBufferSize = _stream->readUint16LE(); } else { _frameDataSize = _width * _height + 500; if (!(_flags & 0x100) || (_flags & 0x1000)) _vidBufferSize = _frameDataSize; } // Frame positions table if (_framesPos) { _stream->seek(framesPosPos, SEEK_SET); for (int i = 0; i < _framesCount; i++) _framesPos[i] = _stream->readUint32LE(); } // Frame coordinates table if (_features & kFeaturesFrameCoords) { _stream->seek(framesCoordsPos, SEEK_SET); _frameCoords = new Coord[_framesCount]; assert(_frameCoords); for (int i = 0; i < _framesCount; i++) { _frameCoords[i].left = _stream->readSint16LE(); _frameCoords[i].top = _stream->readSint16LE(); _frameCoords[i].right = _stream->readSint16LE(); _frameCoords[i].bottom = _stream->readSint16LE(); } } // Seek to the first frame _stream->seek(_firstFramePos, SEEK_SET); // Allocating working memory _frameData = new byte[_frameDataSize + 500]; assert(_frameData); memset(_frameData, 0, _frameDataSize + 500); _vidBuffer = new byte[_vidBufferSize + 500]; assert(_vidBuffer); memset(_vidBuffer, 0, _vidBufferSize + 500); return true; } void Imd::unload() { clear(); } void Imd::setFrameRate(int16 frameRate) { if (frameRate == 0) frameRate = 1; _frameRate = frameRate; _frameLength = 1000 / _frameRate; } void Imd::setXY(int16 x, int16 y) { // Adjusting the standard coordinates if (_stdX != -1) { if (x >= 0) _stdX = _stdX - _x + x; if (y >= 0) _stdY = _stdY - _y + y; } // Going through the coordinate table as well if (_frameCoords) { for (int i = 0; i < _framesCount; i++) { if (_frameCoords[i].left != -1) { if (x >= 0) { _frameCoords[i].left = _frameCoords[i].left - _x + x; _frameCoords[i].right = _frameCoords[i].right - _x + x; } if (y >= 0) { _frameCoords[i].top = _frameCoords[i].top - _y + y; _frameCoords[i].bottom = _frameCoords[i].bottom - _y + y; } } } } if (x >= 0) _x = x; if (y >= 0) _y = y; } void Imd::setVideoMemory(byte *vidMem, uint16 width, uint16 height) { deleteVidMem(); _hasOwnVidMem = false; _vidMem = vidMem; _vidMemWidth = width; _vidMemHeight = height; } void Imd::setVideoMemory() { deleteVidMem(); if ((_width > 0) && (_height > 0)) { setXY(0, 0); _hasOwnVidMem = true; _vidMem = new byte[_width * _height]; _vidMemWidth = _width; _vidMemHeight = _height; } } void Imd::enableSound(Audio::Mixer &mixer) { // Only possible on the first frame if (_curFrame > 0) return; _mixer = &mixer; _soundEnabled = true; } void Imd::disableSound() { if (_audioStream) { if (_soundStage == 2) { _audioStream->finish(); _mixer->stopHandle(_audioHandle); } else delete _audioStream; _audioStream = 0; _soundStage = 0; } _soundEnabled = false; _mixer = 0; } bool Imd::isSoundPlaying() const { if (_audioStream && _mixer->isSoundHandleActive(_audioHandle)) return true; return false; } void Imd::seekFrame(int32 frame, int16 whence, bool restart) { if (!_stream) // Nothing to do return; // Find the frame to which to seek if (whence == SEEK_CUR) frame += _curFrame; else if (whence == SEEK_END) frame = _framesCount - frame - 1; else if (whence != SEEK_SET) return; if ((frame < 0) || (frame >= _framesCount) || (frame == _curFrame)) // Nothing to do return; // Try every possible way to find a file offset to that frame uint32 framePos = 0; if (frame == 0) { framePos = _firstFramePos; } else if (frame == 1) { framePos = _firstFramePos; _stream->seek(framePos, SEEK_SET); framePos += _stream->readUint16LE() + 4; } else if (_framesPos) { framePos = _framesPos[frame]; } else if (restart && (_soundStage == 0)) { for (int i = ((frame > _curFrame) ? _curFrame : 0); i <= frame; i++) processFrame(i); } else error("Frame %d is not directly accessible", frame); // Seek _stream->seek(framePos); _curFrame = frame; } CoktelVideo::State Imd::nextFrame() { return processFrame(_curFrame); } void Imd::waitEndFrame() { if (_soundEnabled && _hasSound) { if (_soundStage != 2) return; if (_skipFrames == 0) { int32 waitTime = (int16) (((_curFrame * _soundSliceLength) - (_mixer->getSoundElapsedTime(_audioHandle) << 16)) >> 16); if (waitTime < 0) { _skipFrames = -waitTime / (_soundSliceLength >> 16); warning("Video A/V sync broken, skipping %d frame(s)", _skipFrames + 1); } else if (waitTime > 0) g_system->delayMillis(waitTime); } else _skipFrames--; } else g_system->delayMillis(_frameLength); } void Imd::copyCurrentFrame(byte *dest, uint16 left, uint16 top, uint16 width, uint16 height, uint16 x, uint16 y, uint16 pitch, int16 transp) { if (!_vidMem) return; if (((left + width) > _width) || ((top + height) > _height)) return; dest += pitch * y; byte *vidMem = _vidMem + _width * top; if (transp < 0) { // No transparency if ((x > 0) || (left > 0) || (pitch != _width) || (width != _width)) { // Copy row-by-row for (int i = 0; i < height; i++) { byte *d = dest + x; byte *s = vidMem + left; memcpy(d, s, width); dest += pitch; vidMem += _width; } } else // Dimensions fit, copy everything at once memcpy(dest, vidMem, width * height); return; } for (int i = 0; i < height; i++) { byte *d = dest + x; byte *s = vidMem + left; for (int j = 0; j < width; j++) { if (*s != transp) *d = *s; s++; d++; } dest += pitch; vidMem += _width; } } void Imd::deleteVidMem(bool del) { if (del) { if (_hasOwnVidMem) delete[] _vidMem; } _hasOwnVidMem = false; _vidMem = 0; _vidMemWidth = _vidMemHeight = 0; } void Imd::clear(bool del) { if (del) { delete[] _framesPos; delete[] _frameCoords; delete[] _frameData; delete[] _vidBuffer; disableSound(); } _stream = 0; _version = 0; _features = 0; _flags = 0; _x = _y = _width = _height = 0; _stdX = _stdY = _stdWidth = _stdHeight = 0; _framesCount = _curFrame = 0; _framesPos = 0; _firstFramePos = 0; _frameCoords = 0; _frameDataSize = _vidBufferSize = 0; _frameData = _vidBuffer = 0; _frameDataLen = 0; memset(_palette, 0, 768); deleteVidMem(del); _hasSound = false; _soundEnabled = false; _soundStage = 0; _skipFrames = 0; _soundFlags = 0; _soundFreq = 0; _soundSliceSize = 0; _soundSlicesCount = 0; _soundSliceLength = 0; _audioStream = 0; _frameRate = 12; _frameLength = 0; _lastFrameTime = 0; } CoktelVideo::State Imd::processFrame(uint16 frame) { State state; uint32 cmd = 0; bool hasNextCmd = false; bool startSound = false; if (!_stream || (frame >= _framesCount)) { state.flags = kStateBreak; return state; } if (frame != _curFrame) { state.flags |= kStateSeeked; seekFrame(frame); } if (!_vidMem) setVideoMemory(); state.left = _x; state.top = _y; state.right = _width + state.left - 1; state.bottom = _height + state.top - 1; do { if (frame != 0) { if (_stdX != -1) { state.left = _stdX; state.top = _stdY; state.right = _stdWidth + state.left - 1; state.bottom = _stdHeight + state.top - 1; state.flags |= kStateStdCoords; } if (_frameCoords && (_frameCoords[frame].left != -1)) { state.left = _frameCoords[frame].left; state.top = _frameCoords[frame].top; state.right = _frameCoords[frame].right; state.bottom = _frameCoords[frame].bottom; state.flags |= kStateFrameCoords; } } cmd = _stream->readUint16LE(); if ((cmd & 0xFFF8) == 0xFFF0) { if (cmd == 0xFFF0) { _stream->seek(2, SEEK_CUR); cmd = _stream->readUint16LE(); } if (cmd == 0xFFF1) { state.flags = kStateBreak; continue; } else if (cmd == 0xFFF2) { // Skip (16 bit) cmd = _stream->readUint16LE(); _stream->seek(cmd, SEEK_CUR); state.flags = kStateBreak; continue; } else if (cmd == 0xFFF3) { // Skip (32 bit) cmd = _stream->readUint32LE(); _stream->seek(cmd, SEEK_CUR); state.flags = kStateBreak; continue; } } if (_soundStage != 0) { byte *soundBuf; // Next sound slice data if (cmd == 0xFF00) { if (!hasNextCmd && _soundEnabled) { soundBuf = new byte[_soundSliceSize]; assert(soundBuf); _stream->read(soundBuf, _soundSliceSize); unsignedToSigned(soundBuf, _soundSliceSize); _audioStream->queueBuffer(soundBuf, _soundSliceSize); } else _stream->seek(_soundSliceSize, SEEK_CUR); cmd = _stream->readUint16LE(); // Initial sound data (all slices) } else if (cmd == 0xFF01) { int dataLength = _soundSliceSize * _soundSlicesCount; if (!hasNextCmd && _soundEnabled) { soundBuf = new byte[dataLength]; assert(soundBuf); _stream->read(soundBuf, dataLength); unsignedToSigned(soundBuf, dataLength); if (_soundStage == 1) startSound = true; _audioStream->queueBuffer(soundBuf, dataLength); } else _stream->seek(dataLength, SEEK_CUR); cmd = _stream->readUint16LE(); // Empty sound slice } else if (!hasNextCmd && (_soundEnabled)) { soundBuf = new byte[_soundSliceSize]; assert(soundBuf); memset(soundBuf, 0, _soundSliceSize); _audioStream->queueBuffer(soundBuf, _soundSliceSize); } } // Set palette if (cmd == 0xFFF4) { _stream->seek(2, SEEK_CUR); state.flags |= kStatePalette; _stream->read(_palette, 768); cmd = _stream->readUint16LE(); } hasNextCmd = false; // Jump to frame if (cmd == 0xFFFD) { frame = _stream->readSint16LE(); if (_framesPos) { _curFrame = frame; _stream->seek(_framesPos[frame], SEEK_SET); hasNextCmd = true; state.flags |= kStateJump; } } else if (cmd == 0xFFFC) { state.flags |= 1; cmd = _stream->readUint32LE(); _stream->read(_frameData, cmd + 2); _frameDataLen = cmd + 2; if (_vidMemWidth <= state.right) { state.left = 0; state.right -= state.left; } if (_vidMemWidth <= state.right) state.right = _vidMemWidth - 1; if (_vidMemHeight <= state.bottom) { state.top = 0; state.bottom -= state.top; } if (_vidMemHeight <= state.bottom) state.bottom = _vidMemHeight -1; state.flags |= renderFrame(state.left, state.top, state.right, state.bottom); state.flags |= _frameData[0]; // Frame video data } else if (cmd != 0) { _stream->read(_frameData, cmd + 2); _frameDataLen = cmd + 2; state.flags |= renderFrame(state.left, state.top, state.right, state.bottom); state.flags |= _frameData[0]; } else state.flags |= kStateNoVideoData; } while (hasNextCmd); if (startSound && _soundEnabled) { _mixer->playInputStream(Audio::Mixer::kSFXSoundType, &_audioHandle, _audioStream); _skipFrames = 0; _soundStage = 2; } _curFrame++; if ((_curFrame == _framesCount) && (_soundStage == 2)) { _audioStream->finish(); _mixer->stopHandle(_audioHandle); _audioStream = 0; _soundStage = 0; } _lastFrameTime = g_system->getMillis(); return state; } uint32 Imd::renderFrame(int16 left, int16 top, int16 right, int16 bottom) { if (!_frameData || !_vidMem || (_width <= 0) || (_height <= 0)) return 0; uint32 retVal = 0; int16 width = right - left + 1; int16 height = bottom - top + 1; int16 sW = _vidMemWidth; byte *dataPtr = _frameData; byte *imdVidMem = _vidMem + sW * top + left; byte *srcPtr; uint8 type = *dataPtr++; if (type & 0x10) { // Palette data // One byte index int index = *dataPtr++; // 16 entries with each 3 bytes (RGB) memcpy(_palette + index * 3, dataPtr, MIN((255 - index) * 3, 48)); retVal = kStatePalette; dataPtr += 48; type ^= 0x10; } srcPtr = dataPtr; if (type & 0x80) { // Frame data is compressed srcPtr = _vidBuffer; type &= 0x7F; if ((type == 2) && (width == sW)) { deLZ77(imdVidMem, dataPtr); return retVal; } else deLZ77(srcPtr, dataPtr); } uint16 pixCount, pixWritten; byte *imdVidMemBak; if (type == 2) { // Whole block for (int i = 0; i < height; i++) { memcpy(imdVidMem, srcPtr, width); srcPtr += width; imdVidMem += sW; } } else if (type == 1) { // Sparse block imdVidMemBak = imdVidMem; for (int i = 0; i < height; i++) { pixWritten = 0; while (pixWritten < width) { pixCount = *srcPtr++; if (pixCount & 0x80) { // Data pixCount = MIN((pixCount & 0x7F) + 1, width - pixWritten); memcpy(imdVidMem, srcPtr, pixCount); pixWritten += pixCount; imdVidMem += pixCount; srcPtr += pixCount; } else { // "Hole" pixCount = (pixCount + 1) % 256; pixWritten += pixCount; imdVidMem += pixCount; } } imdVidMemBak += sW; imdVidMem = imdVidMemBak; } } else if (type == 0x42) { // Whole quarter-wide block for (int i = 0; i < height; i++) { imdVidMemBak = imdVidMem; for (int j = 0; j < width; j += 4, imdVidMem += 4, srcPtr++) memset(imdVidMem, *srcPtr, 4); imdVidMemBak += sW; imdVidMem = imdVidMemBak; } } else if ((type & 0xF) == 2) { // Whole half-high block for (; height > 1; height -= 2, imdVidMem += sW + sW, srcPtr += width) { memcpy(imdVidMem, srcPtr, width); memcpy(imdVidMem + sW, srcPtr, width); } if (height == -1) memcpy(imdVidMem, srcPtr, width); } else { // Sparse half-high block imdVidMemBak = imdVidMem; for (int i = 0; i < height; i += 2) { pixWritten = 0; while (pixWritten < width) { pixCount = *srcPtr++; if (pixCount & 0x80) { // Data pixCount = MIN((pixCount & 0x7F) + 1, width - pixWritten); memcpy(imdVidMem, srcPtr, pixCount); memcpy(imdVidMem + sW, srcPtr, pixCount); pixWritten += pixCount; imdVidMem += pixCount; srcPtr += pixCount; } else { // "Hole" pixCount = (pixCount + 1) % 256; pixWritten += pixCount; imdVidMem += pixCount; } } imdVidMemBak += sW + sW; imdVidMem = imdVidMemBak; } } return retVal; } void Imd::deLZ77(byte *dest, byte *src) { int i; byte buf[4370]; uint16 chunkLength; uint32 frameLength; uint16 bufPos1; uint16 bufPos2; uint16 tmp; uint8 chunkBitField; uint8 chunkCount; bool mode; frameLength = READ_LE_UINT32(src); src += 4; if ((READ_LE_UINT16(src) == 0x1234) && (READ_LE_UINT16(src + 2) == 0x5678)) { src += 4; bufPos1 = 273; mode = 1; // 123Ch (cmp al, 12h) } else { bufPos1 = 4078; mode = 0; // 275h (jnz +2) } memset(buf, 32, bufPos1); chunkCount = 1; chunkBitField = 0; while (frameLength > 0) { chunkCount--; if (chunkCount == 0) { tmp = *src++; chunkCount = 8; chunkBitField = tmp; } if (chunkBitField % 2) { chunkBitField >>= 1; buf[bufPos1] = *src; *dest++ = *src++; bufPos1 = (bufPos1 + 1) % 4096; frameLength--; continue; } chunkBitField >>= 1; tmp = READ_LE_UINT16(src); src += 2; chunkLength = ((tmp & 0xF00) >> 8) + 3; if ((mode && ((chunkLength & 0xFF) == 0x12)) || (!mode && (chunkLength == 0))) chunkLength = *src++ + 0x12; bufPos2 = (tmp & 0xFF) + ((tmp >> 4) & 0x0F00); if (((tmp + chunkLength) >= 4096) || ((chunkLength + bufPos1) >= 4096)) { for (i = 0; i < chunkLength; i++, dest++) { *dest = buf[bufPos2]; buf[bufPos1] = buf[bufPos2]; bufPos1 = (bufPos1 + 1) % 4096; bufPos2 = (bufPos2 + 1) % 4096; } } else if (((tmp + chunkLength) < bufPos1) || ((chunkLength + bufPos1) < bufPos2)) { memcpy(dest, buf + bufPos2, chunkLength); memmove(buf + bufPos1, buf + bufPos2, chunkLength); dest += chunkLength; bufPos1 += chunkLength; bufPos2 += chunkLength; } else { for (i = 0; i < chunkLength; i++, dest++, bufPos1++, bufPos2++) { *dest = buf[bufPos2]; buf[bufPos1] = buf[bufPos2]; } } frameLength -= chunkLength; } } const uint16 Vmd::_tableADPCM[128] = { 0x0000, 0x0008, 0x0010, 0x0020, 0x0030, 0x0040, 0x0050, 0x0060, 0x0070, 0x0080, 0x0090, 0x00A0, 0x00B0, 0x00C0, 0x00D0, 0x00E0, 0x00F0, 0x0100, 0x0110, 0x0120, 0x0130, 0x0140, 0x0150, 0x0160, 0x0170, 0x0180, 0x0190, 0x01A0, 0x01B0, 0x01C0, 0x01D0, 0x01E0, 0x01F0, 0x0200, 0x0208, 0x0210, 0x0218, 0x0220, 0x0228, 0x0230, 0x0238, 0x0240, 0x0248, 0x0250, 0x0258, 0x0260, 0x0268, 0x0270, 0x0278, 0x0280, 0x0288, 0x0290, 0x0298, 0x02A0, 0x02A8, 0x02B0, 0x02B8, 0x02C0, 0x02C8, 0x02D0, 0x02D8, 0x02E0, 0x02E8, 0x02F0, 0x02F8, 0x0300, 0x0308, 0x0310, 0x0318, 0x0320, 0x0328, 0x0330, 0x0338, 0x0340, 0x0348, 0x0350, 0x0358, 0x0360, 0x0368, 0x0370, 0x0378, 0x0380, 0x0388, 0x0390, 0x0398, 0x03A0, 0x03A8, 0x03B0, 0x03B8, 0x03C0, 0x03C8, 0x03D0, 0x03D8, 0x03E0, 0x03E8, 0x03F0, 0x03F8, 0x0400, 0x0440, 0x0480, 0x04C0, 0x0500, 0x0540, 0x0580, 0x05C0, 0x0600, 0x0640, 0x0680, 0x06C0, 0x0700, 0x0740, 0x0780, 0x07C0, 0x0800, 0x0900, 0x0A00, 0x0B00, 0x0C00, 0x0D00, 0x0E00, 0x0F00, 0x1000, 0x1400, 0x1800, 0x1C00, 0x2000, 0x3000, 0x4000 }; Vmd::Vmd(Graphics::PaletteLUT *palLUT) : _palLUT(palLUT) { clear(false); } Vmd::~Vmd() { clear(); } bool Vmd::load(Common::SeekableReadStream &stream) { unload(); _stream = &stream; uint16 headerLength = _stream->readUint16LE(); uint16 handle = _stream->readUint16LE(); _version = _stream->readUint16LE(); if (!(_version & 2)) _features |= kFeaturesPalette; else _features |= kFeaturesFullColor; // 0x4 (4) // Version checking if (headerLength != 814) { warning("VMD Version incorrect (%d, %d, %d)", headerLength, handle, _version); unload(); return false; } _framesCount = _stream->readUint16LE(); // 0x6 (6) _x = _stream->readSint16LE(); _y = _stream->readSint16LE(); _width = _stream->readSint16LE(); _height = _stream->readSint16LE(); // 0xE (14) if ((_width != 0) && (_height != 0)) { _hasVideo = true; _features |= kFeaturesVideo; if (_features & kFeaturesFullColor) _codecIndeo3 = new Indeo3(_width, _height, _palLUT); } else _hasVideo = false; if (_width > 320) { if (!(_version & 4)) { _version |= 4; handle = 0; } } if (handle > 2) { warning("VMD Version incorrect (%d, %d, %d)", headerLength, handle, _version); unload(); return false; } _bytesPerPixel = handle + 1; if (_bytesPerPixel > 1) { _features |= kFeaturesFullColor; _features &= ~kFeaturesPalette; } _flags = _stream->readUint16LE(); _partsPerFrame = _stream->readUint16LE(); _firstFramePos = _stream->readUint32LE(); _stream->skip(4); // Unknown // 0x1A (26) _stream->read((byte *) _palette, 768); // 0x31A (794) _frameDataSize = _stream->readUint32LE(); _vidBufferSize = _stream->readUint32LE(); if ((_version & 2) && !(_version & 8)) { _externalCodec = true; _frameDataSize = _vidBufferSize = 0; } else _externalCodec = false; _preScaleX = 1; _postScaleX = 1; if (_externalCodec) _blitMode = 0; else if (_bytesPerPixel == 1) _blitMode = 0; else if ((_bytesPerPixel == 2) || (_bytesPerPixel == 3)) { int n = (_flags & 0x80) ? 2 : 3; _blitMode = n - 1; if (_bytesPerPixel == 2) { _preScaleX = n; _postScaleX = 1; } else if (_bytesPerPixel == 3) { _preScaleX = 1; _postScaleX = n; } _bytesPerPixel = n; } _scaleExternalX = 1; if (!_externalCodec && !(_flags & 0x1000)) _scaleExternalX = _bytesPerPixel; // 0x322 (802) if (_hasVideo) { if ((_frameDataSize == 0) || (_frameDataSize > 1048576)) _frameDataSize = _width * _height + 1000; if ((_vidBufferSize == 0) || (_vidBufferSize > 1048576)) _vidBufferSize = _frameDataSize; _frameData = new byte[_frameDataSize]; assert(_frameData); memset(_frameData, 0, _frameDataSize); _vidBuffer = new byte[_vidBufferSize]; assert(_vidBuffer); memset(_vidBuffer, 0, _vidBufferSize); if (_blitMode > 0) { _vidMemBuffer = new byte[_bytesPerPixel * (_width * _height + 1000)]; memset(_vidMemBuffer, 0, _bytesPerPixel * (_width * _height + 1000)); } } _soundFreq = _stream->readSint16LE(); _soundSliceSize = _stream->readSint16LE(); _soundSlicesCount = _stream->readSint16LE(); _soundFlags = _stream->readUint16LE(); _hasSound = (_soundFreq != 0); // 0x32A (810) if (_hasSound) { _features |= kFeaturesSound; _soundStereo = (_soundFlags & 0x8000) ? 1 : ((_soundFlags & 0x200) ? 2 : 0); if (_soundStereo > 0) { warning("TODO: VMD stereo"); unload(); return false; } if (_soundSliceSize < 0) { _soundBytesPerSample = 2; _soundSliceSize = -_soundSliceSize; } _soundSliceLength = (uint32) (((double) (1000 << 16)) / ((double) _soundFreq / (double) _soundSliceSize)); _frameLength = _soundSliceLength >> 16; _soundStage = 1; _audioStream = Audio::makeAppendableAudioStream(_soundFreq, (_soundBytesPerSample == 2) ? Audio::Mixer::FLAG_16BITS : 0); } else _frameLength = 1000 / _frameRate; _frameInfoOffset = _stream->readUint32LE(); int numExtraData = 0; _stream->seek(_frameInfoOffset); _frames = new Frame[_framesCount]; for (uint16 i = 0; i < _framesCount; i++) { _frames[i].parts = new Part[_partsPerFrame]; _stream->skip(2); // Unknown _frames[i].offset = _stream->readUint32LE(); } for (uint16 i = 0; i < _framesCount; i++) { bool separator = false; for (uint16 j = 0; j < _partsPerFrame; j++) { _frames[i].parts[j].type = (PartType) _stream->readByte(); _frames[i].parts[j].field_1 = _stream->readByte(); _frames[i].parts[j].size = _stream->readUint32LE(); if (_frames[i].parts[j].type == kPartTypeAudio) { _frames[i].parts[j].flags = _stream->readByte(); _stream->skip(9); // Unknown } else if (_frames[i].parts[j].type == kPartTypeVideo) { _frames[i].parts[j].left = _stream->readUint16LE(); _frames[i].parts[j].top = _stream->readUint16LE(); _frames[i].parts[j].right = _stream->readUint16LE(); _frames[i].parts[j].bottom = _stream->readUint16LE(); _frames[i].parts[j].field_E = _stream->readByte(); _frames[i].parts[j].flags = _stream->readByte(); } else if (_frames[i].parts[j].type == kPartTypeExtraData) { if (!separator) numExtraData++; _stream->skip(10); } else if (_frames[i].parts[j].type == kPartTypeSeparator) { separator = true; _stream->skip(10); } else { // Unknow type _stream->skip(10); } } } _stream->seek(_firstFramePos); if (numExtraData == 0) return true; _extraData.reserve(numExtraData); numExtraData = 0; uint32 ssize = _stream->size(); for (uint16 i = 0; i < _framesCount; i++) { _stream->seek(_frames[i].offset); for (uint16 j = 0; j < _partsPerFrame; j++) { if (_frames[i].parts[j].type == kPartTypeSeparator) break; if (_frames[i].parts[j].type == kPartTypeExtraData) { ExtraData data; data.offset = _stream->pos() + 20; data.size = _frames[i].parts[j].size; data.realSize = _stream->readUint32LE(); _stream->read(data.name, 16); data.name[15] = '\0'; _stream->skip(_frames[i].parts[j].size - 20); if ((((uint32) data.realSize) >= ssize) || (data.name[0] == 0)) continue; _extraData.push_back(data); } else _stream->skip(_frames[i].parts[j].size); } } _stream->seek(_firstFramePos); return true; } void Vmd::unload() { clear(); } int16 Vmd::getWidth() const { return preScaleX(_width); } void Vmd::setXY(int16 x, int16 y) { x *= _scaleExternalX; for (int i = 0; i < _framesCount; i++) { for (int j = 0; j < _partsPerFrame; j++) { if (_frames[i].parts[j].type == kPartTypeVideo) { if (x >= 0) { _frames[i].parts[j].left = _frames[i].parts[j].left - _x + x; _frames[i].parts[j].right = _frames[i].parts[j].right - _x + x; } if (y >= 0) { _frames[i].parts[j].top = _frames[i].parts[j].top - _y + y; _frames[i].parts[j].bottom = _frames[i].parts[j].bottom - _y + y; } } } } if (x >= 0) _x = x; if (y >= 0) _y = y; } void Vmd::seekFrame(int32 frame, int16 whence, bool restart) { if (!_stream) // Nothing to do return; // Find the frame to which to seek if (whence == SEEK_CUR) frame += _curFrame; else if (whence == SEEK_END) frame = _framesCount - frame - 1; else if (whence != SEEK_SET) return; if ((frame < 0) || (frame >= _framesCount)) // Nothing to do return; // Restart sound if (_hasSound && (frame == 0) && (_soundStage == 0) && !_audioStream) { _soundStage = 1; _audioStream = Audio::makeAppendableAudioStream(_soundFreq, (_soundBytesPerSample == 2) ? Audio::Mixer::FLAG_16BITS : 0); } // Seek _stream->seek(_frames[frame].offset); _curFrame = frame; } CoktelVideo::State Vmd::nextFrame() { State state; state = processFrame(_curFrame); _curFrame++; return state; } void Vmd::clear(bool del) { Imd::clear(del); if (del) { delete _codecIndeo3; delete[] _frames; delete[] _vidMemBuffer; } _hasVideo = true; _codecIndeo3 = 0; _partsPerFrame = 0; _frames = 0; _extraData.clear(); _soundBytesPerSample = 1; _soundStereo = 0; _externalCodec = false; _blitMode = 0; _bytesPerPixel = 1; _preScaleX = 1; _postScaleX = 1; _scaleExternalX = 1; _vidMemBuffer = 0; } CoktelVideo::State Vmd::processFrame(uint16 frame) { State state; bool startSound = false; seekFrame(frame); state.flags |= kStateNoVideoData; state.left = 0x7FFF; state.top = 0x7FFF; state.right = 0; state.bottom = 0; if (!_vidMem) setVideoMemory(); for (uint16 i = 0; (i < _partsPerFrame) && (frame < _framesCount); i++) { Part &part = _frames[frame].parts[i]; if (part.type == kPartTypeAudio) { // Next sound slice data if (part.flags == 1) { if (_soundEnabled) { filledSoundSlice(part.size); if (_soundStage == 1) startSound = true; } else _stream->skip(part.size); // Initial sound data (all slices) } else if (part.flags == 2) { if (_soundEnabled) { uint32 mask = _stream->readUint32LE(); filledSoundSlices(part.size - 4, mask); if (_soundStage == 1) startSound = true; } else _stream->skip(part.size); // Empty sound slice } else if (part.flags == 3) { if (_soundEnabled) { emptySoundSlice(_soundSliceSize * _soundBytesPerSample); if (_soundStage == 1) startSound = true; } _stream->skip(part.size); } else { warning("Unknown sound part type %d", part.flags); _stream->skip(part.size); } } else if (part.type == kPartTypeVideo) { state.flags &= ~kStateNoVideoData; uint32 size = part.size; // New palette if (part.flags & 2) { uint8 index = _stream->readByte(); uint8 count = _stream->readByte(); _stream->read(_palette + index * 3, (count + 1) * 3); _stream->skip((255 - count) * 3); state.flags |= kStatePalette; size -= (768 + 2); } _stream->read(_frameData, size); _frameDataLen = size; int16 l = part.left, t = part.top, r = part.right, b = part.bottom; if (renderFrame(l, t, r, b)) { if (!_externalCodec) { l = preScaleX(l); r = preScaleX(r); } // Rendering succeeded, merging areas state.left = MIN(state.left, l); state.top = MIN(state.top, t); state.right = MAX(state.right, r); state.bottom = MAX(state.bottom, b); } } else if (part.type == 4) { // Unknown _stream->skip(part.size); } else { // Unknow type // warning("Unknown frame part type %d, size %d (%d of %d)", part.type, part.size, i + 1, _partsPerFrame); } } if (startSound && _soundEnabled) { _mixer->playInputStream(Audio::Mixer::kSFXSoundType, &_audioHandle, _audioStream); _skipFrames = 0; _soundStage = 2; } if ((_curFrame == (_framesCount - 1)) && (_soundStage == 2)) { _audioStream->finish(); _mixer->stopHandle(_audioHandle); _audioStream = 0; _soundStage = 0; } // If these are still 0x7FFF, no video data has been processed if ((state.left == 0x7FFF) || (state.top == 0x7FFF)) state.left = state.top = state.right = state.bottom = 0; _lastFrameTime = g_system->getMillis(); return state; } void Vmd::deRLE(byte *&srcPtr, byte *&destPtr, int16 len) { srcPtr++; if (len & 1) *destPtr++ = *srcPtr++; len >>= 1; while (len > 0) { uint8 tmp = *srcPtr++; if (tmp & 0x80) { // Verbatim copy tmp &= 0x7F; memcpy(destPtr, srcPtr, tmp * 2); destPtr += tmp * 2; srcPtr += tmp * 2; } else { // 2 bytes tmp times for (int i = 0; i < tmp; i++) { *destPtr++ = srcPtr[0]; *destPtr++ = srcPtr[1]; } srcPtr += 2; } len -= tmp; } } uint32 Vmd::renderFrame(int16 &left, int16 &top, int16 &right, int16 &bottom) { if (!_frameData || !_vidMem || (_width <= 0) || (_height <= 0)) return 0; int16 width = right - left + 1; int16 height = bottom - top + 1; int16 sW = _vidMemWidth; int16 sH = _vidMemHeight; uint32 dataLen = _frameDataLen; byte *dataPtr = _frameData; byte *imdVidMem = _vidMem + sW * top + left; byte *srcPtr; uint8 type; if ((width < 0) || (height < 0)) return 1; byte *dest = imdVidMem; if (Indeo3::isIndeo3(dataPtr, dataLen)) { if (!_codecIndeo3) return 0; if (!_codecIndeo3->decompressFrame(dataPtr, dataLen, _vidBuffer, width, height)) return 0; type = 2; srcPtr = _vidBuffer; width = _width; height = _height; right = left + width - 1; bottom = top + height - 1; } else { if (_externalCodec) { warning("Unknown external codec"); return 0; } type = *dataPtr++; srcPtr = dataPtr; if (_blitMode > 0) { dest = _vidMemBuffer + postScaleX(_width) * (top - _y) + postScaleX((left - _x)); imdVidMem = _vidMem + _vidMemWidth * top + preScaleX(left); sW = postScaleX(_width); sH = _height; } if (type & 0x80) { // Frame data is compressed srcPtr = _vidBuffer; type &= 0x7F; if ((type == 2) && (postScaleX(width) == sW)) { deLZ77(dest, dataPtr); blit(imdVidMem, dest, width, height); return 1; } else deLZ77(srcPtr, dataPtr); } } uint16 pixCount, pixWritten; byte *destBak; if (type == 1) { // Sparse block destBak = dest; for (int i = 0; i < height; i++) { pixWritten = 0; while (pixWritten < postScaleX(width)) { pixCount = *srcPtr++; if (pixCount & 0x80) { // Data pixCount = MIN((pixCount & 0x7F) + 1, postScaleX(width) - pixWritten); memcpy(dest, srcPtr, pixCount); pixWritten += pixCount; dest += pixCount; srcPtr += pixCount; } else { // "Hole" pixCount = (pixCount + 1) % 256; pixWritten += pixCount; dest += pixCount; } } destBak += sW; dest = destBak; } } else if (type == 2) { // Whole block int16 w = MIN(postScaleX(width), sW); int16 h = MIN(height, sH); for (int i = 0; i < h; i++) { memcpy(dest, srcPtr, w); srcPtr += postScaleX(width); dest += sW; } } else if (type == 3) { // RLE block for (int i = 0; i < height; i++) { destBak = dest; pixWritten = 0; while (pixWritten < width) { pixCount = *srcPtr++; if (pixCount & 0x80) { pixCount = (pixCount & 0x7F) + 1; if (*srcPtr != 0xFF) { // Normal copy memcpy(dest, srcPtr, pixCount); dest += pixCount; srcPtr += pixCount; } else deRLE(srcPtr, dest, pixCount); pixWritten += pixCount; } else { // "Hole" dest += pixCount + 1; pixWritten += pixCount + 1; } } destBak += sW; dest = destBak; } } else if (type == 0x42) { // Whole quarter-wide block for (int i = 0; i < height; i++) { destBak = dest; for (int j = 0; j < width; j += 4, dest += 4, srcPtr++) memset(dest, *srcPtr, 4); destBak += sW; dest = destBak; } } else if ((type & 0xF) == 2) { // Whole half-high block for (; height > 1; height -= 2, dest += sW + sW, srcPtr += width) { memcpy(dest, srcPtr, width); memcpy(dest + sW, srcPtr, width); } if (height == -1) memcpy(dest, srcPtr, width); } else { // Sparse half-high block destBak = dest; for (int i = 0; i < height; i += 2) { pixWritten = 0; while (pixWritten < width) { pixCount = *srcPtr++; if (pixCount & 0x80) { // Data pixCount = MIN((pixCount & 0x7F) + 1, width - pixWritten); memcpy(dest, srcPtr, pixCount); memcpy(dest + sW, srcPtr, pixCount); pixWritten += pixCount; dest += pixCount; srcPtr += pixCount; } else { // "Hole" pixCount = (pixCount + 1) % 256; pixWritten += pixCount; dest += pixCount; } } destBak += sW + sW; dest = destBak; } } dest = _vidMemBuffer + postScaleX(_width) * (top - _y) + postScaleX(left - _x); blit(imdVidMem, dest, width, height); return 1; } inline int32 Vmd::preScaleX(int32 x) const { return x / _preScaleX; } inline int32 Vmd::postScaleX(int32 x) const { return x * _postScaleX; } void Vmd::blit(byte *dest, byte *src, int16 width, int16 height) { if (_blitMode == 0) return; if (_blitMode == 1) blit16(dest, src, preScaleX(_width), preScaleX(width), height); else if (_blitMode == 2) blit24(dest, src, preScaleX(_width), preScaleX(width), height); } void Vmd::blit16(byte *dest, byte *src, int16 srcPitch, int16 width, int16 height) { assert(_palLUT); Graphics::SierraLight *dither = new Graphics::SierraLight(width, _palLUT); for (int i = 0; i < height; i++) { byte *d = dest; byte *s = src; for (int j = 0; j < width; j++, s += 2) { uint16 data = READ_LE_UINT16(s); byte r = ((data & 0x7C00) >> 10); byte g = ((data & 0x03E0) >> 5); byte b = ((data & 0x001F) >> 0); byte dY, dU, dV; Graphics::PaletteLUT::RGB2YUV(r << 3, g << 3, b << 3, dY, dU, dV); byte p = dither->dither(dY, dU, dV, j); if ((dY == 0) || ((r == 0) && (g == 0) && (b == 0))) *d++ = 0; else *d++ = p; } dither->nextLine(); dest += _vidMemWidth; src += 2 * srcPitch; } delete dither; } void Vmd::blit24(byte *dest, byte *src, int16 srcPitch, int16 width, int16 height) { assert(_palLUT); Graphics::SierraLight *dither = new Graphics::SierraLight(width, _palLUT); for (int i = 0; i < height; i++) { byte *d = dest; byte *s = src; for (int j = 0; j < width; j++, s += 3) { byte r = s[2]; byte g = s[1]; byte b = s[0]; byte dY, dU, dV; Graphics::PaletteLUT::RGB2YUV(r, g, b, dY, dU, dV); byte p = dither->dither(dY, dU, dV, j); if ((dY == 0) || ((r == 0) && (g == 0) && (b == 0))) *d++ = 0; else *d++ = p; } dither->nextLine(); dest += _vidMemWidth; src += 3 * srcPitch; } delete dither; } void Vmd::emptySoundSlice(uint32 size) { if (!_audioStream) return; byte *soundBuf = new byte[size]; assert(soundBuf); memset(soundBuf, 0, size); _audioStream->queueBuffer(soundBuf, size); } void Vmd::soundSlice8bit(uint32 size) { if (!_audioStream) return; byte *soundBuf = new byte[size]; assert(soundBuf); _stream->read(soundBuf, size); unsignedToSigned(soundBuf, size); _audioStream->queueBuffer(soundBuf, size); } void Vmd::soundSlice16bit(uint32 size, int16 &init) { if (!_audioStream) return; byte *dataBuf = new byte[size]; byte *soundBuf = new byte[size * 2]; _stream->read(dataBuf, size); deADPCM(soundBuf, dataBuf, init, size); _audioStream->queueBuffer(soundBuf, size * 2); delete[] dataBuf; } void Vmd::filledSoundSlice(uint32 size) { if (_soundBytesPerSample == 1) { soundSlice8bit(size); } else if (_soundBytesPerSample == 2) { int16 init = _stream->readSint16LE(); soundSlice16bit(size - 2, init); } } void Vmd::filledSoundSlices(uint32 size, uint32 mask) { int n = MIN(_soundSlicesCount - 1, 31); for (int i = 0; i < n; i++) { if (mask & 1) emptySoundSlice(_soundSliceSize * _soundBytesPerSample); else filledSoundSlice(_soundSliceSize + 1); mask >>= 1; } if (_soundSlicesCount > 32) filledSoundSlice((_soundSlicesCount - 32) * _soundSliceSize); } void Vmd::deADPCM(byte *soundBuf, byte *dataBuf, int16 &init, uint32 n) { int16 *out = (int16 *) soundBuf; int32 s = init; for (uint32 i = 0; i < n; i++) { if (dataBuf[i] & 0x80) s -= _tableADPCM[dataBuf[i] & 0x7F]; else s += _tableADPCM[dataBuf[i]]; s = CLIP(s, -32768, 32767); *out++ = TO_BE_16(s); } } bool Vmd::getAnchor(int16 frame, uint16 partType, int16 &x, int16 &y, int16 &width, int16 &height) { uint32 pos = _stream->pos(); _stream->seek(_frameInfoOffset); // Offsets to frames _stream->skip(_framesCount * 6); // Jump to the specified frame _stream->skip(_partsPerFrame * frame * 16); // Find the anchor part uint16 i; for (i = 0; i < _partsPerFrame; i++) { byte type = _stream->readByte(); if ((type == kPartTypeSeparator) || (type == partType)) break; _stream->skip(15); } if (i == _partsPerFrame) { // No anchor _stream->seek(pos); return false; } _stream->skip(5); x = _stream->readSint16LE(); y = _stream->readSint16LE(); width = _stream->readSint16LE() - x + 1; height = _stream->readSint16LE() - y + 1; _stream->seek(pos); return true; } bool Vmd::hasExtraData(const char *fileName) const { for (uint i = 0; i < _extraData.size(); i++) if (!scumm_stricmp(_extraData[i].name, fileName)) return true; return false; } Common::MemoryReadStream *Vmd::getExtraData(const char *fileName) { uint i = 0; for (i = 0; i < _extraData.size(); i++) if (!scumm_stricmp(_extraData[i].name, fileName)) break; if (i >= _extraData.size()) return 0; if ((_extraData[i].size - 20) != _extraData[i].realSize) { warning("Vmd::getExtraData(): Sizes for \"%s\" differ! (%d, %d)", fileName, (_extraData[i].size - 20), _extraData[i].realSize); return 0; } byte *data = (byte *) malloc(_extraData[i].realSize); _stream->seek(_extraData[i].offset); if (_stream->ioFailed() || (((uint32) _stream->pos()) != _extraData[i].offset)) { warning("Vmd::getExtraData(): Can't seek to offset %d to get extra data file \"%s\"", _extraData[i].offset, fileName); return 0; } _stream->read(data, _extraData[i].realSize); Common::MemoryReadStream *stream = new Common::MemoryReadStream(data, _extraData[i].realSize, true); return stream; } } // End of namespace Gob