summaryrefslogtreecommitdiff
path: root/apps/codecs/libgme/hes_emu.c
diff options
context:
space:
mode:
authorAndree Buschmann <AndreeBuschmann@t-online.de>2011-08-07 20:01:04 +0000
committerAndree Buschmann <AndreeBuschmann@t-online.de>2011-08-07 20:01:04 +0000
commitacb0917556fc33681c1df5a530cf754193e67705 (patch)
tree052a47097009a210e4aed9c207bd6aa4828cc000 /apps/codecs/libgme/hes_emu.c
parent93c6f1329a5691a8be158cefe15641bd1daf9ef8 (diff)
Submit initial patch from FS#12176. Adds support for several new game music formats (AY, GBS, HES, KSS, SGC, VGM and VGZ) and replaces the current NSF and NSFE with a new implementation based on a port of the Game Music Emu library 'GME'. This first submit does not cover the full functionality provided by the author's original patch: Coleco-SGV is not supported, some GME-specific m3u-support has been removed and IRAM is not used yet. Further changes are very likely to follow this submit. Thanks to Mauricio Garrido.
git-svn-id: svn://svn.rockbox.org/rockbox/trunk@30264 a1c6a512-1295-4272-9138-f99709370657
Diffstat (limited to 'apps/codecs/libgme/hes_emu.c')
-rw-r--r--apps/codecs/libgme/hes_emu.c877
1 files changed, 877 insertions, 0 deletions
diff --git a/apps/codecs/libgme/hes_emu.c b/apps/codecs/libgme/hes_emu.c
new file mode 100644
index 0000000000..a44eded8d7
--- /dev/null
+++ b/apps/codecs/libgme/hes_emu.c
@@ -0,0 +1,877 @@
+// Game_Music_Emu 0.5.2. http://www.slack.net/~ant/
+
+#include "hes_emu.h"
+
+#include "blargg_endian.h"
+#include "blargg_source.h"
+
+/* Copyright (C) 2006 Shay Green. This module is free software; you
+can redistribute it and/or modify it under the terms of the GNU Lesser
+General Public License as published by the Free Software Foundation; either
+version 2.1 of the License, or (at your option) any later version. This
+module 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 Lesser General Public License for more
+details. You should have received a copy of the GNU Lesser General Public
+License along with this module; if not, write to the Free Software Foundation,
+Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */
+
+int const timer_mask = 0x04;
+int const vdp_mask = 0x02;
+int const i_flag_mask = 0x04;
+int const unmapped = 0xFF;
+
+long const period_60hz = 262 * 455L; // scanlines * clocks per scanline
+
+int const stereo = 2; // number of channels for stereo
+int const silence_max = 6; // seconds
+int const silence_threshold = 0x10;
+long const fade_block_size = 512;
+int const fade_shift = 8; // fade ends with gain at 1.0 / (1 << fade_shift)
+
+const char gme_wrong_file_type [] ICONST_ATTR = "Wrong file type for this emulator";
+
+void clear_track_vars( struct Hes_Emu* this )
+{
+ this->current_track_ = -1;
+ this->out_time = 0;
+ this->emu_time = 0;
+ this->emu_track_ended_ = true;
+ this->track_ended = true;
+ this->fade_start = LONG_MAX / 2 + 1;
+ this->fade_step = 1;
+ this->silence_time = 0;
+ this->silence_count = 0;
+ this->buf_remain = 0;
+}
+
+void Hes_init( struct Hes_Emu* this )
+{
+ this->sample_rate_ = 0;
+ this->mute_mask_ = 0;
+ this->tempo_ = 1.0;
+
+ // defaults
+ this->max_initial_silence = 2;
+ this->ignore_silence = false;
+
+ // Unload
+ this->voice_count_ = 0;
+ clear_track_vars( this );
+
+ this->timer.raw_load = 0;
+ this->silence_lookahead = 6;
+ Sound_set_gain( this, 1.11 );
+
+ Rom_init( &this->rom, 0x2000 );
+
+ Apu_init( &this->apu );
+ Adpcm_init( &this->adpcm );
+ Cpu_init( &this->cpu );
+
+ /* Set default track count */
+ this->track_count = 255;
+}
+
+static blargg_err_t check_hes_header( void const* header )
+{
+ if ( memcmp( header, "HESM", 4 ) )
+ return gme_wrong_file_type;
+ return 0;
+}
+
+// Setup
+
+blargg_err_t Hes_load( struct Hes_Emu* this, void* data, long size )
+{
+ // Unload
+ this->voice_count_ = 0;
+ clear_track_vars( this );
+
+ assert( offsetof (struct header_t,unused [4]) == header_size );
+ RETURN_ERR( Rom_load( &this->rom, data, size, header_size, &this->header, unmapped ) );
+
+ RETURN_ERR( check_hes_header( this->header.tag ) );
+
+ /* if ( header_.vers != 0 )
+ warning( "Unknown file version" );
+
+ if ( memcmp( header_.data_tag, "DATA", 4 ) )
+ warning( "Data header missing" );
+
+ if ( memcmp( header_.unused, "\0\0\0\0", 4 ) )
+ warning( "Unknown header data" ); */
+
+ // File spec supports multiple blocks, but I haven't found any, and
+ // many files have bad sizes in the only block, so it's simpler to
+ // just try to load the damn data as best as possible.
+
+ long addr = get_le32( this->header.addr );
+ /* long rom_size = get_le32( this->header.size ); */
+ long const rom_max = 0x100000;
+ if ( addr & ~(rom_max - 1) )
+ {
+ /* warning( "Invalid address" ); */
+ addr &= rom_max - 1;
+ }
+ /* if ( (unsigned long) (addr + size) > (unsigned long) rom_max )
+ warning( "Invalid size" );
+
+ if ( rom_size != rom.file_size() )
+ {
+ if ( size <= rom.file_size() - 4 && !memcmp( rom.begin() + size, "DATA", 4 ) )
+ warning( "Multiple DATA not supported" );
+ else if ( size < rom.file_size() )
+ warning( "Extra file data" );
+ else
+ warning( "Missing file data" );
+ } */
+
+ Rom_set_addr( &this->rom, addr );
+
+ this->voice_count_ = osc_count + adpcm_osc_count;
+
+ Apu_volume( &this->apu, this->gain_ );
+ Adpcm_volume( &this->adpcm, this->gain_ );
+
+ // Setup buffer
+ this->clock_rate_ = 7159091;
+ Buffer_clock_rate( &this->stereo_buf, 7159091 );
+ this->buf_changed_count = Buffer_channels_changed_count( &this->stereo_buf );
+
+ Sound_set_tempo( this, this->tempo_ );
+ Sound_mute_voices( this, this->mute_mask_ );
+
+ // Reset track count
+ this->track_count = 255;
+ this->m3u.size = 0;
+ return 0;
+}
+
+
+// Emulation
+
+void recalc_timer_load( struct Hes_Emu* this ) ICODE_ATTR;
+void recalc_timer_load( struct Hes_Emu* this )
+{
+ this->timer.load = this->timer.raw_load * this->timer_base + 1;
+}
+
+// Hardware
+
+void irq_changed( struct Hes_Emu* this ) ICODE_ATTR;
+void run_until( struct Hes_Emu* this, hes_time_t present ) ICODE_ATTR;
+void Cpu_write_vdp( struct Hes_Emu* this, int addr, int data )
+{
+ switch ( addr )
+ {
+ case 0:
+ this->vdp.latch = data & 0x1F;
+ break;
+
+ case 2:
+ if ( this->vdp.latch == 5 )
+ {
+ /* if ( data & 0x04 )
+ warning( "Scanline interrupt unsupported" ); */
+ run_until( this, Cpu_time( &this->cpu ) );
+ this->vdp.control = data;
+ irq_changed( this );
+ }
+ else
+ {
+ dprintf( "VDP not supported: $%02X <- $%02X\n", this->vdp.latch, data );
+ }
+ break;
+
+ case 3:
+ dprintf( "VDP MSB not supported: $%02X <- $%02X\n", this->vdp.latch, data );
+ break;
+ }
+}
+
+int Cpu_done( struct Hes_Emu* this )
+{
+ check( time() >= end_time() ||
+ (!(r.status & i_flag_mask) && time() >= irq_time()) );
+
+ if ( !(this->cpu.r.status & i_flag_mask) )
+ {
+ hes_time_t present = Cpu_time( &this->cpu );
+
+ if ( this->irq.timer <= present && !(this->irq.disables & timer_mask) )
+ {
+ this->timer.fired = true;
+ this->irq.timer = future_hes_time;
+ irq_changed( this ); // overkill, but not worth writing custom code
+ #if defined (GME_FRAME_HOOK_DEFINED)
+ {
+ unsigned const threshold = period_60hz / 30;
+ unsigned long elapsed = present - last_frame_hook;
+ if ( elapsed - period_60hz + threshold / 2 < threshold )
+ {
+ last_frame_hook = present;
+ GME_FRAME_HOOK( this );
+ }
+ }
+ #endif
+ return 0x0A;
+ }
+
+ if ( this->irq.vdp <= present && !(this->irq.disables & vdp_mask) )
+ {
+ // work around for bugs with music not acknowledging VDP
+ //run_until( present );
+ //irq.vdp = future_hes_time;
+ //irq_changed();
+ #if defined(GME_FRAME_HOOK_DEFINED)
+ last_frame_hook = present;
+ GME_FRAME_HOOK( this );
+ #endif
+ return 0x08;
+ }
+ }
+ return 0;
+}
+
+void Emu_cpu_write( struct Hes_Emu* this, hes_addr_t addr, int data )
+{
+ hes_time_t time = Cpu_time( &this->cpu );
+ if ( (unsigned) (addr - start_addr) <= end_addr - start_addr )
+ {
+ GME_APU_HOOK( this, addr - apu.start_addr, data );
+ // avoid going way past end when a long block xfer is writing to I/O space
+ hes_time_t t = min( time, this->cpu.end_time + 8 );
+ Apu_write_data( &this->apu, t, addr, data );
+ return;
+ }
+
+ if ( (unsigned) (addr - io_addr) < io_size )
+ {
+ hes_time_t t = min( time, this->cpu.end_time + 6 );
+ Adpcm_write_data( &this->adpcm, t, addr, data );
+ return;
+ }
+
+ switch ( addr )
+ {
+ case 0x0000:
+ case 0x0002:
+ case 0x0003:
+ Cpu_write_vdp( this, addr, data );
+ return;
+
+ case 0x0C00: {
+ run_until( this, time );
+ this->timer.raw_load = (data & 0x7F) + 1;
+ recalc_timer_load( this );
+ this->timer.count = this->timer.load;
+ break;
+ }
+
+ case 0x0C01:
+ data &= 1;
+ if ( this->timer.enabled == data )
+ return;
+ run_until( this, time );
+ this->timer.enabled = data;
+ if ( data )
+ this->timer.count = this->timer.load;
+ break;
+
+ case 0x1402:
+ run_until( this, time );
+ this->irq.disables = data;
+
+ // flag questionable values
+ if ( (data & 0xF8) && (data & 0xF8) != 0xF8 ) {
+ dprintf( "Int mask: $%02X\n", data );
+ }
+ break;
+
+ case 0x1403:
+ run_until( this, time );
+ if ( this->timer.enabled )
+ this->timer.count = this->timer.load;
+ this->timer.fired = false;
+ break;
+
+#ifndef NDEBUG
+ case 0x1000: // I/O port
+ case 0x0402: // palette
+ case 0x0403:
+ case 0x0404:
+ case 0x0405:
+ return;
+
+ default:
+ dprintf( "unmapped write $%04X <- $%02X\n", addr, data );
+ return;
+#endif
+ }
+
+ irq_changed( this );
+}
+
+int Emu_cpu_read( struct Hes_Emu* this, hes_addr_t addr )
+{
+ hes_time_t time = Cpu_time( &this->cpu );
+ addr &= page_size - 1;
+ switch ( addr )
+ {
+ case 0x0000:
+ if ( this->irq.vdp > time )
+ return 0;
+ this->irq.vdp = future_hes_time;
+ run_until( this, time );
+ irq_changed( this );
+ return 0x20;
+
+ case 0x0002:
+ case 0x0003:
+ dprintf( "VDP read not supported: %d\n", addr );
+ return 0;
+
+ case 0x0C01:
+ //return timer.enabled; // TODO: remove?
+ case 0x0C00:
+ run_until( this, time );
+ dprintf( "Timer count read\n" );
+ return (unsigned) (this->timer.count - 1) / this->timer_base;
+
+ case 0x1402:
+ return this->irq.disables;
+
+ case 0x1403:
+ {
+ int status = 0;
+ if ( this->irq.timer <= time ) status |= timer_mask;
+ if ( this->irq.vdp <= time ) status |= vdp_mask;
+ return status;
+ }
+
+ case 0x180A:
+ case 0x180B:
+ case 0x180C:
+ case 0x180D:
+ return Adpcm_read_data( &this->adpcm, time, addr );
+
+ #ifndef NDEBUG
+ case 0x1000: // I/O port
+ // case 0x180C: // CD-ROM
+ // case 0x180D:
+ break;
+
+ default:
+ dprintf( "unmapped read $%04X\n", addr );
+ #endif
+ }
+
+ return unmapped;
+}
+
+// see hes_cpu_io.h for core read/write functions
+
+// Emulation
+
+void run_until( struct Hes_Emu* this, hes_time_t present )
+{
+ while ( this->vdp.next_vbl < present )
+ this->vdp.next_vbl += this->play_period;
+
+ hes_time_t elapsed = present - this->timer.last_time;
+ if ( elapsed > 0 )
+ {
+ if ( this->timer.enabled )
+ {
+ this->timer.count -= elapsed;
+ if ( this->timer.count <= 0 )
+ this->timer.count += this->timer.load;
+ }
+ this->timer.last_time = present;
+ }
+}
+
+void irq_changed( struct Hes_Emu* this )
+{
+ hes_time_t present = Cpu_time( &this->cpu );
+
+ if ( this->irq.timer > present )
+ {
+ this->irq.timer = future_hes_time;
+ if ( this->timer.enabled && !this->timer.fired )
+ this->irq.timer = present + this->timer.count;
+ }
+
+ if ( this->irq.vdp > present )
+ {
+ this->irq.vdp = future_hes_time;
+ if ( this->vdp.control & 0x08 )
+ this->irq.vdp = this->vdp.next_vbl;
+ }
+
+ hes_time_t time = future_hes_time;
+ if ( !(this->irq.disables & timer_mask) ) time = this->irq.timer;
+ if ( !(this->irq.disables & vdp_mask) ) time = min( time, this->irq.vdp );
+
+ // Set cpu irq time
+ this->cpu.state->time += Cpu_update_end_time( &this->cpu, this->cpu.r.status,
+ this->cpu.end_time, (this->cpu.irq_time = time) );
+}
+
+static void adjust_time( blargg_long* time, hes_time_t delta ) ICODE_ATTR;
+static void adjust_time( blargg_long* time, hes_time_t delta )
+{
+ if ( *time < future_hes_time )
+ {
+ *time -= delta;
+ if ( *time < 0 )
+ *time = 0;
+ }
+}
+
+blargg_err_t run_clocks( struct Hes_Emu* this, blip_time_t* duration_ ) ICODE_ATTR;
+blargg_err_t run_clocks( struct Hes_Emu* this, blip_time_t* duration_ )
+{
+ blip_time_t duration = *duration_; // cache
+
+ Cpu_run( this, duration );
+ /* warning( "Emulation error (illegal instruction)" ); */
+
+ check( time() >= duration );
+ //check( time() - duration < 20 ); // Txx instruction could cause going way over
+
+ run_until( this, duration );
+
+ // end time frame
+ this->timer.last_time -= duration;
+ this->vdp.next_vbl -= duration;
+ #if defined (GME_FRAME_HOOK_DEFINED)
+ last_frame_hook -= *duration;
+ #endif
+
+ // End cpu frame
+ this->cpu.state_.base -= duration;
+ if ( this->cpu.irq_time < future_hes_time ) this->cpu.irq_time -= duration;
+ if ( this->cpu.end_time < future_hes_time ) this->cpu.end_time -= duration;
+
+ adjust_time( &this->irq.timer, duration );
+ adjust_time( &this->irq.vdp, duration );
+ Apu_end_frame( &this->apu, duration );
+ Adpcm_end_frame( &this->adpcm, duration );
+
+ return 0;
+}
+
+blargg_err_t play_( struct Hes_Emu* this, long count, sample_t* out ) ICODE_ATTR;
+blargg_err_t play_( struct Hes_Emu* this, long count, sample_t* out )
+{
+ long remain = count;
+ while ( remain )
+ {
+ remain -= Buffer_read_samples( &this->stereo_buf, &out [count - remain], remain );
+ if ( remain )
+ {
+ if ( this->buf_changed_count != Buffer_channels_changed_count( &this->stereo_buf ) )
+ {
+ this->buf_changed_count = Buffer_channels_changed_count( &this->stereo_buf );
+ // Remute voices
+ Sound_mute_voices( this, this->mute_mask_ );
+ }
+
+ int msec = Buffer_length( &this->stereo_buf );
+ blip_time_t clocks_emulated = (blargg_long) msec * this->clock_rate_ / 1000;
+ RETURN_ERR( run_clocks( this, &clocks_emulated ) );
+ assert( clocks_emulated );
+ Buffer_end_frame( &this->stereo_buf, clocks_emulated );
+ }
+ }
+ return 0;
+}
+
+
+// Music emu
+
+blargg_err_t Hes_set_sample_rate( struct Hes_Emu* this, long rate )
+{
+ require( !this->sample_rate_ ); // sample rate can't be changed once set
+ Buffer_init( &this->stereo_buf );
+ RETURN_ERR( Buffer_set_sample_rate( &this->stereo_buf, rate, 1000 / 20 ) );
+
+ // Set bass frequency
+ Buffer_bass_freq( &this->stereo_buf, 60 );
+
+ this->sample_rate_ = rate;
+ return 0;
+}
+
+void Sound_mute_voice( struct Hes_Emu* this, int index, bool mute )
+{
+ require( (unsigned) index < (unsigned) this->voice_count_ );
+ int bit = 1 << index;
+ int mask = this->mute_mask_ | bit;
+ if ( !mute )
+ mask ^= bit;
+ Sound_mute_voices( this, mask );
+}
+
+void Sound_mute_voices( struct Hes_Emu* this, int mask )
+{
+ require( this->sample_rate_ ); // sample rate must be set first
+ this->mute_mask_ = mask;
+
+ // Set adpcm voice
+ struct channel_t ch = Buffer_channel( &this->stereo_buf );
+ if ( mask & (1 << this->voice_count_ ) )
+ Adpcm_set_output( &this->adpcm, 0, 0, 0, 0 );
+ else
+ Adpcm_set_output( &this->adpcm, 0, ch.center, ch.left, ch.right );
+
+ // Set apu voices
+ int i = this->voice_count_ - 1;
+ for ( ; i--; )
+ {
+ if ( mask & (1 << i) )
+ {
+ Apu_osc_output( &this->apu, i, 0, 0, 0 );
+ }
+ else
+ {
+ assert( (ch.center && ch.left && ch.right) ||
+ (!ch.center && !ch.left && !ch.right) ); // all or nothing
+ Apu_osc_output( &this->apu, i, ch.center, ch.left, ch.right );
+ }
+ }
+}
+
+void Sound_set_tempo( struct Hes_Emu* this, double t )
+{
+ require( this->sample_rate_ ); // sample rate must be set first
+ double const min = 0.02;
+ double const max = 4.00;
+ if ( t < min ) t = min;
+ if ( t > max ) t = max;
+ this->play_period = (hes_time_t) (period_60hz / t);
+ this->timer_base = (int) (1024 / t);
+ recalc_timer_load( this );
+ this->tempo_ = t;
+}
+
+void fill_buf( struct Hes_Emu* this ) ICODE_ATTR;
+blargg_err_t Hes_start_track( struct Hes_Emu* this, int track )
+{
+ clear_track_vars( this );
+
+ // Remap track if playlist available
+ if ( this->m3u.size > 0 ) {
+ struct entry_t* e = &this->m3u.entries[track];
+ track = e->track;
+ }
+
+ this->current_track_ = track;
+
+ Buffer_clear( &this->stereo_buf );
+
+ memset( this->cpu.ram, 0, sizeof this->cpu.ram ); // some HES music relies on zero fill
+ memset( this->sgx, 0, sizeof this->sgx );
+
+ Apu_reset( &this->apu );
+ Adpcm_reset( &this->adpcm );
+ Cpu_reset( &this->cpu );
+
+ unsigned i;
+ for ( i = 0; i < sizeof this->header.banks; i++ )
+ Cpu_set_mmr( this, i, this->header.banks [i] );
+ Cpu_set_mmr( this, page_count, 0xFF ); // unmapped beyond end of address space
+
+ this->irq.disables = timer_mask | vdp_mask;
+ this->irq.timer = future_hes_time;
+ this->irq.vdp = future_hes_time;
+
+ this->timer.enabled = false;
+ this->timer.raw_load= 0x80;
+ this->timer.count = this->timer.load;
+ this->timer.fired = false;
+ this->timer.last_time = 0;
+
+ this->vdp.latch = 0;
+ this->vdp.control = 0;
+ this->vdp.next_vbl = 0;
+
+ this->cpu.ram [0x1FF] = (idle_addr - 1) >> 8;
+ this->cpu.ram [0x1FE] = (idle_addr - 1) & 0xFF;
+ this->cpu.r.sp = 0xFD;
+ this->cpu.r.pc = get_le16( this->header.init_addr );
+ this->cpu.r.a = track;
+
+ recalc_timer_load( this );
+ this->last_frame_hook = 0;
+
+ this->emu_track_ended_ = false;
+ this->track_ended = false;
+
+ if ( !this->ignore_silence )
+ {
+ // play until non-silence or end of track
+ long end;
+ for ( end =this-> max_initial_silence * stereo * this->sample_rate_; this->emu_time < end; )
+ {
+ fill_buf( this );
+ if ( this->buf_remain | (int) this->emu_track_ended_ )
+ break;
+ }
+
+ this->emu_time = this->buf_remain;
+ this->out_time = 0;
+ this->silence_time = 0;
+ this->silence_count = 0;
+ }
+ /* return track_ended() ? warning() : 0; */
+ return 0;
+}
+
+// Tell/Seek
+
+blargg_long msec_to_samples( blargg_long msec, long sample_rate )
+{
+ blargg_long sec = msec / 1000;
+ msec -= sec * 1000;
+ return (sec * sample_rate + msec * sample_rate / 1000) * stereo;
+}
+
+long Track_tell( struct Hes_Emu* this )
+{
+ blargg_long rate = this->sample_rate_ * stereo;
+ blargg_long sec = this->out_time / rate;
+ return sec * 1000 + (this->out_time - sec * rate) * 1000 / rate;
+}
+
+blargg_err_t Track_seek( struct Hes_Emu* this, long msec )
+{
+ blargg_long time = msec_to_samples( msec, this->sample_rate_ );
+ if ( time < this->out_time )
+ RETURN_ERR( Hes_start_track( this, this->current_track_ ) );
+ return Track_skip( this, time - this->out_time );
+}
+
+blargg_err_t skip_( struct Hes_Emu* this, long count ) ICODE_ATTR;
+blargg_err_t skip_( struct Hes_Emu* this, long count )
+{
+ // for long skip, mute sound
+ const long threshold = 30000;
+ if ( count > threshold )
+ {
+ int saved_mute = this->mute_mask_;
+ Sound_mute_voices( this, ~0 );
+
+ while ( count > threshold / 2 && !this->emu_track_ended_ )
+ {
+ RETURN_ERR( play_( this, buf_size, this->buf ) );
+ count -= buf_size;
+ }
+
+ Sound_mute_voices( this, saved_mute );
+ }
+
+ while ( count && !this->emu_track_ended_ )
+ {
+ long n = buf_size;
+ if ( n > count )
+ n = count;
+ count -= n;
+ RETURN_ERR( play_( this, n, this->buf ) );
+ }
+ return 0;
+}
+
+blargg_err_t Track_skip( struct Hes_Emu* this, long count )
+{
+ require( this->current_track_ >= 0 ); // start_track() must have been called already
+ this->out_time += count;
+
+ // remove from silence and buf first
+ {
+ long n = min( count, this->silence_count );
+ this->silence_count -= n;
+ count -= n;
+
+ n = min( count, this->buf_remain );
+ this->buf_remain -= n;
+ count -= n;
+ }
+
+ if ( count && !this->emu_track_ended_ )
+ {
+ this->emu_time += count;
+
+ // End track if error
+ if ( skip_( this, count ) )
+ this->emu_track_ended_ = true;
+ }
+
+ if ( !(this->silence_count | this->buf_remain) ) // caught up to emulator, so update track ended
+ this->track_ended |= this->emu_track_ended_;
+
+ return 0;
+}
+
+
+
+// Fading
+
+void Track_set_fade( struct Hes_Emu* this, long start_msec, long length_msec )
+{
+ this->fade_step = this->sample_rate_ * length_msec / (fade_block_size * fade_shift * 1000 / stereo);
+ this->fade_start = msec_to_samples( start_msec, this->sample_rate_ );
+}
+
+// unit / pow( 2.0, (double) x / step )
+static int int_log( blargg_long x, int step, int unit ) ICODE_ATTR;
+static int int_log( blargg_long x, int step, int unit )
+{
+ int shift = x / step;
+ int fraction = (x - shift * step) * unit / step;
+ return ((unit - fraction) + (fraction >> 1)) >> shift;
+}
+
+void handle_fade( struct Hes_Emu* this, long out_count, sample_t* out ) ICODE_ATTR;
+void handle_fade( struct Hes_Emu* this, long out_count, sample_t* out )
+{
+ int i;
+ for ( i = 0; i < out_count; i += fade_block_size )
+ {
+ int const shift = 14;
+ int const unit = 1 << shift;
+ int gain = int_log( (this->out_time + i - this->fade_start) / fade_block_size,
+ this->fade_step, unit );
+ if ( gain < (unit >> fade_shift) )
+ this->track_ended = this->emu_track_ended_ = true;
+
+ sample_t* io = &out [i];
+ int count;
+ for ( count = min( fade_block_size, out_count - i ); count; --count )
+ {
+ *io = (sample_t) ((*io * gain) >> shift);
+ ++io;
+ }
+ }
+}
+
+// Silence detection
+
+void emu_play( struct Hes_Emu* this, long count, sample_t* out ) ICODE_ATTR;
+void emu_play( struct Hes_Emu* this, long count, sample_t* out )
+{
+ check( current_track_ >= 0 );
+ this->emu_time += count;
+ if ( this->current_track_ >= 0 && !this->emu_track_ended_ ) {
+
+ // End track if error
+ if ( play_( this, count, out ) )
+ this->emu_track_ended_ = true;
+ }
+ else
+ memset( out, 0, count * sizeof *out );
+}
+
+// number of consecutive silent samples at end
+static long count_silence( sample_t* begin, long size ) ICODE_ATTR;
+static long count_silence( sample_t* begin, long size )
+{
+ sample_t first = *begin;
+ *begin = silence_threshold; // sentinel
+ sample_t* p = begin + size;
+ while ( (unsigned) (*--p + silence_threshold / 2) <= (unsigned) silence_threshold ) { }
+ *begin = first;
+ return size - (p - begin);
+}
+
+// fill internal buffer and check it for silence
+void fill_buf( struct Hes_Emu* this )
+{
+ assert( !this->buf_remain );
+ if ( !this->emu_track_ended_ )
+ {
+ emu_play( this, buf_size, this->buf );
+ long silence = count_silence( this->buf, buf_size );
+ if ( silence < buf_size )
+ {
+ this->silence_time = this->emu_time - silence;
+ this->buf_remain = buf_size;
+ return;
+ }
+ }
+ this->silence_count += buf_size;
+}
+
+blargg_err_t Hes_play( struct Hes_Emu* this, long out_count, sample_t* out )
+{
+ if ( this->track_ended )
+ {
+ memset( out, 0, out_count * sizeof *out );
+ }
+ else
+ {
+ require( this->current_track_ >= 0 );
+ require( out_count % stereo == 0 );
+
+ assert( this->emu_time >= this->out_time );
+
+ // prints nifty graph of how far ahead we are when searching for silence
+ //dprintf( "%*s \n", int ((emu_time - out_time) * 7 / sample_rate()), "*" );
+
+ long pos = 0;
+ if ( this->silence_count )
+ {
+ // during a run of silence, run emulator at >=2x speed so it gets ahead
+ long ahead_time = this->silence_lookahead * (this->out_time + out_count - this->silence_time) + this->silence_time;
+ while ( this->emu_time < ahead_time && !(this->buf_remain | this->emu_track_ended_) )
+ fill_buf( this );
+
+ // fill with silence
+ pos = min( this->silence_count, out_count );
+ memset( out, 0, pos * sizeof *out );
+ this->silence_count -= pos;
+
+ if ( this->emu_time - this->silence_time > silence_max * stereo * this->sample_rate_ )
+ {
+ this->track_ended = this->emu_track_ended_ = true;
+ this->silence_count = 0;
+ this->buf_remain = 0;
+ }
+ }
+
+ if ( this->buf_remain )
+ {
+ // empty silence buf
+ long n = min( this->buf_remain, out_count - pos );
+ memcpy( &out [pos], this->buf + (buf_size - this->buf_remain), n * sizeof *out );
+ this->buf_remain -= n;
+ pos += n;
+ }
+
+ // generate remaining samples normally
+ long remain = out_count - pos;
+ if ( remain )
+ {
+ emu_play( this, remain, out + pos );
+ this->track_ended |= this->emu_track_ended_;
+
+ if ( !this->ignore_silence || this->out_time > this->fade_start )
+ {
+ // check end for a new run of silence
+ long silence = count_silence( out + pos, remain );
+ if ( silence < remain )
+ this->silence_time = this->emu_time - silence;
+
+ if ( this->emu_time - this->silence_time >= buf_size )
+ fill_buf( this ); // cause silence detection on next play()
+ }
+ }
+
+ if ( this->out_time > this->fade_start )
+ handle_fade( this, out_count, out );
+ }
+ this->out_time += out_count;
+ return 0;
+}