/*
 * 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
 *
 */

#define GL_GLEXT_PROTOTYPES
#include "bcresources.h"
#include "bcsignals.h"
#include "bcsynchronous.h"
#include "bcwindowbase.h"
#include "condition.h"
#include "mutex.h"


#ifdef HAVE_GL
#include <GL/gl.h>
#endif
#include <unistd.h>

#include <string.h>


TextureID::TextureID(int window_id, int id, int w, int h, int components)
{
	this->window_id = window_id;
	this->id = id;
	this->w = w;
	this->h = h;
	this->components = components;
	in_use = 1;
}

ShaderID::ShaderID(int window_id, unsigned int handle,
		const char *vert, const char *frag)
{
	this->window_id = window_id;
	this->handle = handle;
	if( !vert ) vert = "";
	if( !frag ) frag = "";
	this->vert = cstrdup(vert);
	this->frag = cstrdup(frag);
}

ShaderID::~ShaderID()
{
	delete [] vert;
	delete [] frag;
}

#ifdef HAVE_GL
PBufferID::PBufferID(int window_id, GLXPbuffer glx_pbuffer, GLXContext glx_context, int w, int h)
{
	this->glx_pbuffer = glx_pbuffer;
	this->glx_context = glx_context;
	this->window_id = window_id;
	this->w = w;
	this->h = h;
	in_use = 1;
}
#endif



BC_SynchronousCommand::BC_SynchronousCommand()
{
	command = BC_SynchronousCommand::NONE;
	frame = 0;
	frame_return = 0;
	result = 0;
	command_done = new Condition(0, "BC_SynchronousCommand::command_done", 0);
}

BC_SynchronousCommand::~BC_SynchronousCommand()
{
	delete command_done;
}

void BC_SynchronousCommand::copy_from(BC_SynchronousCommand *command)
{
	this->command =		command->command;
	this->colormodel =	command->colormodel;
	this->window =		command->window;
	this->frame =		command->frame;
	this->window_id =	command->window_id;
	this->frame_return =	command->frame_return;
	this->id =		command->id;
	this->w =		command->w;
	this->h =		command->h;
}




BC_Synchronous::BC_Synchronous()
 : Thread(1, 0, 0)
{
	lock_sync = new Mutex("BC_Synchronous::lock_sync");
	next_command = new Condition(0, "BC_Synchronous::next_command", 1);
	command_lock = new Mutex("BC_Synchronous::command_lock");
	table_lock = new Mutex("BC_Synchronous::table_lock");
	done = 0;
	is_started = 0;
	current_window = 0;
	BC_WindowBase::get_resources()->set_synchronous(this);
}

BC_Synchronous::~BC_Synchronous()
{
	if( running() ) {
		quit();
	}
	join();
	commands.remove_all_objects();
	delete lock_sync;
	delete next_command;
	delete command_lock;
	delete table_lock;
}

void BC_Synchronous::sync_lock(const char *cp)
{
	lock_sync->lock(cp);
}

void BC_Synchronous::sync_unlock()
{
	lock_sync->unlock();
}

BC_SynchronousCommand* BC_Synchronous::new_command()
{
	return new BC_SynchronousCommand();
}

void BC_Synchronous::create_objects()
{
}

void BC_Synchronous::start()
{
	is_started = 1;
	//run();
	Thread::start();
}

void BC_Synchronous::quit()
{
	if( !is_started ) return;
	is_started = 0;
	BC_SynchronousCommand *command = BC_Synchronous::new_command();
	command->command = BC_SynchronousCommand::QUIT;
	send_garbage(command);
	command->command_done->lock("BC_Synchronous::quit");
	delete command;
}

long BC_Synchronous::send_command(BC_SynchronousCommand *command)
{
	BC_SynchronousCommand *command2 = new_command();
	command2->copy_from(command);
	command_lock->lock("BC_Synchronous::send_command");
	commands.append(command2);
	command_lock->unlock();
	next_command->unlock();
//printf("BC_Synchronous::send_command 1 %d\n", next_command->get_value());

// Wait for completion
	command2->command_done->lock("BC_Synchronous::send_command");
	long result = command2->result;
	delete command2;
	return result;
}

void BC_Synchronous::run()
{
	sync_lock("BC_Synchronous::run 0");
	while(!done) {
		command_lock->lock("BC_Synchronous::run");
		BC_SynchronousCommand *command = 0;
		if(commands.total) {
			command = commands.values[0];
			commands.remove_number(0);
		}
		command_lock->unlock();
		if( !command ) {
			sync_unlock();
			next_command->lock("BC_Synchronous::run");
			sync_lock("BC_Synchronous::run 1");
			continue;
		}
//printf("BC_Synchronous::run %d\n", command->command);
		handle_command_base(command);
	}
	sync_unlock();
}

void BC_Synchronous::handle_command_base(BC_SynchronousCommand *command)
{
	switch(command->command) {
	case BC_SynchronousCommand::QUIT:
		done = 1;
		command->command_done->unlock();
		return;

	case BC_SynchronousCommand::DELETE_WINDOW:
		delete_window_sync(command);
		command->command_done->unlock();
		return;

	case BC_SynchronousCommand::DELETE_PIXMAP:
		delete_pixmap_sync(command);
		break;

	case BC_SynchronousCommand::DELETE_DISPLAY:
		delete_display_sync(command);
		break;

	default:
		handle_command(command);
		command->command_done->unlock();
		return;
	}
	delete command;
}

void BC_Synchronous::handle_command(BC_SynchronousCommand *command)
{
}

void BC_Synchronous::put_texture(int id, int w, int h, int components)
{
	if( id >= 0 ) {
		table_lock->lock("BC_Resources::put_texture");
// Search for duplicate
		for( int i = 0; i < texture_ids.total; i++ ) {
			TextureID *ptr = texture_ids.values[i];
			if( ptr->window_id == current_window->get_id() && ptr->id == id ) {
				printf("BC_Synchronous::push_texture: texture exists\n"
					"exists: window=%d id=%d w=%d h=%d\n"
					"new:    window=%d id=%d w=%d h=%d\n",
					ptr->window_id, ptr->id, ptr->w, ptr->h,
					current_window->get_id(), id, w, h);
				table_lock->unlock();
				return;
			}
		}

		TextureID *new_id = new TextureID(current_window->get_id(),
			id, w, h, components);
		texture_ids.append(new_id);
		table_lock->unlock();
	}
}

int BC_Synchronous::get_texture(int w, int h, int components)
{
	table_lock->lock("BC_Resources::get_texture");
	for(int i = 0; i < texture_ids.total; i++)
	{
		if(texture_ids.values[i]->w == w &&
			texture_ids.values[i]->h == h &&
			texture_ids.values[i]->components == components &&
			!texture_ids.values[i]->in_use &&
			texture_ids.values[i]->window_id == current_window->get_id())
		{
			int result = texture_ids.values[i]->id;
			texture_ids.values[i]->in_use = 1;
			table_lock->unlock();
			return result;
		}
	}
	table_lock->unlock();
	return -1;
}

void BC_Synchronous::release_texture(int window_id, int id)
{
	table_lock->lock("BC_Resources::release_texture");
	for(int i = 0; i < texture_ids.total; i++)
	{
		if(texture_ids.values[i]->id == id &&
			texture_ids.values[i]->window_id == window_id)
		{
			texture_ids.values[i]->in_use = 0;
			table_lock->unlock();
			return;
		}
	}
	table_lock->unlock();
}





int BC_Synchronous::get_shader(unsigned int *handle,
		const char *vert, const char *frag)
{
	unsigned int shader = 0, ret = 0;
	if( !vert ) vert = "";
	if( !frag ) frag = "";
	table_lock->lock("BC_Resources::get_shader");
	for( int i=0; !ret && i<shader_ids.size(); ++i ) {
		ShaderID &sp = *shader_ids[i];
		if( sp.window_id == current_window->get_id() &&
		    !strcmp(sp.vert, vert) && !strcmp(sp.frag, frag) ) {
			shader = shader_ids.values[i]->handle;
			ret = 1;
		}
	}
	table_lock->unlock();
	*handle = shader;
	return ret;
}

void BC_Synchronous::put_shader(unsigned int handle,
		const char *vert, const char *frag)
{
	table_lock->lock("BC_Resources::put_shader");
	shader_ids.append(new ShaderID(current_window->get_id(), handle, vert, frag));
	table_lock->unlock();
}

void BC_Synchronous::dump_shader(unsigned int handle)
{
	int got_it = 0;
	table_lock->lock("BC_Resources::dump_shader");
	for( int i=0; i<shader_ids.size(); ++i ) {
		if( shader_ids.values[i]->handle == handle ) {
			printf("BC_Synchronous::dump_shader\n"
				"vert: %s\nfrag: %s\n",
				 shader_ids[i]->vert, shader_ids[i]->frag);
			got_it = 1;
			break;
		}
	}
	table_lock->unlock();
	if( !got_it )
		printf("BC_Synchronous::dump_shader couldn't find %d\n", handle);
}

void BC_Synchronous::delete_window(BC_WindowBase *window)
{
#ifdef HAVE_GL
	BC_SynchronousCommand *command = BC_Synchronous::new_command();
	command->command = BC_SynchronousCommand::DELETE_WINDOW;
	command->window_id = window->get_id();
	command->display = window->get_display();
	command->win = window->win;
	command->glx_win = window->glx_win;
	command->glx_context = window->glx_win_context;

	send_garbage(command);
	command->command_done->lock("BC_Synchronous::quit");
	delete command;
#endif
}

void BC_Synchronous::delete_window_sync(BC_SynchronousCommand *command)
{
#ifdef HAVE_GL
	int window_id = command->window_id;
	Display *display = command->display;
//	Window win = command->win;
	GLXWindow glx_win = command->glx_win;
	GLXContext glx_context = command->glx_context;
	XLockDisplay(display);
//int debug = 0;

// texture ID's are unique to different contexts
	glXMakeContextCurrent(display, glx_win, glx_win, glx_context);

	table_lock->lock("BC_Resources::release_textures");
	for(int i = 0; i < texture_ids.total; i++) {
		if(texture_ids.values[i]->window_id == window_id) {
			GLuint id = texture_ids.values[i]->id;
			glDeleteTextures(1, &id);
//if(debug) printf("BC_Synchronous::delete_window_sync texture_id=%d window_id=%d\n",
// id, window_id);
			texture_ids.remove_object_number(i);
			i--;
		}
	}

	for(int i = 0; i < shader_ids.total; i++)
	{
		if(shader_ids.values[i]->window_id == window_id)
		{
			glDeleteShader(shader_ids.values[i]->handle);
//if(debug)
//printf("BC_Synchronous::delete_window_sync shader_id=%d window_id=%d\n",
//shader_ids.values[i]->handle, window_id);
			shader_ids.remove_object_number(i);
			i--;
		}
	}

	for(int i = 0; i < pbuffer_ids.total; i++)
	{
		if(pbuffer_ids.values[i]->window_id == window_id)
		{
			glXDestroyPbuffer(display, pbuffer_ids.values[i]->glx_pbuffer);
			glXDestroyContext(display, pbuffer_ids.values[i]->glx_context);
//if(debug)
//printf("BC_Synchronous::delete_window_sync pbuffer_id=%p window_id=%d\n",
//  (void*)pbuffer_ids.values[i]->pbuffer, window_id);
			pbuffer_ids.remove_object_number(i);
			i--;
		}
	}


	table_lock->unlock();

	glXMakeContextCurrent(display, None, None, 0);
	if( glx_context )
		glXDestroyContext(display, glx_context);
// causes xerror BadWindow (invalid Window parameter)
//	XDestroyWindow(display, glx_win);
// win destroyed in bcwindowbase
	XUnlockDisplay(display);
#endif
}

void BC_Synchronous::delete_display(BC_WindowBase *window)
{
#ifdef HAVE_GL
	BC_SynchronousCommand *command = BC_Synchronous::new_command();
	command->command = BC_SynchronousCommand::DELETE_DISPLAY;
	command->display = window->get_display();

	send_garbage(command);
#endif
}

void BC_Synchronous::delete_display_sync(BC_SynchronousCommand *command)
{
#ifdef HAVE_GL
	Display *display = command->display;
	XLockDisplay(display);
	XUnlockDisplay(display);
	glXMakeContextCurrent(display, None, None, 0);
	XCloseDisplay(display);
#endif
}

#ifdef HAVE_GL
void BC_Synchronous::put_pbuffer(int w, int h,
		GLXPbuffer glx_pbuffer, GLXContext glx_context)
{
	int exists = 0;
	table_lock->lock("BC_Resources::release_textures");
	for(int i = 0; i < pbuffer_ids.total; i++) {
		PBufferID *ptr = pbuffer_ids.values[i];
		if( ptr->w == w && ptr->h == h && ptr->glx_pbuffer == glx_pbuffer ) {
			exists = 1;
			break;
		}
	}

	if(!exists) {
		PBufferID *ptr = new PBufferID(current_window->get_id(),
			glx_pbuffer, glx_context, w, h);
		pbuffer_ids.append(ptr);
	}
	table_lock->unlock();
}

GLXPbuffer BC_Synchronous::get_pbuffer(int w, int h, GLXContext *glx_context)
{
	table_lock->lock("BC_Resources::release_textures");
	for(int i = 0; i < pbuffer_ids.total; i++) {
		PBufferID *ptr = pbuffer_ids.values[i];
		if(ptr->w == w && ptr->h == h && !ptr->in_use &&
			ptr->window_id == current_window->get_id() ) {
			GLXPbuffer result = ptr->glx_pbuffer;
			*glx_context = ptr->glx_context;
			ptr->in_use = 1;
			table_lock->unlock();
			return result;
		}
	}
	table_lock->unlock();
	return 0;
}

void BC_Synchronous::release_pbuffer(int window_id, GLXPbuffer pbuffer)
{
	table_lock->lock("BC_Resources::release_textures");
	for(int i = 0; i < pbuffer_ids.total; i++) {
		PBufferID *ptr = pbuffer_ids.values[i];
		if( ptr->window_id == window_id &&
		    ptr->glx_pbuffer == pbuffer ) {
			ptr->in_use = 0;
		}
	}
	table_lock->unlock();
}

void BC_Synchronous::delete_pixmap(BC_WindowBase *window,
	GLXPixmap glx_pixmap, GLXContext glx_context)
{
	BC_SynchronousCommand *command = BC_Synchronous::new_command();
	command->command = BC_SynchronousCommand::DELETE_PIXMAP;
	command->window_id = window->get_id();
	command->display = window->get_display();
	command->win = window->win;
	command->glx_win = window->glx_win;
	command->glx_pixmap = glx_pixmap;
	command->glx_context = glx_context;

	send_garbage(command);
}
#endif

void BC_Synchronous::delete_pixmap_sync(BC_SynchronousCommand *command)
{
#ifdef HAVE_GL
	Display *display = command->display;
	GLXWindow glx_win = command->glx_win;
	XLockDisplay(display);
	glXMakeContextCurrent(display, glx_win, glx_win, command->glx_context);
	glXDestroyContext(display, command->glx_context);
	glXDestroyGLXPixmap(display, command->glx_pixmap);
	XUnlockDisplay(display);
#endif
}



void BC_Synchronous::send_garbage(BC_SynchronousCommand *command)
{
	command_lock->lock("BC_Synchronous::send_garbage");
	commands.append(command);
	command_lock->unlock();
	next_command->unlock();
}

BC_WindowBase* BC_Synchronous::get_window()
{
	return current_window;
}