libretro/scummvm
1
0
Fork 0
mirror of https://github.com/libretro/scummvm.git synced 2024-12-26 19:55:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity
0f3d67c1ac
scummvm/engines/sci/sfx/iterator.cpp
Max Horn 0f3d67c1ac SCI: C++ifyed SongIterator and its subclasses 
svn-id: r39152
2009-03-06 07:25:48 +00:00

1900 lines
48 KiB
C++
Raw Blame History

/* 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$
*
*/
/* Song iterators */
#include "common/util.h"
#include "sci/sfx/iterator_internal.h"
#include "sci/sfx/player.h"
#include "sci/tools.h"
#include "sci/sci_memory.h"
#include "sound/audiostream.h"
#include "sound/mixer.h"
namespace Sci {
static const int MIDI_cmdlen[16] = {0, 0, 0, 0, 0, 0, 0, 0,
2, 2, 2, 2, 1, 1, 2, 0
};
/*#define DEBUG_DECODING*/
/*#define DEBUG_VERBOSE*/
void print_tabs_id(int nr, songit_id_t id) {
while (nr-- > 0)
fprintf(stderr, "\t");
fprintf(stderr, "[%08lx] ", id);
}
static unsigned char *sci_memchr(void *_data, int c, int n) {
unsigned char *data = (unsigned char *) _data;
while (n && !(*data == c)) {
++data;
--n;
}
if (n)
return data;
else
return NULL;
}
/************************************/
/*-- SCI0 iterator implementation --*/
/************************************/
#define SCI0_MIDI_OFFSET 33
#define SCI0_END_OF_SONG 0xfc /* proprietary MIDI command */
#define SCI0_PCM_SAMPLE_RATE_OFFSET 0x0e
#define SCI0_PCM_SIZE_OFFSET 0x20
#define SCI0_PCM_DATA_OFFSET 0x2c
#define CHECK_FOR_END_ABSOLUTE(offset) \
if (offset > self->_size) { \
warning(SIPFX "Reached end of song without terminator (%x/%x) at %d!", offset, self->_size, __LINE__); \
return SI_FINISHED; \
}
#define CHECK_FOR_END(offset_augment) \
if ((channel->offset + (offset_augment)) > channel->end) { \
channel->state = SI_STATE_FINISHED; \
warning(SIPFX "Reached end of track %d without terminator (%x+%x/%x) at %d!", channel->id, channel->offset, offset_augment, channel->end, __LINE__); \
return SI_FINISHED; \
}
static inline int _parse_ticks(byte *data, int *offset_p, int size) {
int ticks = 0;
int tempticks;
int offset = 0;
do {
tempticks = data[offset++];
ticks += (tempticks == SCI_MIDI_TIME_EXPANSION_PREFIX) ?
SCI_MIDI_TIME_EXPANSION_LENGTH : tempticks;
} while (tempticks == SCI_MIDI_TIME_EXPANSION_PREFIX
&& offset < size);
if (offset_p)
*offset_p = offset;
return ticks;
}
static int _sci0_get_pcm_data(Sci0SongIterator *self,
sfx_pcm_config_t *format, int *xoffset, uint *xsize);
#define PARSE_FLAG_LOOPS_UNLIMITED (1 << 0) /* Unlimited # of loops? */
#define PARSE_FLAG_PARAMETRIC_CUE (1 << 1) /* Assume that cues take an additional "cue value" argument */
/* This implements a difference between SCI0 and SCI1 cues. */
void _reset_synth_channels(BaseSongIterator *self, SongIteratorChannel *channel) {
int i;
byte buf[5];
tell_synth_func *tell = sfx_get_player_tell_func();
for (i = 0; i < MIDI_CHANNELS; i++) {
if (channel->saw_notes & (1 << i)) {
buf[0] = 0xe0 | i; /* Pitch bend */
buf[1] = 0x80; /* Wheel center */
buf[2] = 0x40;
if (tell)
tell(3, buf);
/* TODO: Reset other controls? */
}
}
}
static int _parse_sci_midi_command(BaseSongIterator *self, unsigned char *buf,
int *result, SongIteratorChannel *channel, int flags) {
unsigned char cmd;
int paramsleft;
int midi_op;
int midi_channel;
channel->state = SI_STATE_DELTA_TIME;
cmd = self->data[channel->offset++];
if (!(cmd & 0x80)) {
/* 'Running status' mode */
channel->offset--;
cmd = channel->last_cmd;
}
if (cmd == 0xfe) {
fprintf(stderr, "song iterator subsystem: Corrupted sound resource detected.\n");
return SI_FINISHED;
}
midi_op = cmd >> 4;
midi_channel = cmd & 0xf;
paramsleft = MIDI_cmdlen[midi_op];
channel->saw_notes |= 1 << midi_channel;
#if 0
if (1) {
fprintf(stderr, "[IT]: off=%x, cmd=%02x, takes %d args ",
channel->offset - 1, cmd, paramsleft);
fprintf(stderr, "[%02x %02x <%02x> %02x %02x %02x]\n",
self->data[channel->offset-3],
self->data[channel->offset-2],
self->data[channel->offset-1],
self->data[channel->offset],
self->data[channel->offset+1],
self->data[channel->offset+2]);
}
#endif
buf[0] = cmd;
CHECK_FOR_END(paramsleft);
memcpy(buf + 1, self->data + channel->offset, paramsleft);
*result = 1 + paramsleft;
channel->offset += paramsleft;
channel->last_cmd = cmd;
/* Are we supposed to play this channel? */
if (
/* First, exclude "global" properties-- such as cues-- from consideration */
(midi_op < 0xf
&& !(cmd == SCI_MIDI_SET_SIGNAL)
&& !(SCI_MIDI_CONTROLLER(cmd)
&& buf[1] == SCI_MIDI_CUMULATIVE_CUE))
/* Next, check if the channel is allowed */
&& (!((1 << midi_channel) & channel->playmask)))
return /* Execute next command */
self->nextCommand(buf, result);
if (cmd == SCI_MIDI_EOT) {
/* End of track? */
_reset_synth_channels(self, channel);
/* fprintf(stderr, "eot; loops = %d, notesplayed=%d\n", self->loops, channel->notes_played);*/
if (self->loops > 1 /* && channel->notes_played*/) {
/* If allowed, decrement the number of loops */
if (!(flags & PARSE_FLAG_LOOPS_UNLIMITED))
*result = --self->loops;
#ifdef DEBUG_DECODING
fprintf(stderr, "%s L%d: (%p):%d Looping ", __FILE__, __LINE__, self, channel->id);
if (flags & PARSE_FLAG_LOOPS_UNLIMITED)
fprintf(stderr, "(indef.)");
else
fprintf(stderr, "(%d)", self->loops);
fprintf(stderr, " %x -> %x\n",
channel->offset, channel->loop_offset);
#endif
channel->offset = channel->loop_offset;
channel->notes_played = 0;
channel->state = SI_STATE_DELTA_TIME;
channel->total_timepos = channel->loop_timepos;
channel->last_cmd = 0xfe;
fprintf(stderr, "Looping song iterator %08lx.\n", self->ID);
return SI_LOOP;
} else {
channel->state = SI_STATE_FINISHED;
#ifdef DEBUG_DECODING
fprintf(stderr, "%s L%d: (%p):%d EOT because"
" %d notes, %d loops\n",
__FILE__, __LINE__, self, channel->id,
channel->notes_played, self->loops);
#endif
return SI_FINISHED;
}
} else if (cmd == SCI_MIDI_SET_SIGNAL) {
if (buf[1] == SCI_MIDI_SET_SIGNAL_LOOP) {
channel->loop_offset = channel->offset;
channel->loop_timepos = channel->total_timepos;
return /* Execute next command */
self->nextCommand(buf, result);
} else {
/* Used to be conditional <= 127 */
*result = buf[1]; /* Absolute cue */
return SI_ABSOLUTE_CUE;
}
} else if (SCI_MIDI_CONTROLLER(cmd)) {
switch (buf[1]) {
case SCI_MIDI_CUMULATIVE_CUE:
if (flags & PARSE_FLAG_PARAMETRIC_CUE)
self->ccc += buf[2];
else { /* No parameter to CC */
self->ccc++;
/* channel->offset--; */
}
*result = self->ccc;
return SI_RELATIVE_CUE;
case SCI_MIDI_RESET_ON_SUSPEND:
self->resetflag = buf[2];
break;
case SCI_MIDI_SET_POLYPHONY:
self->polyphony[midi_channel] = buf[2];
#if 0
{
int i;
int voices = 0;
for (i = 0; i < ((Sci1SongIterator *) self)->_numChannels; i++) {
voices += self->polyphony[i];
}
sciprintf("SET_POLYPHONY(%d, %d) for a total of %d voices\n", midi_channel, buf[2], voices);
sciprintf("[iterator-1] DEBUG: Polyphony = [ ");
for (i = 0; i < ((Sci1SongIterator *) self)->_numChannels; i++)
sciprintf("%d ", self->polyphony[i]);
sciprintf("]\n");
sciprintf("[iterator-1] DEBUG: Importance = [ ");
for (i = 0; i < ((Sci1SongIterator *) self)->_numChannels; i++)
sciprintf("%d ", self->importance[i]);
sciprintf("]\n");
}
#endif
break;
case SCI_MIDI_SET_REVERB:
break;
case SCI_MIDI_CHANNEL_MUTE:
sciprintf("CHANNEL_MUTE(%d, %d)\n", midi_channel, buf[2]);
break;
case SCI_MIDI_HOLD: {
// Safe cast: This controller is only used in SCI1
Sci1SongIterator *self1 = (Sci1SongIterator *) self;
if (buf[2] == self1->hold) {
channel->offset = channel->initial_offset;
channel->notes_played = 0;
channel->state = SI_STATE_COMMAND;
channel->total_timepos = 0;
self1->_numLoopedChannels = self1->active_channels - 1;
return SI_LOOP;
}
break;
}
case 0x04: /* UNKNOWN NYI (happens in LSL2 gameshow) */
case 0x46: /* UNKNOWN NYI (happens in LSL3 binoculars) */
case 0x61: /* UNKNOWN NYI (special for adlib? Iceman) */
case 0x73: /* UNKNOWN NYI (happens in Hoyle) */
case 0xd1: /* UNKNOWN NYI (happens in KQ4 when riding the unicorn) */
return /* Execute next command */
self->nextCommand(buf, result);
case 0x01: /* modulation */
case 0x07: /* volume */
case 0x0a: /* panpot */
case 0x0b: /* expression */
case 0x40: /* hold */
case 0x79: /* reset all */
/* No special treatment neccessary */
break;
}
return 0;
} else {
if ((cmd & 0xf0) == 0x90) /* note on? */
channel->notes_played++;
/* Process as normal MIDI operation */
return 0;
}
}
static int _sci_midi_process_state(BaseSongIterator *self, unsigned char *buf, int *result,
SongIteratorChannel *channel, int flags) {
CHECK_FOR_END(0);
switch (channel->state) {
case SI_STATE_PCM: {
if (*(self->data + channel->offset) == 0
&& *(self->data + channel->offset + 1) == SCI_MIDI_EOT)
/* Fake one extra tick to trick the interpreter into not killing the song iterator right away */
channel->state = SI_STATE_PCM_MAGIC_DELTA;
else
channel->state = SI_STATE_DELTA_TIME;
return SI_PCM;
}
case SI_STATE_PCM_MAGIC_DELTA: {
sfx_pcm_config_t format;
int offset;
uint size;
int delay;
if (_sci0_get_pcm_data((Sci0SongIterator *) self, &format, &offset, &size))
return SI_FINISHED; /* 'tis broken */
channel->state = SI_STATE_FINISHED;
delay = (size * 50 + format.rate - 1) / format.rate; /* number of ticks to completion*/
fprintf(stderr, "delaying %d ticks\n", delay);
return delay;
}
case SI_STATE_UNINITIALISED:
warning(SIPFX "Attempt to read command from uninitialized iterator!");
self->init();
return self->nextCommand(buf, result);
case SI_STATE_FINISHED:
return SI_FINISHED;
case SI_STATE_DELTA_TIME: {
int offset;
int ticks = _parse_ticks(self->data + channel->offset,
&offset,
self->_size - channel->offset);
channel->offset += offset;
channel->delay += ticks;
channel->timepos_increment = ticks;
CHECK_FOR_END(0);
channel->state = SI_STATE_COMMAND;
if (ticks)
return ticks;
}
/* continute otherwise... */
case SI_STATE_COMMAND: {
int retval;
channel->total_timepos += channel->timepos_increment;
channel->timepos_increment = 0;
retval = _parse_sci_midi_command(self, buf, result,
channel, flags);
if (retval == SI_FINISHED) {
if (self->active_channels)
--(self->active_channels);
#ifdef DEBUG_DECODING
fprintf(stderr, "%s L%d: (%p):%d Finished channel, %d channels left\n",
__FILE__, __LINE__, self, channel->id,
self->active_channels);
#endif
/* If we still have channels left... */
if (self->active_channels) {
return self->nextCommand(buf, result);
}
/* Otherwise, we have reached the end */
self->loops = 0;
}
return retval;
}
default:
warning(SIPFX "Invalid iterator state %d!", channel->state);
BREAKPOINT();
return SI_FINISHED;
}
}
static inline int _sci_midi_process(BaseSongIterator *self, unsigned char *buf, int *result,
SongIteratorChannel *channel, int flags) {
return _sci_midi_process_state(self, buf, result,
channel,
flags);
}
int Sci0SongIterator::nextCommand(unsigned char *buf, int *result) {
return _sci_midi_process(this, buf, result,
&channel,
PARSE_FLAG_PARAMETRIC_CUE);
}
static inline int _sci0_header_magic_p(unsigned char *data, int offset, int size) {
if (offset + 0x10 > size)
return 0;
return
(data[offset] == 0x1a)
&& (data[offset + 1] == 0x00)
&& (data[offset + 2] == 0x01)
&& (data[offset + 3] == 0x00);
}
static int _sci0_get_pcm_data(Sci0SongIterator *self,
sfx_pcm_config_t *format, int *xoffset, uint *xsize) {
int tries = 2;
int found_it = 0;
unsigned char *pcm_data;
int size;
uint offset = SCI0_MIDI_OFFSET;
if (self->data[0] != 2)
return 1;
/* No such luck */
while ((tries--) && (offset < self->_size) && (!found_it)) {
/* Search through the garbage manually */
unsigned char *fc = sci_memchr(self->data + offset,
SCI0_END_OF_SONG,
self->_size - offset);
if (!fc) {
warning(SIPFX "Playing unterminated song!");
return 1;
}
/* add one to move it past the END_OF_SONG marker */
offset = fc - self->data + 1;
if (_sci0_header_magic_p(self->data, offset, self->_size))
found_it = 1;
}
if (!found_it) {
warning(SIPFX "Song indicates presence of PCM, but"
" none found (finally at offset %04x)", offset);
return 1;
}
pcm_data = self->data + offset;
size = getUInt16(pcm_data + SCI0_PCM_SIZE_OFFSET);
/* Two of the format parameters are fixed by design: */
format->format = SFX_PCM_FORMAT_U8;
format->stereo = SFX_PCM_MONO;
format->rate = getUInt16(pcm_data + SCI0_PCM_SAMPLE_RATE_OFFSET);
if (offset + SCI0_PCM_DATA_OFFSET + size != self->_size) {
int d = offset + SCI0_PCM_DATA_OFFSET + size - self->_size;
warning(SIPFX "PCM advertizes %d bytes of data, but %d"
" bytes are trailing in the resource!",
size, self->_size - (offset + SCI0_PCM_DATA_OFFSET));
if (d > 0)
size -= d; /* Fix this */
}
*xoffset = offset;
*xsize = size;
return 0;
}
static Audio::AudioStream *makeStream(byte *data, int size, sfx_pcm_config_t conf) {
printf("Playing PCM data of size %d, rate %d\n", size, conf.rate);
// Duplicate the data
byte *sound = (byte *)malloc(size);
memcpy(sound, data + SCI0_PCM_DATA_OFFSET, size);
// Convert stream format flags
int flags = Audio::Mixer::FLAG_AUTOFREE;
if (conf.format == SFX_PCM_FORMAT_U8)
flags |= Audio::Mixer::FLAG_UNSIGNED;
else if (conf.format == SFX_PCM_FORMAT_S16_NATIVE) {
flags |= Audio::Mixer::FLAG_16BITS;
#ifndef SCUMM_BIG_ENDIAN
flags |= Audio::Mixer::FLAG_LITTLE_ENDIAN;
#endif
}
if (conf.stereo)
flags |= Audio::Mixer::FLAG_STEREO;
return Audio::makeLinearInputStream(sound, size, conf.rate, flags, 0, 0);
}
Audio::AudioStream *Sci0SongIterator::getAudioStream() {
sfx_pcm_config_t conf;
int offset;
uint size;
if (_sci0_get_pcm_data(this, &conf, &offset, &size))
return NULL;
channel.state = SI_STATE_FINISHED; /* Don't play both PCM and music */
return makeStream(data + offset + SCI0_PCM_DATA_OFFSET, size, conf);
}
SongIterator *Sci0SongIterator::handleMessage(SongIteratorMessage msg) {
if (msg.recipient == _SIMSG_BASE) {
switch (msg.type) {
case _SIMSG_BASEMSG_PRINT:
print_tabs_id(msg.args[0].i, ID);
fprintf(stderr, "SCI0: dev=%d, active-chan=%d, size=%d, loops=%d\n",
_deviceId, active_channels, _size, loops);
break;
case _SIMSG_BASEMSG_SET_LOOPS:
loops = msg.args[0].i;
break;
case _SIMSG_BASEMSG_CLONE: {
// FIXME: Implement cloning for C++ objects properly
BaseSongIterator *mem = new Sci0SongIterator();
memcpy(mem, this, sizeof(Sci0SongIterator));
sci_refcount_incref(mem->data);
#ifdef DEBUG_VERBOSE
fprintf(stderr, "** CLONE INCREF for new %p from %p at %p\n", mem, this, mem->data);
#endif
return mem; /* Assume caller has another copy of this */
}
case _SIMSG_BASEMSG_STOP: {
songit_id_t sought_id = msg.ID;
if (sought_id == ID)
channel.state = SI_STATE_FINISHED;
break;
}
case _SIMSG_BASEMSG_SET_PLAYMASK: {
int i;
_deviceId = msg.args[0].i;
/* Set all but the rhytm channel mask bits */
channel.playmask &= ~(1 << MIDI_RHYTHM_CHANNEL);
for (i = 0; i < MIDI_CHANNELS; i++)
if (data[2 + (i << 1)] & _deviceId
&& i != MIDI_RHYTHM_CHANNEL)
channel.playmask |= (1 << i);
}
break;
case _SIMSG_BASEMSG_SET_RHYTHM:
channel.playmask &= ~(1 << MIDI_RHYTHM_CHANNEL);
if (msg.args[0].i)
channel.playmask |= (1 << MIDI_RHYTHM_CHANNEL);
break;
case _SIMSG_BASEMSG_SET_FADE: {
fade_params_t *fp = (fade_params_t *) msg.args[0].p;
fade.action = fp->action;
fade.final_volume = fp->final_volume;
fade.ticks_per_step = fp->ticks_per_step;
fade.step_size = fp->step_size;
break;
}
default:
return NULL;
}
return this;
}
return NULL;
}
int Sci0SongIterator::getTimepos() {
return channel.total_timepos;
}
static void _base_init_channel(SongIteratorChannel *channel, int id, int offset,
int end) {
channel->playmask = PLAYMASK_NONE; /* Disable all channels */
channel->id = id;
channel->notes_played = 0;
channel->state = SI_STATE_DELTA_TIME;
channel->loop_timepos = 0;
channel->total_timepos = 0;
channel->timepos_increment = 0;
channel->delay = 0; /* Only used for more than one channel */
channel->last_cmd = 0xfe;
channel->offset
= channel->loop_offset
= channel->initial_offset
= offset;
channel->end = end;
channel->saw_notes = 0;
}
void Sci0SongIterator::init() {
fade.action = FADE_ACTION_NONE;
resetflag = 0;
loops = 0;
priority = 0;
ccc = 0; /* Reset cumulative cue counter */
active_channels = 1;
_base_init_channel(&channel, 0, SCI0_MIDI_OFFSET, _size);
_reset_synth_channels(this, &channel);
_delayRemaining = 0;
if (data[0] == 2) /* Do we have an embedded PCM? */
channel.state = SI_STATE_PCM;
}
void Sci0SongIterator::cleanup() {
#ifdef DEBUG_VERBOSE
fprintf(stderr, "** FREEING it %p: data at %p\n", this, data);
#endif
if (data)
sci_refcount_decref(data);
data = NULL;
}
/***************************/
/*-- SCI1 song iterators --*/
/***************************/
#define SCI01_INVALID_DEVICE 0xff
/* Second index determines whether PCM output is supported */
static int sci0_to_sci1_device_map[][2] = {
{0x06, 0x0c}, /* MT-32 */
{0xff, 0xff}, /* YM FB-01 */
{0x00, 0x00}, /* CMS/Game Blaster-- we assume OPL/2 here... */
{0xff, 0xff}, /* Casio MT540/CT460 */
{0x13, 0x13}, /* Tandy 3-voice */
{0x12, 0x12}, /* PC speaker */
{0xff, 0xff},
{0xff, 0xff},
}; /* Maps bit number to device ID */
#define SONGDATA(x) self->data[offset + (x)]
#define SCI1_CHANDATA(off) self->data[channel->offset + (off)]
static int _sci1_sample_init(Sci1SongIterator *self, int offset) {
Sci1Sample *sample, **seekerp;
int rate;
int length;
int begin;
int end;
CHECK_FOR_END_ABSOLUTE((uint)offset + 10);
if (self->data[offset + 1] != 0)
sciprintf("[iterator-1] In sample at offset 0x04x: Byte #1 is %02x instead of zero\n",
self->data[offset + 1]);
rate = getInt16(self->data + offset + 2);
length = getUInt16(self->data + offset + 4);
begin = getInt16(self->data + offset + 6);
end = getInt16(self->data + offset + 8);
CHECK_FOR_END_ABSOLUTE((uint)(offset + 10 + length));
sample = new Sci1Sample();
sample->delta = begin;
sample->size = length;
sample->data = self->data + offset + 10;
#ifdef DEBUG_VERBOSE
fprintf(stderr, "[SAMPLE] %x/%x/%x/%x l=%x\n",
offset + 10, begin, end, self->_size, length);
#endif
sample->format.format = SFX_PCM_FORMAT_U8;
sample->format.stereo = SFX_PCM_MONO;
sample->format.rate = rate;
sample->announced = 0;
/* Perform insertion sort */
seekerp = &(self->_nextSample);
while (*seekerp && (*seekerp)->delta < begin)
seekerp = &((*seekerp)->next);
sample->next = *seekerp;
*seekerp = sample;
return 0; /* Everything's fine */
}
static int _sci1_song_init(Sci1SongIterator *self) {
Sci1Sample *seeker;
int last_time;
uint offset = 0;
self->_numChannels = 0;
self->_nextSample = 0;
// self->_deviceId = 0x0c;
if (SONGDATA(0) == 0xf0) {
self->priority = SONGDATA(1);
offset += 8;
}
while (SONGDATA(0) != 0xff
&& SONGDATA(0) != self->_deviceId) {
offset++;
CHECK_FOR_END_ABSOLUTE(offset + 1);
while (SONGDATA(0) != 0xff) {
CHECK_FOR_END_ABSOLUTE(offset + 7);
offset += 6;
}
offset++;
}
if (SONGDATA(0) == 0xff) {
sciprintf("[iterator-1] Song does not support"
" hardware 0x%02x\n",
self->_deviceId);
return 1;
}
offset++;
while (SONGDATA(0) != 0xff) { /* End of list? */
uint track_offset;
int end;
offset += 2;
CHECK_FOR_END_ABSOLUTE(offset + 4);
track_offset = getUInt16(self->data + offset);
end = getUInt16(self->data + offset + 2);
CHECK_FOR_END_ABSOLUTE(track_offset - 1);
if (self->data[track_offset] == 0xfe) {
if (_sci1_sample_init(self, track_offset))
return 1; /* Error */
} else {
/* Regular MIDI channel */
if (self->_numChannels >= MIDI_CHANNELS) {
sciprintf("[iterator-1] Warning: Song has more than %d channels, cutting them off\n",
MIDI_CHANNELS);
break; /* Scan for remaining samples */
} else {
int channel_nr
= self->data[track_offset] & 0xf;
SongIteratorChannel *channel =
&(self->_channels[self->_numChannels++]);
if (self->data[track_offset] & 0xf0)
printf("Channel %d has mapping bits %02x\n",
channel_nr, self->data[track_offset] & 0xf0);
_base_init_channel(channel,
channel_nr,
/* Skip over header bytes: */
track_offset + 2,
track_offset + end);
_reset_synth_channels(self, channel);
self->polyphony[self->_numChannels - 1]
= SCI1_CHANDATA(-1);
self->importance[self->_numChannels - 1]
= self->polyphony[self->_numChannels - 1] >> 4;
self->polyphony[self->_numChannels - 1] &= 15;
channel->playmask = ~0; /* Enable all */
self->channel_mask |= (1 << channel_nr);
CHECK_FOR_END_ABSOLUTE(offset + end);
}
}
offset += 4;
CHECK_FOR_END_ABSOLUTE(offset);
}
/* Now ensure that sapmle deltas are relative to the previous sample */
seeker = self->_nextSample;
last_time = 0;
self->active_channels = self->_numChannels;
self->_numLoopedChannels = 0;
while (seeker) {
int prev_last_time = last_time;
sciprintf("[iterator-1] Detected sample: %d Hz, %d bytes at time %d\n",
seeker->format.rate, seeker->size, seeker->delta);
last_time = seeker->delta;
seeker->delta -= prev_last_time;
seeker = seeker->next;
}
return 0; /* Success */
}
#undef SONGDATA
static inline int _sci1_get_smallest_delta(Sci1SongIterator *self) {
int i, d = -1;
for (i = 0; i < self->_numChannels; i++)
if (self->_channels[i].state == SI_STATE_COMMAND
&& (d == -1 || self->_channels[i].delay < d))
d = self->_channels[i].delay;
if (self->_nextSample && self->_nextSample->delta < d)
return self->_nextSample->delta;
else
return d;
}
static inline void _sci1_update_delta(Sci1SongIterator *self, int delta) {
int i;
if (self->_nextSample)
self->_nextSample->delta -= delta;
for (i = 0; i < self->_numChannels; i++)
if (self->_channels[i].state == SI_STATE_COMMAND)
self->_channels[i].delay -= delta;
}
static inline int _sci1_no_delta_time(Sci1SongIterator *self) { /* Checks that none of the channels is waiting for its delta to be read */
int i;
for (i = 0; i < self->_numChannels; i++)
if (self->_channels[i].state == SI_STATE_DELTA_TIME)
return 0;
return 1;
}
#if 0
// Unreferenced - removed
static void _sci1_dump_state(Sci1SongIterator *self) {
int i;
sciprintf("-- [%p] ------------------------\n", self);
for (i = 0; i < self->_numChannels; i++) {
int j;
sciprintf("%d(s%02d): d-%d:\t(%x/%x) ",
self->_channels[i].id,
self->_channels[i].state,
self->_channels[i].delay,
self->_channels[i].offset,
self->_channels[i].end);
for (j = -3; j < 9; j++) {
if (j == 0)
sciprintf(">");
else
sciprintf(" ");
sciprintf("%02x", self->data[self->_channels[i].offset + j]);
if (j == 0)
sciprintf("<");
else
sciprintf(" ");
}
sciprintf("\n");
}
if (self->_nextSample) {
sciprintf("\t[sample %d]\n",
self->_nextSample->delta);
}
sciprintf("------------------------------------------\n");
}
#endif
#define COMMAND_INDEX_NONE -1
#define COMMAND_INDEX_PCM -2
static inline int _sci1_command_index(Sci1SongIterator *self) {
/* Determine the channel # of the next active event, or -1 */
int i;
int base_delay = 0x7ffffff;
int best_chan = COMMAND_INDEX_NONE;
for (i = 0; i < self->_numChannels; i++)
if ((self->_channels[i].state != SI_STATE_PENDING)
&& (self->_channels[i].state != SI_STATE_FINISHED)) {
if ((self->_channels[i].state == SI_STATE_DELTA_TIME)
&& (self->_channels[i].delay == 0))
return i;
/* First, read all unknown delta times */
if (self->_channels[i].delay < base_delay) {
best_chan = i;
base_delay = self->_channels[i].delay;
}
}
if (self->_nextSample && base_delay >= self->_nextSample->delta)
return COMMAND_INDEX_PCM;
return best_chan;
}
Audio::AudioStream *Sci1SongIterator::getAudioStream() {
if (_nextSample && _nextSample->delta <= 0) {
Sci1Sample *sample = _nextSample;
Audio::AudioStream *feed = makeStream(sample->data, sample->size, sample->format);
_nextSample = _nextSample->next;
delete sample;
return feed;
} else
return NULL;
}
int Sci1SongIterator::nextCommand(byte *buf, int *result) {
int retval = -42; /* Shouldn't happen, but gcc doesn't agree */
int chan;
if (!_initialised) {
sciprintf("[iterator-1] DEBUG: Initialising for %d\n",
_deviceId);
_initialised = 1;
if (_sci1_song_init(this))
return SI_FINISHED;
}
if (_delayRemaining) {
int delay = _delayRemaining;
_delayRemaining = 0;
return delay;
}
do {
chan = _sci1_command_index(this);
if (chan == COMMAND_INDEX_NONE) {
return SI_FINISHED;
}
if (chan == COMMAND_INDEX_PCM) {
if (_nextSample->announced) {
/* Already announced; let's discard it */
Audio::AudioStream *feed = getAudioStream();
delete feed;
} else {
int delay = _nextSample->delta;
if (delay) {
_sci1_update_delta(this, delay);
return delay;
}
/* otherwise we're touching a PCM */
_nextSample->announced = 1;
return SI_PCM;
}
} else { /* Not a PCM */
retval = _sci_midi_process(this,
buf, result,
&(_channels[chan]),
PARSE_FLAG_LOOPS_UNLIMITED);
if (retval == SI_LOOP) {
_numLoopedChannels++;
_channels[chan].state = SI_STATE_PENDING;
_channels[chan].delay = 0;
if (_numLoopedChannels == active_channels) {
int i;
/* Everyone's ready: Let's loop */
for (i = 0; i < _numChannels; i++)
if (_channels[i].state == SI_STATE_PENDING)
_channels[i].state = SI_STATE_DELTA_TIME;
_numLoopedChannels = 0;
return SI_LOOP;
}
} else if (retval == SI_FINISHED) {
#ifdef DEBUG
fprintf(stderr, "FINISHED some channel\n");
#endif
} else if (retval > 0) {
int sd ;
sd = _sci1_get_smallest_delta(this);
if (_sci1_no_delta_time(this) && sd) {
/* No other channel is ready */
_sci1_update_delta(this, sd);
/* Only from here do we return delta times */
return sd;
}
}
} /* Not a PCM */
} while (retval > 0); /* All delays must be processed separately */
return retval;
}
SongIterator *Sci1SongIterator::handleMessage(SongIteratorMessage msg) {
if (msg.recipient == _SIMSG_BASE) { /* May extend this in the future */
switch (msg.type) {
case _SIMSG_BASEMSG_PRINT: {
int playmask = 0;
int i;
for (i = 0; i < _numChannels; i++)
playmask |= _channels[i].playmask;
print_tabs_id(msg.args[0].i, ID);
fprintf(stderr, "SCI1: chan-nr=%d, playmask=%04x\n",
_numChannels, playmask);
}
break;
case _SIMSG_BASEMSG_CLONE: {
// FIXME: Implement cloning for C++ objects properly
Sci1SongIterator *mem = new Sci1SongIterator();
Sci1Sample **samplep;
int delta = msg.args[0].i; /* Delay until next step */
memcpy(mem, this, sizeof(Sci1SongIterator)); // FIXME
samplep = &(mem->_nextSample);
sci_refcount_incref(mem->data);
mem->_delayRemaining += delta;
/* Clone chain of samples */
while (*samplep) {
Sci1Sample *newsample = new Sci1Sample;
memcpy(newsample, *samplep, sizeof(Sci1Sample));
*samplep = newsample;
samplep = &(newsample->next);
}
return mem; /* Assume caller has another copy of this */
}
case _SIMSG_BASEMSG_STOP: {
songit_id_t sought_id = msg.ID;
int i;
if (sought_id == ID) {
ID = 0;
for (i = 0; i < _numChannels; i++)
_channels[i].state = SI_STATE_FINISHED;
}
break;
}
case _SIMSG_BASEMSG_SET_PLAYMASK:
if (msg.ID == ID) {
channel_mask = 0;
_deviceId
= sci0_to_sci1_device_map
[sci_ffs(msg.args[0].i & 0xff) - 1]
[sfx_pcm_available()]
;
if (_deviceId == 0xff) {
sciprintf("[iterator-1] Warning: Device %d(%d) not supported",
msg.args[0].i & 0xff, sfx_pcm_available());
}
if (_initialised) {
int i;
int toffset = -1;
for (i = 0; i < _numChannels; i++)
if (_channels[i].state != SI_STATE_FINISHED
&& _channels[i].total_timepos > toffset) {
toffset = _channels[i].total_timepos
+ _channels[i].timepos_increment
- _channels[i].delay;
}
/* Find an active channel so that we can
** get the correct time offset */
_sci1_song_init(this);
toffset -= _delayRemaining;
_delayRemaining = 0;
if (toffset > 0)
return new_fast_forward_iterator(this, toffset);
} else {
_sci1_song_init(this);
_initialised = 1;
}
break;
}
case _SIMSG_BASEMSG_SET_LOOPS:
if (msg.ID == ID)
loops = (msg.args[0].i > 32767) ? 99 : 0;
/* 99 is arbitrary, but we can't use '1' because of
** the way we're testing in the decoding section. */
break;
case _SIMSG_BASEMSG_SET_HOLD:
hold = msg.args[0].i;
break;
case _SIMSG_BASEMSG_SET_RHYTHM:
/* Ignore */
break;
case _SIMSG_BASEMSG_SET_FADE: {
fade_params_t *fp = (fade_params_t *) msg.args[0].p;
fade.action = fp->action;
fade.final_volume = fp->final_volume;
fade.ticks_per_step = fp->ticks_per_step;
fade.step_size = fp->step_size;
break;
}
default:
warning(SIPFX "Unsupported command %d to SCI1 iterator", msg.type);
}
return this;
}
return NULL;
}
void Sci1SongIterator::init() {
fade.action = FADE_ACTION_NONE;
resetflag = 0;
loops = 0;
priority = 0;
ccc = 127;
_deviceId = 0x00; // Default to Sound Blaster/Adlib for purposes of cue computation
_nextSample = NULL;
_numChannels = 0;
_initialised = 0;
_delayRemaining = 0;
loops = 0;
hold = 0;
memset(polyphony, 0, sizeof(polyphony));
memset(importance, 0, sizeof(importance));
}
void Sci1SongIterator::cleanup() {
Sci1Sample *sample_seeker = _nextSample;
while (sample_seeker) {
Sci1Sample *old_sample = sample_seeker;
sample_seeker = sample_seeker->next;
delete old_sample;
}
#ifdef DEBUG_VERBOSE
fprintf(stderr, "** FREEING it %p: data at %p\n", this, data);
#endif
if (data)
sci_refcount_decref(data);
data = NULL;
}
int Sci1SongIterator::getTimepos() {
int max = 0;
int i;
for (i = 0; i < _numChannels; i++)
if (_channels[i].total_timepos > max)
max = _channels[i].total_timepos;
return max;
}
/*****************************/
/*-- Cleanup song iterator --*/
/*****************************/
class CleanupSongIterator : public SongIterator {
public:
CleanupSongIterator(uint channels) {
channel_mask = channels;
ID = 17;
flags = 0;
death_listeners_nr = 0;
}
int nextCommand(byte *buf, int *result);
Audio::AudioStream *getAudioStream() { return NULL; }
SongIterator *handleMessage(SongIteratorMessage msg);
int getTimepos() { return 0; }
};
SongIterator *CleanupSongIterator::handleMessage(SongIteratorMessage msg) {
if (msg.recipient == _SIMSG_BASEMSG_PRINT && msg.type == _SIMSG_BASEMSG_PRINT) {
print_tabs_id(msg.args[0].i, ID);
fprintf(stderr, "CLEANUP\n");
}
return NULL;
}
int CleanupSongIterator::nextCommand(byte *buf, int *result) {
/* Task: Return channel-notes-off for each channel */
if (channel_mask) {
int bs = sci_ffs(channel_mask) - 1;
channel_mask &= ~(1 << bs);
buf[0] = 0xb0 | bs; /* Controller */
buf[1] = SCI_MIDI_CHANNEL_NOTES_OFF;
buf[2] = 0; /* Hmm... */
*result = 3;
return 0;
} else
return SI_FINISHED;
}
SongIterator *new_cleanup_iterator(uint channels) {
CleanupSongIterator *it = new CleanupSongIterator(channels);
return it;
}
/**********************************/
/*-- Fast-forward song iterator --*/
/**********************************/
int FastForwardSongIterator::nextCommand(byte *buf, int *result) {
int rv;
if (delta <= 0)
return SI_MORPH; /* Did our duty */
while (1) {
rv = delegate->nextCommand(buf, result);
if (rv > 0) {
/* Subtract from the delta we want to wait */
delta -= rv;
/* Done */
if (delta < 0)
return -delta;
}
if (rv <= 0)
return rv;
}
}
Audio::AudioStream *FastForwardSongIterator::getAudioStream() {
return delegate->getAudioStream();
}
SongIterator *FastForwardSongIterator::handleMessage(SongIteratorMessage msg) {
if (msg.recipient == _SIMSG_PLASTICWRAP)
switch (msg.type) {
case _SIMSG_PLASTICWRAP_ACK_MORPH:
if (delta <= 0) {
SongIterator *it = delegate;
delete this;
return it;
}
break;
default:
BREAKPOINT();
}
else if (msg.recipient == _SIMSG_BASE) {
switch (msg.type) {
case _SIMSG_BASEMSG_CLONE: {
// FIXME: Implement cloning for C++ objects properly
FastForwardSongIterator *clone = new FastForwardSongIterator();
memcpy(clone, this, sizeof(FastForwardSongIterator));
songit_handle_message(&clone->delegate, msg);
return clone;
}
case _SIMSG_BASEMSG_PRINT:
print_tabs_id(msg.args[0].i, ID);
fprintf(stderr, "PLASTICWRAP:\n");
msg.args[0].i++;
songit_handle_message(&delegate, msg);
break;
default:
songit_handle_message(&delegate, msg);
}
} else
songit_handle_message(&delegate, msg);
return NULL;
}
int FastForwardSongIterator::getTimepos() {
return delegate->getTimepos();
}
SongIterator *new_fast_forward_iterator(SongIterator *capsit, int delta) {
if (capsit == NULL) {
return NULL;
}
FastForwardSongIterator *it = new FastForwardSongIterator();
it->delegate = capsit;
it->delta = delta;
it->channel_mask = capsit->channel_mask;
return it;
}
/********************/
/*-- Tee iterator --*/
/********************/
int TeeSongIterator::nextCommand(byte *buf, int *result) {
static int ready_masks[2] = {TEE_LEFT_READY, TEE_RIGHT_READY};
static int active_masks[2] = {TEE_LEFT_ACTIVE, TEE_RIGHT_ACTIVE};
static int pcm_masks[2] = {TEE_LEFT_PCM, TEE_RIGHT_PCM};
int i;
int retid;
#ifdef DEBUG_TEE_ITERATOR
fprintf(stderr, "[Tee] %02x\n", _status);
#endif
if (!(_status & (TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE)))
/* None is active? */
return SI_FINISHED;
if (morph_deferred == TEE_MORPH_READY)
return SI_MORPH;
if ((_status & (TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE))
!= (TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE)) {
/* Not all are is active? */
int which = 0;
#ifdef DEBUG_TEE_ITERATOR
fprintf(stderr, "\tRequesting transformation...\n");
#endif
if (_status & TEE_LEFT_ACTIVE)
which = TEE_LEFT;
else if (_status & TEE_RIGHT_ACTIVE)
which = TEE_RIGHT;
memcpy(buf, _children[which].buf, MAX_BUF_SIZE);
*result = _children[which].result;
morph_deferred = TEE_MORPH_READY;
return _children[which].retval;
}
/* First, check for unreported PCMs */
for (i = TEE_LEFT; i <= TEE_RIGHT; i++)
if ((_status & (ready_masks[i] | pcm_masks[i]))
== (ready_masks[i] | pcm_masks[i])) {
_status &= ~ready_masks[i];
return SI_PCM;
}
for (i = TEE_LEFT; i <= TEE_RIGHT; i++)
if (!(_status & ready_masks[i])) {
/* Buffers aren't ready yet */
_children[i].retval =
songit_next(&(_children[i].it),
_children[i].buf,
&(_children[i].result),
IT_READER_MASK_ALL
| IT_READER_MAY_FREE
| IT_READER_MAY_CLEAN);
_status |= ready_masks[i];
#ifdef DEBUG_TEE_ITERATOR
fprintf(stderr, "\t Must check %d: %d\n", i, _children[i].retval);
#endif
if (_children[i].retval == SI_ABSOLUTE_CUE ||
_children[i].retval == SI_RELATIVE_CUE)
return _children[i].retval;
if (_children[i].retval == SI_FINISHED) {
_status &= ~active_masks[i];
/* Recurse to complete */
#ifdef DEBUG_TEE_ITERATOR
fprintf(stderr, "\t Child %d signalled completion, recursing w/ status %02x\n", i, _status);
#endif
return nextCommand(buf, result);
} else if (_children[i].retval == SI_PCM) {
_status |= pcm_masks[i];
_status &= ~ready_masks[i];
return SI_PCM;
}
}
/* We've already handled PCM, MORPH and FINISHED, CUEs & LOOP remain */
retid = TEE_LEFT;
if ((_children[TEE_LEFT].retval > 0)
/* Asked to delay */
&& (_children[TEE_RIGHT].retval <= _children[TEE_LEFT].retval))
/* Is not delaying or not delaying as much */
retid = TEE_RIGHT;
#ifdef DEBUG_TEE_ITERATOR
fprintf(stderr, "\tl:%d / r:%d / chose %d\n",
_children[TEE_LEFT].retval, _children[TEE_RIGHT].retval, retid);
#endif
#if 0
if (_children[retid].retval == 0) {
/* Perform remapping, if neccessary */
byte *buf = _children[retid].buf;
if (*buf != SCI_MIDI_SET_SIGNAL
&& *buf < 0xf0) { /* Not a generic command */
int chan = *buf & 0xf;
int op = *buf & 0xf0;
chan = _children[retid].channel_remap[chan];
*buf = chan | op;
}
}
#endif
/* Adjust delta times */
if (_children[retid].retval > 0
&& _children[1-retid].retval > 0) {
if (_children[1-retid].retval
== _children[retid].retval)
/* If both _children wait the same amount of time,
** we have to re-fetch commands from both */
_status &= ~ready_masks[1-retid];
else
/* If they don't, we can/must re-use the other
** child's delay time */
_children[1-retid].retval
-= _children[retid].retval;
}
_status &= ~ready_masks[retid];
memcpy(buf, _children[retid].buf, MAX_BUF_SIZE);
*result = _children[retid].result;
return _children[retid].retval;
}
Audio::AudioStream *TeeSongIterator::getAudioStream() {
static int pcm_masks[2] = {TEE_LEFT_PCM, TEE_RIGHT_PCM};
int i;
for (i = TEE_LEFT; i <= TEE_RIGHT; i++)
if (_status & pcm_masks[i]) {
_status &= ~pcm_masks[i];
return _children[i].it->getAudioStream();
}
return NULL; // No iterator
}
SongIterator *TeeSongIterator::handleMessage(SongIteratorMessage msg) {
if (msg.recipient == _SIMSG_BASE) {
switch (msg.type) {
case _SIMSG_BASEMSG_PRINT:
print_tabs_id(msg.args[0].i, ID);
fprintf(stderr, "TEE:\n");
msg.args[0].i++;
break; /* And continue with our children */
case _SIMSG_BASEMSG_CLONE: {
// FIXME: Implement cloning for C++ objects properly
TeeSongIterator *newit = new TeeSongIterator();
memcpy(newit, this, sizeof(TeeSongIterator));
if (newit->_children[TEE_LEFT].it)
newit->_children[TEE_LEFT].it =
songit_clone(newit->_children[TEE_LEFT].it, msg.args[0].i);
if (newit->_children[TEE_RIGHT].it)
newit->_children[TEE_RIGHT].it =
songit_clone(newit->_children[TEE_RIGHT].it, msg.args[0].i);
return newit;
}
default:
break;
}
}
if (msg.recipient == _SIMSG_PLASTICWRAP) {
SongIterator *old_it;
switch (msg.type) {
case _SIMSG_PLASTICWRAP_ACK_MORPH:
if (!(_status & (TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE))) {
songit_free(this);
return NULL;
} else if (!(_status & TEE_LEFT_ACTIVE)) {
if (may_destroy)
songit_free(_children[TEE_LEFT].it);
old_it = _children[TEE_RIGHT].it;
delete this;
return old_it;
} else if (!(_status & TEE_RIGHT_ACTIVE)) {
if (may_destroy)
songit_free(_children[TEE_RIGHT].it);
old_it = _children[TEE_LEFT].it;
delete this;
return old_it;
} else {
sciprintf("[tee-iterator] WARNING:"
" Morphing without need\n");
return this;
}
default:
BREAKPOINT();
}
}
if (_children[TEE_LEFT].it)
songit_handle_message(&(_children[TEE_LEFT].it), msg);
if (_children[TEE_RIGHT].it)
songit_handle_message(&(_children[TEE_RIGHT].it), msg);
return NULL;
}
void TeeSongIterator::init() {
_status = TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE;
_children[TEE_LEFT].it->init();
_children[TEE_RIGHT].it->init();
}
#if 0
// Unreferenced - removed
static void _tee_free(TeeSongIterator *it) {
int i;
for (i = TEE_LEFT; i <= TEE_RIGHT; i++)
if (it->_children[i].it && it->may_destroy)
songit_free(it->_children[i].it);
}
#endif
static void songit_tee_death_notification(TeeSongIterator *self,
SongIterator *corpse) {
if (corpse == self->_children[TEE_LEFT].it) {
self->_status &= ~TEE_LEFT_ACTIVE;
self->_children[TEE_LEFT].it = NULL;
} else if (corpse == self->_children[TEE_RIGHT].it) {
self->_status &= ~TEE_RIGHT_ACTIVE;
self->_children[TEE_RIGHT].it = NULL;
} else {
BREAKPOINT();
}
}
SongIterator *songit_new_tee(SongIterator *left, SongIterator *right, int may_destroy) {
int i;
int firstfree = 1; /* First free channel */
int incomplete_map = 0;
TeeSongIterator *it = new TeeSongIterator();
it->morph_deferred = TEE_MORPH_NONE;
it->_status = TEE_LEFT_ACTIVE | TEE_RIGHT_ACTIVE;
it->may_destroy = may_destroy;
it->_children[TEE_LEFT].it = left;
it->_children[TEE_RIGHT].it = right;
/* By default, don't remap */
for (i = 0; i < 16; i++)
it->_children[TEE_LEFT].channel_remap[i]
= it->_children[TEE_RIGHT].channel_remap[i] = i;
/* Default to lhs channels */
it->channel_mask = left->channel_mask;
for (i = 0; i < 16; i++)
if (it->channel_mask & (1 << i) & right->channel_mask
&& (i != MIDI_RHYTHM_CHANNEL) /* Share rhythm */) { /*conflict*/
while ((firstfree == MIDI_RHYTHM_CHANNEL)
/* Either if it's the rhythm channel or if it's taken */
|| (firstfree < MIDI_CHANNELS
&& ((1 << firstfree) & it->channel_mask)))
++firstfree;
if (firstfree == MIDI_CHANNELS) {
incomplete_map = 1;
fprintf(stderr, "[songit-tee <%08lx,%08lx>] "
"Could not remap right channel #%d:"
" Out of channels\n",
left->ID, right->ID, i);
} else {
it->_children[TEE_RIGHT].channel_remap[i]
= firstfree;
it->channel_mask |= (1 << firstfree);
}
}
#ifdef DEBUG_TEE_ITERATOR
if (incomplete_map) {
int c;
fprintf(stderr, "[songit-tee <%08lx,%08lx>] Channels:"
" %04x <- %04x | %04x\n",
left->ID, right->ID,
it->channel_mask,
left->channel_mask, right->channel_mask);
for (c = 0 ; c < 2; c++)
for (i = 0 ; i < 16; i++)
fprintf(stderr, " map [%d][%d] -> %d\n",
c, i, it->_children[c].channel_remap[i]);
}
#endif
song_iterator_add_death_listener(it,
left, (void (*)(void *, void*))
songit_tee_death_notification);
song_iterator_add_death_listener(it,
right, (void (*)(void *, void*))
songit_tee_death_notification);
return it;
}
/*************************************/
/*-- General purpose functionality --*/
/*************************************/
int songit_next(SongIterator **it, unsigned char *buf, int *result, int mask) {
int retval;
if (!*it)
return SI_FINISHED;
do {
retval = (*it)->nextCommand(buf, result);
if (retval == SI_MORPH) {
fprintf(stderr, " Morphing %p (stored at %p)\n", (void *)*it, (void *)it);
if (!SIMSG_SEND((*it), SIMSG_ACK_MORPH)) {
BREAKPOINT();
} else fprintf(stderr, "SI_MORPH successful\n");
}
if (retval == SI_FINISHED)
fprintf(stderr, "[song-iterator] Song finished. mask = %04x, cm=%04x\n",
mask, (*it)->channel_mask);
if (retval == SI_FINISHED
&& (mask & IT_READER_MAY_CLEAN)
&& (*it)->channel_mask) { /* This last test will fail
** with a terminated
** cleanup iterator */
int channel_mask = (*it)->channel_mask;
if (mask & IT_READER_MAY_FREE)
songit_free(*it);
*it = new_cleanup_iterator(channel_mask);
retval = -9999; /* Continue */
}
} while (!( /* Until one of the following holds */
(retval > 0 && (mask & IT_READER_MASK_DELAY))
|| (retval == 0 && (mask & IT_READER_MASK_MIDI))
|| (retval == SI_LOOP && (mask & IT_READER_MASK_LOOP))
|| (retval == SI_ABSOLUTE_CUE &&
(mask & IT_READER_MASK_CUE))
|| (retval == SI_RELATIVE_CUE &&
(mask & IT_READER_MASK_CUE))
|| (retval == SI_PCM && (mask & IT_READER_MASK_PCM))
|| (retval == SI_FINISHED)
));
if (retval == SI_FINISHED
&& (mask & IT_READER_MAY_FREE)) {
songit_free(*it);
*it = NULL;
}
return retval;
}
SongIterator *songit_new(unsigned char *data, uint size, int type, songit_id_t id) {
BaseSongIterator *it;
int i;
if (!data || size < 22) {
warning(SIPFX "Attempt to instantiate song iterator for null song data");
return NULL;
}
switch (type) {
case SCI_SONG_ITERATOR_TYPE_SCI0:
/**-- Playing SCI0 sound resources --**/
it = new Sci0SongIterator();
it->channel_mask = 0xffff; /* Allocate all channels by default */
for (i = 0; i < MIDI_CHANNELS; i++)
it->polyphony[i] = data[1 + (i << 1)];
((Sci0SongIterator *)it)->channel.state = SI_STATE_UNINITIALISED;
break;
case SCI_SONG_ITERATOR_TYPE_SCI1:
/**-- SCI01 or later sound resource --**/
it = new Sci1SongIterator();
it->channel_mask = 0; /* Defer channel allocation */
for (i = 0; i < MIDI_CHANNELS; i++)
it->polyphony[i] = 0; /* Unknown */
break;
default:
/**-- Invalid/unsupported sound resources --**/
warning(SIPFX "Attempt to instantiate invalid/unknown"
" song iterator type %d", type);
return NULL;
}
it->ID = id;
it->death_listeners_nr = 0;
it->data = (unsigned char*)sci_refcount_memdup(data, size);
it->_size = size;
it->init();
return it;
}
void songit_free(SongIterator *it) {
if (it) {
int i;
it->cleanup();
for (i = 0; i < it->death_listeners_nr; i++)
it->death_listeners[i].notify(it->death_listeners[i].self, it);
delete it;
}
}
SongIteratorMessage::SongIteratorMessage() {
ID = 0;
recipient = 0;
type = 0;
}
SongIteratorMessage::SongIteratorMessage(songit_id_t id, int r, int t, int a1, int a2) {
ID = id;
recipient = r;
type = t;
args[0].i = a1;
args[1].i = a2;
}
SongIteratorMessage::SongIteratorMessage(songit_id_t id, int r, int t, void *a1, int a2) {
ID = id;
recipient = r;
type = t;
args[0].p = a1;
args[1].i = a2;
}
int songit_handle_message(SongIterator **it_reg_p, SongIteratorMessage msg) {
SongIterator *it = *it_reg_p;
SongIterator *newit;
newit = it->handleMessage(msg);
if (!newit)
return 0; /* Couldn't handle */
*it_reg_p = newit; /* Might have self-morphed */
return 1;
}
SongIterator *songit_clone(SongIterator *it, int delta) {
SIMSG_SEND(it, SIMSG_CLONE(delta));
it->death_listeners_nr = 0;
it->flags |= SONGIT_FLAG_CLONE;
return it;
}
void song_iterator_add_death_listener(SongIterator *it,
void *client, void (*notify)(void *self, void *notifier)) {
if (it->death_listeners_nr >= SONGIT_MAX_LISTENERS) {
error("FATAL: Too many death listeners for song iterator");
}
it->death_listeners[it->death_listeners_nr].notify = notify;
it->death_listeners[it->death_listeners_nr].self = client;
it->death_listeners_nr++;
}
void song_iterator_remove_death_listener(SongIterator *it, void *client) {
int i;
for (i = 0; i < it->death_listeners_nr; i++) {
if (it->death_listeners[i].self == client) {
--it->death_listeners_nr;
/* Overwrite, if this wasn't the last one */
if (i + 1 < it->death_listeners_nr)
it->death_listeners[i]
= it->death_listeners[it->death_listeners_nr];
return;
}
}
error("FATAL: Could not remove death listener from song iterator\n");
}
SongIterator *sfx_iterator_combine(SongIterator *it1, SongIterator *it2) {
if (it1 == NULL)
return it2;
if (it2 == NULL)
return it1;
/* Both are non-NULL: */
return songit_new_tee(it1, it2, 1); /* 'may destroy' */
}
} // End of namespace Sci
Reference in New Issue View Git Blame Copy Permalink