/*
 * CINELERRA
 * Copyright (C) 2009 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 "amodule.h"
#include "atrack.h"
#include "attachmentpoint.h"
#include "autoconf.h"
#include "bcsignals.h"
#include "cplayback.h"
#include "cstrdup.h"
#include "cwindow.h"
#include "edl.h"
#include "edlsession.h"
#include "file.h"
#include "floatautos.h"
#include "keyframes.h"
#include "localsession.h"
#include "mainerror.h"
#include "mainprogress.h"
#include "menueffects.h"
#include "mwindow.h"
#include "mwindowgui.h"
#include "playbackengine.h"
#include "plugin.h"
#include "pluginaclient.h"
#include "pluginaclientlad.h"
#include "pluginfclient.h"
#include "pluginclient.h"
#include "plugincommands.h"
#include "pluginserver.h"
#include "pluginvclient.h"
#include "preferences.h"
#include "samples.h"
#include "sema.h"
#include "mainsession.h"
#include "theme.h"
#include "trackcanvas.h"
#include "tracks.h"
#include "transportque.h"
#include "vdevicex11.h"
#include "vframe.h"
#include "videodevice.h"
#include "virtualanode.h"
#include "virtualvnode.h"
#include "vmodule.h"
#include "vtrack.h"


#include<stdio.h>
#include<unistd.h>
#include<fcntl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include<sys/stat.h>
#include <sys/mman.h>


void PluginServer::init()
{
	reset_parameters();
	this->plugin_type = PLUGIN_TYPE_UNKNOWN;
	plugin_obj = new PluginObj();
	modules = new ArrayList<Module*>;
	nodes = new ArrayList<VirtualNode*>;
	tip = 0;
	gui_id = -1;
	plugin_id = -1;
}

PluginServer::PluginServer()
{
	init();
}

PluginServer::PluginServer(MWindow *mwindow, const char *path, int type)
{
	char fpath[BCTEXTLEN];
	init();
	this->plugin_type = type;
	this->mwindow = mwindow;
	if( type == PLUGIN_TYPE_FFMPEG ) {
		ff_name = cstrdup(path);
		sprintf(fpath, "ff_%s", path);
		path = fpath;
	}
	set_path(path);
}

PluginServer::PluginServer(PluginServer &that)
{
	reset_parameters();
	plugin_type = that.plugin_type;
	plugin_obj = that.plugin_obj;
	plugin_obj->add_user();
	title = !that.title ? 0 : cstrdup(that.title);
	tip = !that.tip ? 0 : cstrdup(that.tip);
	path = !that.path ? 0 : cstrdup(that.path);
	ff_name = !that.ff_name ? 0 : cstrdup(that.ff_name);
	modules = new ArrayList<Module*>;
	nodes = new ArrayList<VirtualNode*>;

	attachment = that.attachment;
	realtime = that.realtime;
	multichannel = that.multichannel;
	preferences = that.preferences;
	synthesis = that.synthesis;
	audio = that.audio;
	video = that.video;
	theme = that.theme;
	fileio = that.fileio;
	uses_gui = that.uses_gui;
	mwindow = that.mwindow;
	keyframe = that.keyframe;
	new_plugin = that.new_plugin;

	lad_descriptor = that.lad_descriptor;
	lad_descriptor_function = that.lad_descriptor_function;
	lad_index = that.lad_index;
}

PluginServer::~PluginServer()
{
	close_plugin();
	delete [] path;
	delete [] ff_name;
	delete [] title;
	delete [] tip;
	delete modules;
	delete nodes;
	delete picon;
	plugin_obj->remove_user();
}

// Done only once at creation
int PluginServer::reset_parameters()
{
	mwindow = 0;
	keyframe = 0;
	prompt = 0;
	cleanup_plugin();

	plugin_obj = 0;
	client = 0; 
	new_plugin = 0;
	lad_index = -1;
	lad_descriptor_function = 0;
	lad_descriptor = 0;
	ff_name = 0;
	use_opengl = 0;
	vdevice = 0;
	plugin_type = 0;
	start_auto = end_auto = 0;
	autos = 0;
	reverse = 0;
	plugin_open = 0;
	realtime = multichannel = fileio = 0;
	synthesis = 0;
	audio = video = theme = 0;
	uses_gui = 0;
	transition = 0;
	title = 0;
	tip = 0;
	path = 0;
	data_text = 0;
	for( int i=sizeof(args)/sizeof(args[0]); --i>=0; ) args[i] = 0;
	total_args = 0; 
	dir_idx = 0;
	modules = 0;
	nodes = 0;
	attachmentpoint = 0;
	edl = 0;
	preferences = 0;
	prompt = 0;
	temp_frame = 0;
	picon = 0;

	return 0;
}

// Done every time the plugin is opened or closed
int PluginServer::cleanup_plugin()
{
	in_buffer_size = out_buffer_size = 0;
	total_in_buffers = total_out_buffers = 0;
	error_flag = 0;
	written_samples = 0;
	shared_buffers = 0;
	new_buffers = 0;
	written_samples = written_frames = 0;
	gui_on = 0;
	plugin_id = -1;
	plugin_open = 0;
	return 0;
}

void PluginServer::set_mwindow(MWindow *mwindow)
{
	this->mwindow = mwindow;
}

void PluginServer::set_attachmentpoint(AttachmentPoint *attachmentpoint)
{
	this->attachmentpoint = attachmentpoint;
}

void PluginServer::set_keyframe(KeyFrame *keyframe)
{
	this->keyframe = keyframe;
}

void PluginServer::set_prompt(MenuEffectPrompt *prompt)
{
	this->prompt = prompt;
}

void PluginServer::set_lad_index(int i)
{
	this->lad_index = i;
}

int PluginServer::get_lad_index()
{
	return this->lad_index;
}

int PluginServer::is_unknown()
{
	return plugin_type == PLUGIN_TYPE_UNKNOWN ? 1 : 0;
}

int PluginServer::is_executable()
{
	return  plugin_type == PLUGIN_TYPE_EXECUTABLE ? 1 : 0;
}

int PluginServer::is_builtin()
{
	return plugin_type == PLUGIN_TYPE_BUILTIN ? 1 : 0;
}

int PluginServer::is_ladspa()
{
	return plugin_type == PLUGIN_TYPE_LADSPA ? 1 : 0;
}

int PluginServer::is_ffmpeg()
{
	return plugin_type == PLUGIN_TYPE_FFMPEG ? 1 : 0;
}

int PluginServer::is_lv2()
{
	return plugin_type == PLUGIN_TYPE_LV2 ? 1 : 0;
}

void PluginServer::set_path(const char *path)
{
	delete [] this->path;
	this->path = cstrdup(path);
}

char* PluginServer::get_path()
{
	return this->path;
}

int PluginServer::get_synthesis()
{
	return synthesis;
}


void PluginServer::set_title(const char *string)
{
	delete [] title;
	title = cstrdup(string);
}

void PluginServer::generate_display_title(char *string)
{
	char ltitle[BCTEXTLEN];
	if( BC_Resources::locale_utf8 )
		strcpy(ltitle, _(title));
	else
		BC_Resources::encode(BC_Resources::encoding, 0,
				_(title),strlen(title)+1, ltitle,BCTEXTLEN);
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin && plugin->track )
		sprintf(string, "%s: %s", plugin->track->title, ltitle);
	else
		strcpy(string, ltitle);
}

void *PluginObj::load(const char *plugin_dir, const char *path)
{
	char dlpath[BCTEXTLEN], *dp = dlpath;
	const char *cp = path;
	if( *cp != '/' ) {
		const char *bp = plugin_dir;
		while( *bp ) *dp++ = *bp++;
		*dp++ = '/';
	}
	while( *cp ) *dp++ = *cp++;
	*dp = 0;
	return dlobj = load(dlpath);
}

int PluginServer::load_obj()
{
	void *obj = plugin_obj->obj();
	if( !obj ) obj =plugin_obj->load(preferences->plugin_dir, path);
	return obj ? 1 : 0;
}

const char *PluginServer::load_error()
{
	return plugin_obj->load_error();
}

void *PluginServer::get_sym(const char *sym)
{
	if( !plugin_obj->obj() ) return 0;
	return plugin_obj->load_sym(sym);
}

// Open plugin for signal processing
int PluginServer::open_plugin(int master,
	Preferences *preferences,
	EDL *edl,
	Plugin *plugin)
{
	if( plugin_open ) return 0;

	this->preferences = preferences;
	this->plugin_id = plugin ? plugin->orig_id : -1;
	this->edl = edl;
	if( !is_ffmpeg() && !is_lv2() && !is_executable() && !load_obj() ) {
// If the load failed, can't use error string to detect executable
//  because locale and language selection changes the load_error() message
//	if( !strstr(string, "executable") ) { set_title(path); plugin_type = PLUGIN_TYPE_EXECUTABLE; }
		eprintf("PluginServer::open_plugin: load_obj %s = %s\n", path, load_error());
		return PLUGINSERVER_NOT_RECOGNIZED;
	}
	if( is_unknown() || is_builtin() ) {
		new_plugin =
			(PluginClient* (*)(PluginServer*)) get_sym("new_plugin");
		if( new_plugin )
			plugin_type = PLUGIN_TYPE_BUILTIN;
	}
	if( is_unknown() || is_ladspa() ) {
		lad_descriptor_function =
			(LADSPA_Descriptor_Function) get_sym("ladspa_descriptor");
		if( lad_descriptor_function ) {
			if( lad_index < 0 ) return PLUGINSERVER_IS_LAD;
			lad_descriptor = lad_descriptor_function(lad_index);
			if( !lad_descriptor )
				return PLUGINSERVER_NOT_RECOGNIZED;
			plugin_type = PLUGIN_TYPE_LADSPA;
		}
	}
	if( is_unknown() ) {
		fprintf(stderr, "PluginServer::open_plugin "
			" %d: plugin undefined in %s\n", __LINE__, path);
		return PLUGINSERVER_NOT_RECOGNIZED;
	}
	switch( plugin_type ) {
	case PLUGIN_TYPE_EXECUTABLE:
		return PLUGINSERVER_OK;
	case PLUGIN_TYPE_BUILTIN:
		client = new_plugin(this);
		break;
	case PLUGIN_TYPE_FFMPEG:
		client = new_ffmpeg_plugin();
		break;
	case PLUGIN_TYPE_LADSPA:
		client = new PluginAClientLAD(this);
		break;
	case PLUGIN_TYPE_LV2:
		client = new_lv2_plugin();
		break;
	default:
		client = 0;
		break;
	}
	if( !client )
		return PLUGINSERVER_NOT_RECOGNIZED;

// Run initialization functions
	realtime = client->is_realtime();
// Don't load defaults when probing the directory.
	if( !master ) {
		if( realtime )
			client->load_defaults_xml();
		else
			client->load_defaults();
	}
	audio = client->is_audio();
	video = client->is_video();
	theme = client->is_theme();
	fileio = client->is_fileio();
	uses_gui = client->uses_gui();
	multichannel = client->is_multichannel();
	synthesis = client->is_synthesis();
	transition = client->is_transition();
	set_title(client->plugin_title());

//printf("PluginServer::open_plugin 2\n");
	plugin_open = 1;
	return PLUGINSERVER_OK;
}

int PluginServer::close_plugin()
{
	if( !plugin_open ) return 0;
	delete client;
	plugin_open = 0;
	cleanup_plugin();
	return 0;
}

void PluginServer::client_side_close()
{
// Last command executed in client thread
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		mwindow->hide_plugin(plugin, 1);
	else if( prompt ) {
		prompt->lock_window();
		prompt->set_done(1);
		prompt->unlock_window();
	}
}

void PluginServer::render_stop()
{
	if( client )
		client->render_stop();
	send_reset_gui_frames();
}

void PluginServer::write_table(FILE *fp, const char *path, int idx, int64_t mtime)
{
	if( !fp ) return;
	fprintf(fp, "%d \"%s\" \"%s\" %jd %d %d %d %d %d %d %d %d %d %d %d\n",
		plugin_type, path, title, mtime, idx, audio, video, theme, realtime,
		fileio, uses_gui, multichannel, synthesis, transition, lad_index);
}

int PluginServer::scan_table(char *text, int &type, char *path, char *title, int64_t &mtime)
{
	int n = sscanf(text, "%d \"%[^\"]\" \"%[^\"]\" %jd", &type, path, title, &mtime);
	return n < 4 ? 1 : 0;
}

int PluginServer::read_table(char *text)
{
	char path[BCTEXTLEN], title[BCTEXTLEN];
	int64_t mtime;
	int n = sscanf(text, "%d \"%[^\"]\" \"%[^\"]\" %jd %d %d %d %d %d %d %d %d %d %d %d",
		&plugin_type, path, title, &mtime, &dir_idx, &audio, &video, &theme, &realtime,
		&fileio, &uses_gui, &multichannel, &synthesis, &transition, &lad_index);
	if( n != 15 ) return 1;
	set_title(title);
	return 0;
}

int PluginServer::init_realtime(int realtime_sched,
		int total_in_buffers,
		int buffer_size)
{

	if( !plugin_open ) return 0;

// set for realtime priority
// initialize plugin
// Call start_realtime
	this->total_in_buffers = this->total_out_buffers = total_in_buffers;
	client->plugin_init_realtime(realtime_sched,
		total_in_buffers,
		buffer_size);

	return 0;
}


// Replaced by pull method but still needed for transitions
void PluginServer::process_transition(VFrame *input,
		VFrame *output,
		int64_t current_position,
		int64_t total_len)
{
	if( !plugin_open ) return;
	PluginVClient *vclient = (PluginVClient*)client;

	vclient->source_position = current_position;
	vclient->source_start = 0;
	vclient->total_len = total_len;

	vclient->input = new VFrame*[1];
	vclient->output = new VFrame*[1];

	vclient->input[0] = input;
	vclient->output[0] = output;

	vclient->process_realtime(input, output);
	vclient->age_temp();
	delete [] vclient->input;
	delete [] vclient->output;
	use_opengl = 0;
}

void PluginServer::process_transition(Samples *input,
		Samples *output,
		int64_t current_position,
		int64_t fragment_size,
		int64_t total_len)
{
	if( !plugin_open ) return;
	PluginAClient *aclient = (PluginAClient*)client;

	aclient->source_position = current_position;
	aclient->total_len = total_len;
	aclient->source_start = 0;
	aclient->process_realtime(fragment_size,
		input,
		output);
}


void PluginServer::process_buffer(VFrame **frame,
	int64_t current_position,
	double frame_rate,
	int64_t total_len,
	int direction)
{
	if( !plugin_open ) return;
	PluginVClient *vclient = (PluginVClient*)client;
	vclient->in_buffer_size = vclient->out_buffer_size = 1;
	vclient->source_position = current_position;
	vclient->total_len = total_len;
	vclient->frame_rate = frame_rate;
	vclient->input = new VFrame*[total_in_buffers];
	vclient->output = new VFrame*[total_in_buffers];
	for( int i = 0; i < total_in_buffers; i++ ) {
		vclient->input[i] = frame[i];
		vclient->output[i] = frame[i];
	}

	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin ) {
		vclient->source_start = (int64_t)plugin->startproject *
			frame_rate / vclient->project_frame_rate;
	}
	vclient->direction = direction;

//PRINT_TRACE
//printf("plugin=%p source_start=%ld\n", plugin, vclient->source_start);
//	vclient->begin_process_buffer();
	if( multichannel )
		vclient->process_buffer(frame, current_position, frame_rate);
	else
		vclient->process_buffer(frame[0], current_position, frame_rate);
//	vclient->end_process_buffer();

	for( int i = 0; i < total_in_buffers; i++ )
		frame[i]->push_prev_effect(title);

	delete [] vclient->input;
	delete [] vclient->output;

	vclient->age_temp();
	use_opengl = 0;
}

void PluginServer::process_buffer(Samples **buffer,
	int64_t current_position,
	int64_t fragment_size,
	int64_t sample_rate,
	int64_t total_len,
	int direction)
{
	if( !plugin_open ) return;
	PluginAClient *aclient = (PluginAClient*)client;
	aclient->source_position = current_position;
	aclient->total_len = total_len;
	aclient->sample_rate = sample_rate;
	aclient->in_buffer_size = aclient->out_buffer_size = fragment_size;
	aclient->output_buffers = buffer;

	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		aclient->source_start = plugin->startproject *
			sample_rate /
			aclient->project_sample_rate;

	aclient->direction = direction;
	aclient->begin_process_buffer();
	if( multichannel ) {
		aclient->process_buffer(fragment_size,
			buffer, current_position, sample_rate);
	}
	else {
		aclient->process_buffer(fragment_size,
			buffer[0], current_position, sample_rate);
	}
	aclient->end_process_buffer();
}


void PluginServer::send_reset_gui_frames()
{
	if( !attachmentpoint ) return;
	attachmentpoint->reset_gui_frames(this);
}

void PluginServer::send_render_gui(void *data)
{
	if( !attachmentpoint ) return;
	attachmentpoint->render_gui(data, this);
}

void PluginServer::send_render_gui(void *data, int size)
{
	if( !attachmentpoint ) return;
	attachmentpoint->render_gui(data, size, this);
}

void PluginServer::render_gui(void *data)
{
	if( !client ) return;
	client->plugin_render_gui(data);
}

void PluginServer::render_gui(void *data, int size)
{
	if( !client ) return;
	client->plugin_render_gui(data, size);
}


PluginGUIs::PluginGUIs(MWindow *mwindow)
{
	this->mwindow = mwindow;
	this->next_id = 0;
}
PluginGUIs::~PluginGUIs()
{
}

void PluginGUIs::append(PluginServer *server)
{
	server->gui_id = next_id++;
	ArrayList<PluginServer*>::append(server);
}

PluginServer *PluginGUIs::gui_server(int gui_id)
{
	for( int i=0; i<size(); ++i ) {
		PluginServer *plugin_server = get(i);
		if( plugin_server->gui_id == gui_id )
			return plugin_server;
	}
	return 0;
}


void PluginServer::reset_gui_frames()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		mwindow->reset_plugin_gui_frames(plugin);
}

void PluginServer::reset_plugin_gui_frames()
{
	if( !client ) return;
	client->plugin_reset_gui_frames();
}

void PluginServer::render_gui_frames(PluginClientFrames *frames)
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		mwindow->render_plugin_gui_frames(frames, plugin);
}

void PluginServer::render_plugin_gui_frames(PluginClientFrames *frames)
{
	if( !client ) return;
	client->plugin_render_gui_frames(frames);
}

MainProgressBar* PluginServer::start_progress(char *string, int64_t length)
{
	mwindow->gui->lock_window();
	MainProgressBar *result = mwindow->mainprogress->start_progress(string, length);
	mwindow->gui->unlock_window();
	return result;
}

int64_t PluginServer::get_written_samples()
{
	if( !plugin_open ) return 0;
	return written_samples;
}

int64_t PluginServer::get_written_frames()
{
	if( !plugin_open ) return 0;
	return written_frames;
}


// ======================= Non-realtime plugin

int PluginServer::get_parameters(int64_t start, int64_t end, int channels)
{
	if( !plugin_open ) return 0;

	client->start = start;
	client->end = end;
	client->source_start = start;
	client->total_len = end - start;
	client->total_in_buffers = channels;

//PRINT_TRACE
//printf(" source_start=%ld total_len=%ld\n", client->source_start, client->total_len);

	return client->plugin_get_parameters();
}

int PluginServer::set_interactive()
{
	if( !plugin_open ) return 0;
	client->set_interactive();
	return 0;
}

void PluginServer::append_module(Module *module)
{
	modules->append(module);
}

void PluginServer::append_node(VirtualNode *node)
{
	nodes->append(node);
}

void PluginServer::reset_nodes()
{
	nodes->remove_all();
}

int PluginServer::set_error()
{
	error_flag = 1;
	return 0;
}

int PluginServer::set_realtime_sched()
{
	//struct sched_param params;
	//params.sched_priority = 1;
	//sched_setscheduler(0, SCHED_RR, &param);
	return 0;
}


int PluginServer::process_loop(VFrame **buffers, int64_t &write_length)
{
	if( !plugin_open ) return 1;
	return client->plugin_process_loop(buffers, write_length);
}

int PluginServer::process_loop(Samples **buffers, int64_t &write_length)
{
	if( !plugin_open ) return 1;
	return client->plugin_process_loop(buffers, write_length);
}


int PluginServer::start_loop(int64_t start,
	int64_t end,
	int64_t buffer_size,
	int total_buffers)
{
	if( !plugin_open ) return 0;
	client->plugin_start_loop(start, end, buffer_size, total_buffers);
	return 0;
}

int PluginServer::stop_loop()
{
	if( !plugin_open ) return 0;
	return client->plugin_stop_loop();
}

int PluginServer::read_frame(VFrame *buffer,
	int channel,
	int64_t start_position)
{
	((VModule*)modules->values[channel])->render(buffer,
		start_position, PLAY_FORWARD,
		mwindow->edl->session->frame_rate, 0, 0);
	return 0;
}

int PluginServer::read_samples(Samples *buffer,
	int channel, int64_t sample_rate, int64_t start_position, int64_t len)
{
// len is now in buffer
	if( !multichannel ) channel = 0;

	if( nodes->total > channel )
		return ((VirtualANode*)nodes->values[channel])->read_data(buffer,
			len, start_position, sample_rate);
	if( modules->total > channel )
		return ((AModule*)modules->values[channel])->render(buffer,
			len, start_position, PLAY_FORWARD, sample_rate, 0);
	printf("PluginServer::read_samples no object available for channel=%d\n",
		channel);
	return -1;
}


int PluginServer::read_samples(Samples *buffer,
		int channel, int64_t start_position, int64_t size)
{
// total_samples is now set in buffer
	((AModule*)modules->values[channel])->render(buffer,
		size, start_position, PLAY_FORWARD,
		mwindow->edl->session->sample_rate, 0);
	return 0;
}

int PluginServer::read_frame(VFrame *buffer,
		int channel, int64_t start_position, double frame_rate,
		int use_opengl)
{
// Data source depends on whether we're part of a virtual console or a
// plugin array.
//     VirtualNode
//     Module
// If we're a VirtualNode, read_data in the virtual plugin node handles
//     backward propogation and produces the data.
// If we're a Module, render in the module produces the data.
//PRINT_TRACE

	int result = -1;
	if( !multichannel ) channel = 0;

// Push our name on the next effect stack
	buffer->push_next_effect(title);
//printf("PluginServer::read_frame %p\n", buffer);
//buffer->dump_stacks();

	if( nodes->total > channel ) {
//printf("PluginServer::read_frame %d\n", __LINE__);
		result = ((VirtualVNode*)nodes->values[channel])->read_data(buffer,
			start_position, frame_rate, use_opengl);
	}
	else
	if( modules->total > channel ) {
//printf("PluginServer::read_frame %d\n", __LINE__);
		result = ((VModule*)modules->values[channel])->render(buffer,
			start_position, //			PLAY_FORWARD,
			client->direction, frame_rate, 0, 0, use_opengl);
	}
	else {
		printf("PluginServer::read_frame no object available for channel=%d\n",
			channel);
	}

// Pop our name from the next effect stack
	buffer->pop_next_effect();

	return result;
}


// Called by client
int PluginServer::get_gui_status()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		return plugin->show ? GUI_ON : GUI_OFF;
	else
		return GUI_OFF;
}

void PluginServer::raise_window()
{
	if( !plugin_open ) return;
	client->raise_window();
}

void PluginServer::show_gui()
{
	if( !plugin_open ) return;
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin ) {
		plugin->gui_id = gui_id;
		client->total_len = plugin->length;
		client->source_start = plugin->startproject;
	}
	if( video ) {
		client->source_position = Units::to_int64(
			mwindow->edl->local_session->get_selectionstart(1) *
				mwindow->edl->session->frame_rate);
	}
	else
	if( audio ) {
		client->source_position = Units::to_int64(
			mwindow->edl->local_session->get_selectionstart(1) *
				mwindow->edl->session->sample_rate);
	}

	client->update_display_title();
	client->show_gui();
}

void PluginServer::hide_gui()
{
	if( !plugin_open ) return;
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin ) plugin->gui_id = -1;
	if( client->defaults ) client->save_defaults();
	client->hide_gui();
}

void PluginServer::update_gui()
{
	if( !plugin_open ) return;
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( !plugin ) return;

	client->total_len = plugin->length;
	client->source_start = plugin->startproject;

	if( video ) {
		client->source_position = Units::to_int64(
			mwindow->edl->local_session->get_selectionstart(1) *
				mwindow->edl->session->frame_rate);
	}
	else if( audio ) {
		client->source_position = Units::to_int64(
			mwindow->edl->local_session->get_selectionstart(1) *
				mwindow->edl->session->sample_rate);
	}

	client->plugin_update_gui();
}

void PluginServer::update_title()
{
	if( !plugin_open ) return;

	client->update_display_title();
}


int PluginServer::set_string(char *string)
{
	if( !plugin_open ) return 0;

	client->set_string_client(string);
	return 0;
}

int PluginServer::gui_open()
{
	if( attachmentpoint ) return attachmentpoint->gui_open();
	return 0;
}

void PluginServer::set_use_opengl(int value, VideoDevice *vdevice)
{
	this->use_opengl = value;
	this->vdevice = vdevice;
}

int PluginServer::get_use_opengl()
{
	return use_opengl;
}


void PluginServer::run_opengl(PluginClient *plugin_client)
{
	if( vdevice )
		((VDeviceX11*)vdevice->get_output_base())->run_plugin(plugin_client);
}

// ============================= queries

void PluginServer::get_defaults_path(char *path)
{
	char string2[BCTEXTLEN];
	switch( plugin_type ) {
	case PLUGIN_TYPE_FFMPEG:
	case PLUGIN_TYPE_LV2:
		strcpy(string2, client->plugin_title());
		break;
	case PLUGIN_TYPE_BUILTIN:
	case PLUGIN_TYPE_LADSPA:
	default: { // Get plugin name from path
		char *ptr1 = strrchr(get_path(), '/');
		char *ptr2 = strrchr(get_path(), '.');
		if( !ptr1 ) ptr1 = get_path();
		if( !ptr2 ) ptr2 = get_path() + strlen(get_path());
		char *ptr3 = string2;
		while( ptr1 < ptr2 ) *ptr3++ = *ptr1++;
		*ptr3 = 0;
		break; }
	}
	sprintf(path, "%s/%s.xml", File::get_config_path(), string2);
}

void PluginServer::save_defaults()
{
	if( client ) client->save_defaults();
}

int PluginServer::get_samplerate()
{
	if( !plugin_open ) return 0;
	if( audio )
		return client->get_samplerate();
	if( mwindow )
		return mwindow->edl->session->sample_rate;
	printf("PluginServer::get_samplerate audio and mwindow == NULL\n");
	return 1;
}


double PluginServer::get_framerate()
{
	if( !plugin_open ) return 0;
	if( video )
		return client->get_framerate();
	if( mwindow )
		return mwindow->edl->session->frame_rate;
	printf("PluginServer::get_framerate video and mwindow == NULL\n");
	return 1;
}

int PluginServer::get_project_samplerate()
{
	if( mwindow )
		return mwindow->edl->session->sample_rate;
	if( edl )
		return edl->session->sample_rate;
	printf("PluginServer::get_project_samplerate mwindow and edl are NULL.\n");
	return 1;
}

double PluginServer::get_project_framerate()
{
	if( mwindow )
		return mwindow->edl->session->frame_rate;
	if( edl )
		return edl->session->frame_rate;
	printf("PluginServer::get_project_framerate mwindow and edl are NULL.\n");
	return 1;
}


int PluginServer::detach_buffers()
{
	ring_buffers_out.remove_all();
	offset_out_render.remove_all();
	double_buffer_out_render.remove_all();
	realtime_out_size.remove_all();

	ring_buffers_in.remove_all();
	offset_in_render.remove_all();
	double_buffer_in_render.remove_all();
	realtime_in_size.remove_all();

	out_buffer_size = 0;
	shared_buffers = 0;
	total_out_buffers = 0;
	in_buffer_size = 0;
	total_in_buffers = 0;
	return 0;
}

int PluginServer::arm_buffer(int buffer_number,
		int64_t offset_in, int64_t offset_out,
		int double_buffer_in, int double_buffer_out)
{
	offset_in_render.values[buffer_number] = offset_in;
	offset_out_render.values[buffer_number] = offset_out;
	double_buffer_in_render.values[buffer_number] = double_buffer_in;
	double_buffer_out_render.values[buffer_number] = double_buffer_out;
	return 0;
}


int PluginServer::set_automation(FloatAutos *autos, FloatAuto **start_auto, FloatAuto **end_auto, int reverse)
{
	this->autos = autos;
	this->start_auto = start_auto;
	this->end_auto = end_auto;
	this->reverse = reverse;
	return 0;
}



void PluginServer::save_data(KeyFrame *keyframe)
{
	if( !plugin_open ) return;
	client->save_data(keyframe);
}

KeyFrame* PluginServer::get_prev_keyframe(int64_t position)
{
	KeyFrame *result = 0;
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		result = plugin->get_prev_keyframe(position, client->direction);
	else
		result = keyframe;
	return result;
}

KeyFrame* PluginServer::get_next_keyframe(int64_t position)
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	KeyFrame *result = !plugin ? 0 :
		plugin->get_next_keyframe(position, client->direction);
	return result;
}

// Called for
KeyFrame* PluginServer::get_keyframe()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
// Realtime plugin case
		return plugin->get_keyframe();
// Rendered plugin case
	return keyframe;
}


void PluginServer::apply_keyframe(KeyFrame *src)
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( !plugin )
		keyframe->copy_data(src);
	else if( plugin->is_transition() )
		plugin->get_keyframe()->copy_data(src);
	else
// Span keyframes
		plugin->keyframes->update_parameter(src);
}


void PluginServer::get_camera(float *x, float *y, float *z,
	int64_t position, int direction)
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		plugin->track->automation->get_camera(x, y, z, position, direction);
}

void PluginServer::get_projector(float *x, float *y, float *z,
	int64_t position, int direction)
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		plugin->track->automation->get_projector(x, y, z, position, direction);
}


int PluginServer::get_interpolation_type()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	if( plugin )
		return plugin->edl->session->interpolation_type;
	return NEAREST_NEIGHBOR;
}

Theme* PluginServer::new_theme()
{
	if( theme )
		return client->new_theme();
	return 0;
}

Theme* PluginServer::get_theme()
{
	if( mwindow ) return mwindow->theme;
	printf("PluginServer::get_theme mwindow not set\n");
	return 0;
}


void PluginServer::get_plugin_png_name(char *png_name)
{
	char *pp = png_name, *ep = pp + BCSTRLEN-1;
	char *cp = strrchr(path, '/');
	cp = !cp ? path : cp+1;
	char *sp = strrchr(cp, '.');
	if( !sp ) sp = cp+strlen(cp);
	while( pp < ep && cp < sp ) *pp++ = *cp++;
	snprintf(pp, ep-pp, ".png");
}

int PluginServer::get_plugin_png_path(char *png_path, const char *plugin_icons)
{
	char png_name[BCSTRLEN];
	get_plugin_png_name(png_name);
	char *pp = png_path, *ep = pp + BCTEXTLEN-1;
	pp += snprintf(pp, ep-pp, "%s/picon/%s/%s",
		File::get_plugin_path(), plugin_icons, png_name);
	return access(png_path,R_OK) ? 1 : 0;
}

int PluginServer::get_plugin_png_path(char *png_path)
{
	int ret = get_plugin_png_path(png_path, mwindow->preferences->plugin_icons);
	if( ret ) ret = get_plugin_png_path(png_path, DEFAULT_PICON);
	return ret;
}

VFrame *PluginServer::get_plugin_images()
{
	char png_path[BCTEXTLEN];
	if( !get_plugin_png_path(png_path) )
		return VFramePng::vframe_png(png_path,0,0);
	char png_name[BCSTRLEN];
	get_plugin_png_name(png_name);
	unsigned char *data = mwindow->theme->get_image_data(png_name, 0);
	return data ? new VFramePng(data, 0.) : 0;
}

VFrame *PluginServer::get_picon()
{
	if( !picon )
		picon = get_plugin_images();
	return picon;
}

// Called when plugin interface is tweeked
void PluginServer::sync_parameters()
{
	if( video ) mwindow->restart_brender();
	mwindow->sync_parameters();
	mwindow->update_keyframe_guis();
	if( mwindow->edl->session->auto_conf->plugins ) {
		mwindow->gui->lock_window("PluginServer::sync_parameters");
		mwindow->gui->draw_overlays(1);
		mwindow->gui->unlock_window();
	}
}

int64_t PluginServer::get_startproject()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	return !plugin ? -1 : plugin->startproject;
}
int64_t PluginServer::get_endproject()
{
	Plugin *plugin = edl->tracks->plugin_exists(plugin_id);
	return !plugin ? -1 : plugin->startproject + plugin->length;
}

void PluginServer::dump(FILE *fp)
{
	fprintf(fp,"    PluginServer %d %p %s %s %d\n",
		__LINE__, this, path, title, realtime);
}