WIP new AudioServer, with buses, effects, etc.

6 files changed, 411 insertions, 0 deletions

diff --git a/modules/stb_vorbis/SCsub b/modules/stb_vorbis/SCsub
new file mode 100644
index 0000000000..897d05961c
--- /dev/null
+++ b/modules/stb_vorbis/SCsub
@@ -0,0 +1,10 @@
+#!/usr/bin/env python
+
+Import('env')
+Import('env_modules')
+
+# Thirdparty source files
+
+env_stb_vorbis = env_modules.Clone()
+
+env_stb_vorbis.add_source_files(env.modules_sources, "*.cpp")
diff --git a/modules/stb_vorbis/audio_stream_ogg_vorbis.cpp b/modules/stb_vorbis/audio_stream_ogg_vorbis.cpp
new file mode 100644
index 0000000000..31bf5ac292
--- /dev/null
+++ b/modules/stb_vorbis/audio_stream_ogg_vorbis.cpp
@@ -0,0 +1,236 @@
+
+#include "audio_stream_ogg_vorbis.h"
+#include "thirdparty/stb_vorbis/stb_vorbis.c"
+#include "os/file_access.h"
+
+
+void AudioStreamPlaybackOGGVorbis::_mix_internal(AudioFrame* p_buffer,int p_frames) {
+
+	ERR_FAIL_COND(!active);
+
+	int todo=p_frames;
+
+	while(todo) {
+
+		int mixed = stb_vorbis_get_samples_float_interleaved(ogg_stream,2,(float*)p_buffer,todo*2);
+		todo-=mixed;
+
+		if (todo) {
+			//end of file!
+			if (false) {
+				//loop
+				seek_pos(0);
+				loops++;
+			} else {
+				for(int i=mixed;i<p_frames;i++) {
+					p_buffer[i]=AudioFrame(0,0);
+				}
+				active=false;
+			}
+		}
+	}
+
+
+}
+
+float AudioStreamPlaybackOGGVorbis::get_stream_sampling_rate() {
+
+	return vorbis_stream->sample_rate;
+}
+
+
+void AudioStreamPlaybackOGGVorbis::start(float p_from_pos) {
+
+	seek_pos(p_from_pos);
+	active=true;
+	loops=0;
+	_begin_resample();
+
+
+}
+
+void AudioStreamPlaybackOGGVorbis::stop() {
+
+	active=false;
+}
+bool AudioStreamPlaybackOGGVorbis::is_playing() const {
+
+	return active;
+}
+
+int AudioStreamPlaybackOGGVorbis::get_loop_count() const {
+
+	return loops;
+}
+
+float AudioStreamPlaybackOGGVorbis::get_pos() const {
+
+	return float(frames_mixed)/vorbis_stream->sample_rate;
+}
+void AudioStreamPlaybackOGGVorbis::seek_pos(float p_time) {
+
+	if (!active)
+		return;
+
+	stb_vorbis_seek(ogg_stream, uint32_t(p_time*vorbis_stream->sample_rate));
+}
+
+float AudioStreamPlaybackOGGVorbis::get_length() const {
+
+	return vorbis_stream->length;
+}
+
+AudioStreamPlaybackOGGVorbis::~AudioStreamPlaybackOGGVorbis() {
+	if (ogg_alloc.alloc_buffer) {
+		AudioServer::get_singleton()->audio_data_free(ogg_alloc.alloc_buffer);
+		stb_vorbis_close(ogg_stream);
+	}
+}
+
+Ref<AudioStreamPlayback> AudioStreamOGGVorbis::instance_playback() {
+
+
+
+	Ref<AudioStreamPlaybackOGGVorbis> ovs;
+	printf("instance at %p, data %p\n",this,data);
+
+	ERR_FAIL_COND_V(data==NULL,ovs);
+
+	ovs.instance();
+	ovs->vorbis_stream=Ref<AudioStreamOGGVorbis>(this);
+	ovs->ogg_alloc.alloc_buffer=(char*)AudioServer::get_singleton()->audio_data_alloc(decode_mem_size);
+	ovs->ogg_alloc.alloc_buffer_length_in_bytes=decode_mem_size;
+	ovs->frames_mixed=0;
+	ovs->active=false;
+	ovs->loops=0;
+	int error ;
+	ovs->ogg_stream = stb_vorbis_open_memory( (const unsigned char*)data, data_len, &error, &ovs->ogg_alloc );
+	if (!ovs->ogg_stream) {
+
+		AudioServer::get_singleton()->audio_data_free(ovs->ogg_alloc.alloc_buffer);
+		ovs->ogg_alloc.alloc_buffer=NULL;
+		ERR_FAIL_COND_V(!ovs->ogg_stream,Ref<AudioStreamPlaybackOGGVorbis>());
+	}
+
+	return ovs;
+}
+
+String AudioStreamOGGVorbis::get_stream_name() const {
+
+	return "";//return stream_name;
+}
+
+Error AudioStreamOGGVorbis::setup(const uint8_t *p_data,uint32_t p_data_len) {
+
+
+#define MAX_TEST_MEM (1<<20)
+
+	uint32_t alloc_try=1024;
+	PoolVector<char> alloc_mem;
+	PoolVector<char>::Write w;
+	stb_vorbis * ogg_stream=NULL;
+	stb_vorbis_alloc ogg_alloc;
+
+	while(alloc_try<MAX_TEST_MEM) {
+
+		alloc_mem.resize(alloc_try);
+		w = alloc_mem.write();
+
+		ogg_alloc.alloc_buffer=w.ptr();
+		ogg_alloc.alloc_buffer_length_in_bytes=alloc_try;
+
+		int error;
+		ogg_stream = stb_vorbis_open_memory( (const unsigned char*)p_data, p_data_len, &error, &ogg_alloc );
+
+		if (!ogg_stream && error==VORBIS_outofmem) {
+			w = PoolVector<char>::Write();
+			alloc_try*=2;
+		} else {
+			break;
+		}
+	}
+	ERR_FAIL_COND_V(alloc_try==MAX_TEST_MEM,ERR_OUT_OF_MEMORY);
+	ERR_FAIL_COND_V(ogg_stream==NULL,ERR_FILE_CORRUPT);
+
+	stb_vorbis_info info = stb_vorbis_get_info(ogg_stream);
+
+	channels = info.channels;
+	sample_rate = info.sample_rate;
+	decode_mem_size = alloc_try;
+	//does this work? (it's less mem..)
+	//decode_mem_size = ogg_alloc.alloc_buffer_length_in_bytes + info.setup_memory_required + info.temp_memory_required + info.max_frame_size;
+
+	//print_line("succeded "+itos(ogg_alloc.alloc_buffer_length_in_bytes)+" setup "+itos(info.setup_memory_required)+" setup temp "+itos(info.setup_temp_memory_required)+" temp "+itos(info.temp_memory_required)+" maxframe"+itos(info.max_frame_size));
+
+	length=stb_vorbis_stream_length_in_seconds(ogg_stream);
+	stb_vorbis_close(ogg_stream);
+
+	data = AudioServer::get_singleton()->audio_data_alloc(p_data_len,p_data);
+	data_len=p_data_len;
+
+	printf("create at %p, data %p\n",this,data);
+	return OK;
+}
+
+AudioStreamOGGVorbis::AudioStreamOGGVorbis() {
+
+
+	data=NULL;
+	length=0;
+	sample_rate=1;
+	channels=1;
+	decode_mem_size=0;
+}
+
+
+
+
+RES ResourceFormatLoaderAudioStreamOGGVorbis::load(const String &p_path, const String& p_original_path, Error *r_error) {
+	if (r_error)
+		*r_error=OK;
+
+	FileAccess *f = FileAccess::open(p_path,FileAccess::READ);
+	if (!f) {
+		*r_error=ERR_CANT_OPEN;
+		ERR_FAIL_COND_V(!f,RES());
+	}
+
+	size_t len = f->get_len();
+
+	PoolVector<uint8_t> data;
+	data.resize(len);
+	PoolVector<uint8_t>::Write w = data.write();
+
+	f->get_buffer(w.ptr(),len);
+
+	memdelete(f);
+
+	Ref<AudioStreamOGGVorbis> ogg_stream;
+	ogg_stream.instance();
+
+	Error err = ogg_stream->setup(w.ptr(),len);
+
+	if (err!=OK) {
+		*r_error=err;
+		ogg_stream.unref();
+		ERR_FAIL_V(RES());
+	}
+
+	return ogg_stream;
+}
+
+void ResourceFormatLoaderAudioStreamOGGVorbis::get_recognized_extensions(List<String> *p_extensions) const {
+
+	p_extensions->push_back("ogg");
+}
+String ResourceFormatLoaderAudioStreamOGGVorbis::get_resource_type(const String &p_path) const {
+
+	if (p_path.get_extension().to_lower()=="ogg")
+		return "AudioStreamOGGVorbis";
+	return "";
+}
+
+bool ResourceFormatLoaderAudioStreamOGGVorbis::handles_type(const String& p_type) const {
+	return (p_type=="AudioStream" || p_type=="AudioStreamOGG" || p_type=="AudioStreamOGGVorbis");
+}
+
diff --git a/modules/stb_vorbis/audio_stream_ogg_vorbis.h b/modules/stb_vorbis/audio_stream_ogg_vorbis.h
new file mode 100644
index 0000000000..4555423f85
--- /dev/null
+++ b/modules/stb_vorbis/audio_stream_ogg_vorbis.h
@@ -0,0 +1,84 @@
+#ifndef AUDIO_STREAM_STB_VORBIS_H
+#define AUDIO_STREAM_STB_VORBIS_H
+
+#include "servers/audio/audio_stream.h"
+#include "io/resource_loader.h"
+
+#define STB_VORBIS_HEADER_ONLY
+#include "thirdparty/stb_vorbis/stb_vorbis.c"
+#undef STB_VORBIS_HEADER_ONLY
+
+
+class AudioStreamOGGVorbis;
+
+class AudioStreamPlaybackOGGVorbis : public AudioStreamPlaybackResampled {
+
+	GDCLASS( AudioStreamPlaybackOGGVorbis, AudioStreamPlaybackResampled )
+
+	stb_vorbis * ogg_stream;
+	stb_vorbis_alloc ogg_alloc;
+	uint32_t frames_mixed;
+	bool active;
+	int loops;
+
+friend class AudioStreamOGGVorbis;
+
+	Ref<AudioStreamOGGVorbis> vorbis_stream;
+protected:
+
+	virtual void _mix_internal(AudioFrame* p_buffer, int p_frames);
+	virtual float get_stream_sampling_rate();
+
+public:
+	virtual void start(float p_from_pos=0.0);
+	virtual void stop();
+	virtual bool is_playing() const;
+
+	virtual int get_loop_count() const; //times it looped
+
+	virtual float get_pos() const;
+	virtual void seek_pos(float p_time);
+
+	virtual float get_length() const; //if supported, otherwise return 0
+
+	AudioStreamPlaybackOGGVorbis() {   }
+	~AudioStreamPlaybackOGGVorbis();
+};
+
+class AudioStreamOGGVorbis : public AudioStream {
+
+	GDCLASS( AudioStreamOGGVorbis, AudioStream )
+	OBJ_SAVE_TYPE( AudioStream ) //children are all saved as AudioStream, so they can be exchanged
+
+friend class AudioStreamPlaybackOGGVorbis;
+
+	void *data;
+	uint32_t data_len;
+
+	int decode_mem_size;
+	float sample_rate;
+	int channels;
+	float length;
+
+public:
+
+
+	virtual Ref<AudioStreamPlayback> instance_playback();
+	virtual String get_stream_name() const;
+
+	Error setup(const uint8_t *p_data, uint32_t p_data_len);
+
+	AudioStreamOGGVorbis();
+};
+
+class ResourceFormatLoaderAudioStreamOGGVorbis : public ResourceFormatLoader {
+public:
+	virtual RES load(const String &p_path,const String& p_original_path="",Error *r_error=NULL);
+	virtual void get_recognized_extensions(List<String> *p_extensions) const;
+	virtual bool handles_type(const String& p_type) const;
+	virtual String get_resource_type(const String &p_path) const;
+};
+
+
+
+#endif
diff --git a/modules/stb_vorbis/config.py b/modules/stb_vorbis/config.py
new file mode 100644
index 0000000000..fb920482f5
--- /dev/null
+++ b/modules/stb_vorbis/config.py
@@ -0,0 +1,7 @@
+
+def can_build(platform):
+    return True
+
+
+def configure(env):
+    pass
diff --git a/modules/stb_vorbis/register_types.cpp b/modules/stb_vorbis/register_types.cpp
new file mode 100644
index 0000000000..143ad6f47e
--- /dev/null
+++ b/modules/stb_vorbis/register_types.cpp
@@ -0,0 +1,44 @@
+/*************************************************************************/
+/*  register_types.cpp                                                   */
+/*************************************************************************/
+/*                       This file is part of:                           */
+/*                           GODOT ENGINE                                */
+/*                    http://www.godotengine.org                         */
+/*************************************************************************/
+/* Copyright (c) 2007-2017 Juan Linietsky, Ariel Manzur.                 */
+/*                                                                       */
+/* Permission is hereby granted, free of charge, to any person obtaining */
+/* a copy of this software and associated documentation files (the       */
+/* "Software"), to deal in the Software without restriction, including   */
+/* without limitation the rights to use, copy, modify, merge, publish,   */
+/* distribute, sublicense, and/or sell copies of the Software, and to    */
+/* permit persons to whom the Software is furnished to do so, subject to */
+/* the following conditions:                                             */
+/*                                                                       */
+/* The above copyright notice and this permission notice shall be        */
+/* included in all copies or substantial portions of the Software.       */
+/*                                                                       */
+/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,       */
+/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF    */
+/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
+/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY  */
+/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,  */
+/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE     */
+/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.                */
+/*************************************************************************/
+#include "register_types.h"
+#include "audio_stream_ogg_vorbis.h"
+
+static ResourceFormatLoaderAudioStreamOGGVorbis *vorbis_stream_loader = NULL;
+
+void register_stb_vorbis_types() {
+
+	vorbis_stream_loader = memnew( ResourceFormatLoaderAudioStreamOGGVorbis );
+	ResourceLoader::add_resource_format_loader(vorbis_stream_loader);
+	ClassDB::register_class<AudioStreamOGGVorbis>();
+}
+
+void unregister_stb_vorbis_types() {
+
+	memdelete( vorbis_stream_loader );
+}
diff --git a/modules/stb_vorbis/register_types.h b/modules/stb_vorbis/register_types.h
new file mode 100644
index 0000000000..2824aa9f0c
--- /dev/null
+++ b/modules/stb_vorbis/register_types.h
@@ -0,0 +1,30 @@
+/*************************************************************************/
+/*  register_types.h                                                     */
+/*************************************************************************/
+/*                       This file is part of:                           */
+/*                           GODOT ENGINE                                */
+/*                    http://www.godotengine.org                         */
+/*************************************************************************/
+/* Copyright (c) 2007-2017 Juan Linietsky, Ariel Manzur.                 */
+/*                                                                       */
+/* Permission is hereby granted, free of charge, to any person obtaining */
+/* a copy of this software and associated documentation files (the       */
+/* "Software"), to deal in the Software without restriction, including   */
+/* without limitation the rights to use, copy, modify, merge, publish,   */
+/* distribute, sublicense, and/or sell copies of the Software, and to    */
+/* permit persons to whom the Software is furnished to do so, subject to */
+/* the following conditions:                                             */
+/*                                                                       */
+/* The above copyright notice and this permission notice shall be        */
+/* included in all copies or substantial portions of the Software.       */
+/*                                                                       */
+/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,       */
+/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF    */
+/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
+/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY  */
+/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,  */
+/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE     */
+/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.                */
+/*************************************************************************/
+void register_stb_vorbis_types();
+void unregister_stb_vorbis_types();