--- /dev/null
+
+/*
+ * CINELERRA
+ * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
+ *
+ * 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ *
+ */
+
+#include "asset.h"
+#include "audiodevice.h"
+#include "bcdisplayinfo.h"
+#include "bcsignals.h"
+#include "clip.h"
+#include "bchash.h"
+#include "edlsession.h"
+#include "filexml.h"
+#include "guicast.h"
+#include "language.h"
+#include "mwindow.h"
+#include "pluginaclient.h"
+#include "pluginserver.h"
+#include "recordconfig.h"
+#include "samples.h"
+#include "transportque.inc"
+#include "vframe.h"
+
+#include <string.h>
+#include <stdint.h>
+
+class LiveAudio;
+class LiveAudioWindow;
+
+
+class LiveAudioConfig
+{
+public:
+ LiveAudioConfig();
+};
+
+
+
+
+
+
+class LiveAudioWindow : public PluginClientWindow
+{
+public:
+ LiveAudioWindow(LiveAudio *plugin);
+ ~LiveAudioWindow();
+
+ void create_objects();
+
+ LiveAudio *plugin;
+};
+
+
+
+
+
+
+class LiveAudio : public PluginAClient
+{
+public:
+ LiveAudio(PluginServer *server);
+ ~LiveAudio();
+
+
+ PLUGIN_CLASS_MEMBERS(LiveAudioConfig);
+
+ int process_buffer(int64_t size,
+ Samples **buffer,
+ int64_t start_position,
+ int sample_rate);
+ int is_realtime();
+ int is_multichannel();
+ int is_synthesis();
+ void save_data(KeyFrame *keyframe);
+ void read_data(KeyFrame *keyframe);
+ void update_gui();
+ void render_stop();
+
+ AudioDevice *adevice;
+
+ Samples **history;
+ int history_ptr;
+ int history_channels;
+ int64_t history_position;
+ int history_size;
+// Fragment size from the EDL session
+ int fragment_size;
+};
+
+
+
+
+
+
+
+
+
+
+
+
+LiveAudioConfig::LiveAudioConfig()
+{
+}
+
+
+
+
+
+
+
+
+LiveAudioWindow::LiveAudioWindow(LiveAudio *plugin)
+ : PluginClientWindow(plugin,
+ 300,
+ 160,
+ 300,
+ 160,
+ 0)
+{
+ this->plugin = plugin;
+}
+
+LiveAudioWindow::~LiveAudioWindow()
+{
+}
+
+void LiveAudioWindow::create_objects()
+{
+ int x = 10, y = 10;
+
+ BC_Title *title;
+ add_subwindow(title = new BC_Title(x, y, _("Live audio")));
+ show_window();
+ flush();
+}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+REGISTER_PLUGIN(LiveAudio)
+
+
+
+
+
+
+LiveAudio::LiveAudio(PluginServer *server)
+ : PluginAClient(server)
+{
+ adevice = 0;
+ history = 0;
+ history_channels = 0;
+ history_ptr = 0;
+ history_position = 0;
+ history_size = 0;
+
+ fragment_size = 0;
+}
+
+
+LiveAudio::~LiveAudio()
+{
+ if(adevice)
+ {
+ adevice->interrupt_crash();
+ adevice->close_all();
+ }
+ delete adevice;
+ if(history)
+ {
+ for(int i = 0; i < history_channels; i++)
+ delete history[i];
+ delete [] history;
+ }
+}
+
+
+
+int LiveAudio::process_buffer(int64_t size,
+ Samples **buffer,
+ int64_t start_position,
+ int sample_rate)
+{
+ load_configuration();
+
+// printf("LiveAudio::process_buffer 10 size=%lld buffer_size=%d channels=%d size=%d\n",
+// size, get_buffer_size(), get_total_buffers(), size);
+
+ int first_buffer = 0;
+
+ if(!adevice)
+ {
+ EDLSession *session = PluginClient::get_edlsession();
+ if(session)
+ {
+ fragment_size = session->record_fragment_size;
+ history_channels = session->aconfig_in->channels;
+
+ adevice = new AudioDevice(server ? server->mwindow : 0);
+// Take fragment size & channels from the recording config
+ adevice->open_input(session->aconfig_in,
+ session->vconfig_in,
+ get_project_samplerate(),
+ fragment_size,
+ session->aconfig_in->channels,
+ session->real_time_record);
+ adevice->start_recording();
+ first_buffer = 1;
+ history_position = start_position;
+ }
+ }
+
+ if(!history || history[0]->get_allocated() < size)
+ {
+// compute new history which is a multiple of our fragment size
+ int new_history_size = fragment_size;
+ while(new_history_size < size)
+ new_history_size += fragment_size;
+
+
+ if(!history)
+ {
+ history = new Samples*[history_channels];
+ for(int i = 0; i < history_channels; i++)
+ history[i] = 0;
+ }
+
+ for(int i = 0; i < history_channels; i++)
+ {
+ delete history[i];
+ history[i] = new Samples(new_history_size);
+ bzero(history[i]->get_data(), sizeof(double) * new_history_size);
+ }
+ }
+
+
+
+// if(get_direction() == PLAY_FORWARD)
+ {
+// Reset history buffer to current position if before maximum history
+ if(start_position < history_position - history[0]->get_allocated())
+ history_position = start_position;
+
+
+
+// Extend history buffer
+ int64_t end_position = start_position + size;
+// printf("LiveAudio::process_buffer %lld %lld %lld\n",
+// end_position,
+// history_position,
+// end_position - history_position);
+ if(end_position > history_position)
+ {
+// Reset history buffer to current position if after maximum history
+ if(start_position >= history_position + history[0]->get_allocated())
+ history_position = start_position;
+// A delay seems required because ALSA playback may get ahead of
+// ALSA recording and never recover.
+ if(first_buffer) end_position += sample_rate;
+ int done = 0;
+ while(!done && history_position < end_position)
+ {
+ if(history_ptr + fragment_size >= history[0]->get_allocated())
+ {
+ done = 1;
+ }
+
+// Read rest of buffer from sound driver
+ if(adevice)
+ {
+ int over[history_channels];
+ double max[history_channels];
+ int result = adevice->read_buffer(history,
+ history_channels,
+ fragment_size,
+ over,
+ max,
+ history_ptr);
+ if( result && adevice->config_updated() )
+ adevice->config_update();
+ }
+
+ history_ptr += fragment_size;
+// wrap around buffer
+ if(history_ptr >= history[0]->get_allocated())
+ history_ptr = 0;
+ history_position += fragment_size;
+ }
+ }
+
+// Copy data from history buffer
+ int buffer_position = 0;
+ int history_buffer_ptr = history_ptr - history_position + start_position;
+ while(history_buffer_ptr < 0)
+ history_buffer_ptr += history[0]->get_allocated();
+ while(buffer_position < size)
+ {
+ int fragment = size;
+ if(history_buffer_ptr + fragment > history[0]->get_allocated())
+ fragment = history[0]->get_allocated() - history_buffer_ptr;
+ if(buffer_position + fragment > size)
+ fragment = size - buffer_position;
+
+ for(int i = 0; i < get_total_buffers(); i++)
+ {
+ int input_channel = i;
+// Clamp channel to total history channels
+ if(input_channel >= history_channels)
+ input_channel = history_channels - 1;
+ memcpy(buffer[i]->get_data() + buffer_position,
+ history[input_channel]->get_data() + history_buffer_ptr,
+ sizeof(double) * fragment);
+ }
+
+ history_buffer_ptr += fragment;
+ if(history_buffer_ptr >= history[0]->get_allocated())
+ history_buffer_ptr = 0;
+ buffer_position += fragment;
+ }
+
+
+ }
+
+
+ return 0;
+}
+
+void LiveAudio::render_stop()
+{
+ if(adevice)
+ {
+ adevice->interrupt_crash();
+ adevice->close_all();
+ }
+ delete adevice;
+ adevice = 0;
+ history_ptr = 0;
+ history_position = 0;
+ history_size = 0;
+}
+
+
+const char* LiveAudio::plugin_title() { return _("Live Audio"); }
+int LiveAudio::is_realtime() { return 1; }
+int LiveAudio::is_multichannel() { return 1; }
+int LiveAudio::is_synthesis() { return 1; }
+
+
+
+NEW_WINDOW_MACRO(LiveAudio, LiveAudioWindow)
+
+
+
+int LiveAudio::load_configuration()
+{
+ return 0;
+}
+
+
+void LiveAudio::save_data(KeyFrame *keyframe)
+{
+}
+
+void LiveAudio::read_data(KeyFrame *keyframe)
+{
+}
+
+void LiveAudio::update_gui()
+{
+}
+
+
+
+
+
projects / goodguy / history.git / blobdiff