diff options
Diffstat (limited to '')
| -rw-r--r-- | drivers/mpc/audio_stream_mpc.cpp | 389 |
1 files changed, 389 insertions, 0 deletions
diff --git a/drivers/mpc/audio_stream_mpc.cpp b/drivers/mpc/audio_stream_mpc.cpp new file mode 100644 index 000000000..91912c894 --- /dev/null +++ b/drivers/mpc/audio_stream_mpc.cpp @@ -0,0 +1,389 @@ +#include "audio_stream_mpc.h" + + +Error AudioStreamMPC::_open_file() { + + if (f) { + memdelete(f); + f=NULL; + } + Error err; + f=FileAccess::open(file,FileAccess::READ,&err); + + if (err) { + f=NULL; + ERR_FAIL_V(err); + return err; + } + + f->seek_end(0); + streamlen=f->get_pos(); + f->seek(0); + if (streamlen<=0) { + memdelete(f); + f=NULL; + ERR_FAIL_V(ERR_INVALID_DATA); + } + + data_ofs=0; + if (preload) { + + data.resize(streamlen); + DVector<uint8_t>::Write w = data.write(); + f->get_buffer(&w[0],streamlen); + memdelete(f); + f=NULL; + + } + + return OK; +} + +void AudioStreamMPC::_close_file() { + + if (f) { + memdelete(f); + f=NULL; + } + data.resize(0); + streamlen=0; + data_ofs=0; +} + +int AudioStreamMPC::_read_file(void *p_dst,int p_bytes) { + + if (f) + return f->get_buffer((uint8_t*)p_dst,p_bytes); + + DVector<uint8_t>::Read r = data.read(); + if (p_bytes+data_ofs > streamlen) { + p_bytes=streamlen-data_ofs; + } + + copymem(p_dst,&r[data_ofs],p_bytes); + //print_line("read file: "+itos(p_bytes)); + data_ofs+=p_bytes; + return p_bytes; +} + +bool AudioStreamMPC::_seek_file(int p_pos){ + + if (p_pos<0 || p_pos>streamlen) + return false; + + if (f) { + f->seek(p_pos); + return true; + } + + //print_line("read file to: "+itos(p_pos)); + data_ofs=p_pos; + return true; + +} +int AudioStreamMPC::_tell_file() const{ + + if (f) + return f->get_pos(); + + //print_line("tell file, get: "+itos(data_ofs)); + return data_ofs; + +} + +int AudioStreamMPC::_sizeof_file() const{ + + //print_line("sizeof file, get: "+itos(streamlen)); + return streamlen; +} + +bool AudioStreamMPC::_canseek_file() const{ + + //print_line("canseek file, get true"); + return true; +} + +///////////////////// + +mpc_int32_t AudioStreamMPC::_mpc_read(mpc_reader *p_reader,void *p_dst, mpc_int32_t p_bytes) { + + AudioStreamMPC *smpc=(AudioStreamMPC *)p_reader->data; + return smpc->_read_file(p_dst,p_bytes); +} + +mpc_bool_t AudioStreamMPC::_mpc_seek(mpc_reader *p_reader,mpc_int32_t p_offset) { + + AudioStreamMPC *smpc=(AudioStreamMPC *)p_reader->data; + return smpc->_seek_file(p_offset); + +} +mpc_int32_t AudioStreamMPC::_mpc_tell(mpc_reader *p_reader) { + + AudioStreamMPC *smpc=(AudioStreamMPC *)p_reader->data; + return smpc->_tell_file(); + +} +mpc_int32_t AudioStreamMPC::_mpc_get_size(mpc_reader *p_reader) { + + AudioStreamMPC *smpc=(AudioStreamMPC *)p_reader->data; + return smpc->_sizeof_file(); + + +} +mpc_bool_t AudioStreamMPC::_mpc_canseek(mpc_reader *p_reader) { + + AudioStreamMPC *smpc=(AudioStreamMPC *)p_reader->data; + return smpc->_canseek_file(); +} + + + +bool AudioStreamMPC::_can_mix() const { + + return active && !paused; +} + + +void AudioStreamMPC::update() { + + if (!active || paused) + return; + + int todo=get_todo(); + + while(todo>MPC_DECODER_BUFFER_LENGTH/si.channels) { + + mpc_frame_info frame; + + frame.buffer=sample_buffer; + + mpc_status err = mpc_demux_decode(demux, &frame); + if (frame.bits!=-1) { + + int16_t *dst_buff = get_write_buffer(); + +#ifdef MPC_FIXED_POINT + + for( int i = 0; i < frame.samples * si.channels; i++) { + int tmp = sample_buffer[i] >> MPC_FIXED_POINT_FRACTPART; + if (tmp > ((1 << 15) - 1)) tmp = ((1 << 15) - 1); + if (tmp < -(1 << 15)) tmp = -(1 << 15); + dst_buff[i] = tmp; + } +#else + for( int i = 0; i < frame.samples * si.channels; i++) { + + int tmp = Math::fast_ftoi(sample_buffer[i]*32767.0); + if (tmp > ((1 << 15) - 1)) tmp = ((1 << 15) - 1); + if (tmp < -(1 << 15)) tmp = -(1 << 15); + dst_buff[i] = tmp; + + } + +#endif + + int frames = frame.samples; + write(frames); + todo-=frames; + } else { + + if (err != MPC_STATUS_OK) { + + stop(); + ERR_EXPLAIN("Error decoding MPC"); + ERR_FAIL(); + } else { + + //finished + if (!loop) { + stop(); + return; + } else { + + + loops++; + mpc_demux_exit(demux); + _seek_file(0); + demux = mpc_demux_init(&reader); + //do loop somehow + + } + } + } + } +} + +Error AudioStreamMPC::_reload() { + + ERR_FAIL_COND_V(demux!=NULL, ERR_FILE_ALREADY_IN_USE); + + Error err = _open_file(); + ERR_FAIL_COND_V(err!=OK,ERR_CANT_OPEN); + + demux = mpc_demux_init(&reader); + ERR_FAIL_COND_V(!demux,ERR_CANT_CREATE); + + mpc_demux_get_info(demux, &si); + _setup(si.channels,si.sample_freq,MPC_DECODER_BUFFER_LENGTH*2/si.channels); + + return OK; +} + +void AudioStreamMPC::set_file(const String& p_file) { + + file=p_file; + +} + + +String AudioStreamMPC::get_file() const { + + return file; +} + + +void AudioStreamMPC::play() { + + + _THREAD_SAFE_METHOD_ + + if (active) + stop(); + active=false; + + Error err = _open_file(); + ERR_FAIL_COND(err!=OK); + if (_reload()!=OK) + return; + active=true; + loops=0; + +} + +void AudioStreamMPC::stop() { + + _THREAD_SAFE_METHOD_ + if (!active) + return; + if (demux) { + mpc_demux_exit(demux); + demux=NULL; + } + _close_file(); + active=false; + +} +bool AudioStreamMPC::is_playing() const { + + return active; +} + +void AudioStreamMPC::set_paused(bool p_paused) { + + paused=p_paused; +} +bool AudioStreamMPC::is_paused(bool p_paused) const { + + return paused; +} + +void AudioStreamMPC::set_loop(bool p_enable) { + + loop=p_enable; +} +bool AudioStreamMPC::has_loop() const { + + return loop; +} + +float AudioStreamMPC::get_length() const { + + return 0; +} + +String AudioStreamMPC::get_stream_name() const { + + return ""; +} + +int AudioStreamMPC::get_loop_count() const { + + return 0; +} + +float AudioStreamMPC::get_pos() const { + + return 0; +} +void AudioStreamMPC::seek_pos(float p_time) { + + +} + +AudioStream::UpdateMode AudioStreamMPC::get_update_mode() const { + + return UPDATE_THREAD; +} + +void AudioStreamMPC::_bind_methods() { + + ObjectTypeDB::bind_method(_MD("set_file","name"),&AudioStreamMPC::set_file); + ObjectTypeDB::bind_method(_MD("get_file"),&AudioStreamMPC::get_file); + + ADD_PROPERTYNZ( PropertyInfo(Variant::STRING,"file",PROPERTY_HINT_FILE,"mpc"), _SCS("set_file"), _SCS("get_file")); + +} + +AudioStreamMPC::AudioStreamMPC() { + + preload=true; + f=NULL; + streamlen=0; + data_ofs=0; + active=false; + paused=false; + loop=false; + demux=NULL; + reader.data=this; + reader.read=_mpc_read; + reader.seek=_mpc_seek; + reader.tell=_mpc_tell; + reader.get_size=_mpc_get_size; + reader.canseek=_mpc_canseek; + loops=0; + +} + +AudioStreamMPC::~AudioStreamMPC() { + + stop(); + + if (f) + memdelete(f); +} + + + +RES ResourceFormatLoaderAudioStreamMPC::load(const String &p_path,const String& p_original_path) { + + AudioStreamMPC *mpc_stream = memnew(AudioStreamMPC); + mpc_stream->set_file(p_path); + return Ref<AudioStreamMPC>(mpc_stream); +} + +void ResourceFormatLoaderAudioStreamMPC::get_recognized_extensions(List<String> *p_extensions) const { + + p_extensions->push_back("mpc"); +} +bool ResourceFormatLoaderAudioStreamMPC::handles_type(const String& p_type) const { + + return (p_type=="AudioStream") || (p_type=="AudioStreamMPC"); +} + +String ResourceFormatLoaderAudioStreamMPC::get_resource_type(const String &p_path) const { + + if (p_path.extension().to_lower()=="mpc") + return "AudioStreamMPC"; + return ""; +} + |