/*
 * 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 "bcsignals.h"
#include "byteorder.h"
#include "clip.h"
#include "edit.h"
#include "file.h"
#include "fileogg.h"
#include "guicast.h"
#include "interlacemodes.h"
#include "language.h"
#include "mainerror.h"
#include "mutex.h"
#include "mwindow.inc"
#include "preferences.h"
#include "render.h"
#include "vframe.h"
#include "versioninfo.h"
#include "videodevice.inc"

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>

#define READ_SIZE 3*66000

/* This code was aspired by ffmpeg2theora */
/* Special thanks for help on this code goes out to j@v2v.cc */

int ogg_ret0, ogg_ret1, ogg_ret2;

FileOGG::FileOGG(Asset *asset, File *file)
 : FileBase(asset, file)
{
	if(asset->format == FILE_UNKNOWN)
		asset->format = FILE_OGG;
	asset->byte_order = 0;
	reset_parameters();
	final_write = 1;
}

FileOGG::~FileOGG()
{
	if (tf)
	{

		if (tf->videosync)
		{
			ogg_sync_clear(&tf->videosync->sync);
			delete tf->videosync;
			theora_info_clear(&tf->ti);
			theora_comment_clear(&tf->tc);
		}
		if (tf->audiosync)
		{
			ogg_sync_clear(&tf->audiosync->sync);
			delete tf->audiosync;
			vorbis_info_clear(&tf->vi);
			vorbis_comment_clear(&tf->vc);
		}
		if (tf->vpage)
			free(tf->vpage);
		if (tf->apage)
			free(tf->apage);
		delete tf;
	}
	if (temp_frame) delete temp_frame;
	if (stream) close_file();
	if(pcm_history)
	{
		for(int i = 0; i < asset->channels; i++)
			delete [] pcm_history[i];
		delete [] pcm_history;
	}

	if (flush_lock) delete flush_lock;
}

void FileOGG::get_parameters(BC_WindowBase *parent_window,
	Asset *asset, BC_WindowBase* &format_window,
	int audio_options, int video_options, EDL *edl)
{
	if(audio_options)
	{
		OGGConfigAudio *window = new OGGConfigAudio(parent_window, asset);
		format_window = window;
		window->create_objects();
		window->run_window();
		delete window;
	}
	else
	if(video_options)
	{
		OGGConfigVideo *window = new OGGConfigVideo(parent_window, asset);
		format_window = window;
		window->create_objects();
		window->run_window();
		delete window;
	}
}

int FileOGG::reset_parameters_derived()
{
	tf = 0;
	temp_frame = 0;
	stream = 0;
	flush_lock = 0;
	pcm_history = 0;
	start_frame = 0;
	return 0;
}

static int read_buffer(FILE *in, sync_window_t *sw, int buflen)
{
	char *buffer = ogg_sync_buffer(&sw->sync, buflen);
//	printf("reading range: %lli - %lli\n", sw->file_bufpos, sw->file_bufpos + buflen);
	sw->wlen = fread(buffer, 1, buflen, in);
	ogg_sync_wrote(&sw->sync, sw->wlen);
//	printf("XX data: %c %c %c %c\n", sw->sync.data[0], sw->sync.data[1], sw->sync.data[2], sw->sync.data[3]);
	sw->file_bufpos += sw->wlen;
//	printf("sb: %i\n",buffer);
	return (sw->wlen);
}

static int read_buffer_at(FILE *in, sync_window_t *sw, int buflen, off_t filepos)
{
//	printf("seeking to %lli %lli\n", filepos, sw->file_bufpos);
	fseeko(in, filepos, SEEK_SET);
//	if (sw->file_bufpos != filepos)
//	{
		sw->file_bufpos = filepos;
		sw->file_pagepos = filepos; // this one is not valid until sync_pageseek!
		ogg_sync_reset(&sw->sync);

//	}
	return read_buffer(in, sw, buflen);
}

static int take_page_out_autoadvance(FILE *in, sync_window_t *sw, ogg_page *og)
{
	while (1)
	{
		int ret = ogg_sync_pageout(&sw->sync, og);
		if (ret > 0)
		{
//		printf("fpa: %lli\n", sw->file_pagepos);
// advance 'virtual' position
			sw->file_pagepos += og->header_len + og->body_len;
//		printf("ret2: %i %i\n",ret, og->header_len + og->body_len);
			return ret;
		}
		else if (ret < 0)
		{
			eprintf(_("FileOGG: Taking page out on nonsynced stream!\n"));
			return ret;

		} else
		{
			// need more data for page
			if ((ret = read_buffer(in, sw, READ_SIZE)) == 0)
			{
				printf(_("FileOGG: There is no more data in the file we are reading from\n"));
				return 0;  // No more data
			}
		}
	}
	return 1;
}


// we never need to autoadvance when syncing, since our read chunks are larger than
// maximum page size
static int sync_and_take_page_out(sync_window_t *sw, ogg_page *page)
{
	page->header_len = 0;
	page->body_len = 0;
	page->header = 0;
	page->body = 0;
	int ret = ogg_sync_pageseek(&sw->sync, page);
	if (ret < 0)
	{
		sw->file_pagepos -= ret;
	}
	else if (ret > 0)
	{
		sw->file_pagepos += ret;
//		printf("ret: %i %i\n",ret, page->header_len + page->body_len);
	}
	return ret;
}

int FileOGG::open_file(int rd, int wr)
{
	if (!tf)
	{
		tf = new theoraframes_info_t;
		memset(tf, 0, sizeof(*tf));
	}


	if(wr)
	{


		if((stream = fopen(asset->path, "w+b")) == 0)
		{
			eprintf(_("Error while opening \"%s\" for writing. %m\n"), asset->path);
			return 1;
		}

		tf->audio_bytesout = 0;
		tf->video_bytesout = 0;
		tf->videotime = 0;
		tf->audiotime = 0;

		tf->vpage_valid = 0;
		tf->apage_valid = 0;
		tf->apage_buffer_length = 0;
		tf->vpage_buffer_length = 0;
		tf->apage = NULL;
		tf->vpage = NULL;
		tf->v_pkg=0;
		tf->a_pkg=0;


		/* yayness.  Set up Ogg output stream */
		srand (time (NULL));

		if(asset->video_data)
		{
			ogg_stream_init (&tf->to, rand ());    /* oops, add one ot the above */

			theora_info_init (&tf->ti);

			tf->ti.frame_width = asset->width;
			tf->ti.frame_height = asset->height;

			tf->ti.width = ((asset->width + 15) >>4)<<4; // round up to the nearest multiple of 16
			tf->ti.height = ((asset->height + 15) >>4)<<4; // round up to the nearest multiple of 16
			if (tf->ti.width != tf->ti.frame_width || tf->ti.height != tf->ti.frame_height)
			{
				eprintf(_("WARNING: Encoding theora when width or height are not dividable by 16 is suboptimal\n"));
			}

			tf->ti.offset_x = 0;
			tf->ti.offset_y = tf->ti.height - tf->ti.frame_height;
			tf->ti.fps_numerator = (unsigned int)(asset->frame_rate * 1000000);
			tf->ti.fps_denominator = 1000000;

			if (asset->aspect_ratio > 0)
			{
				// Cinelerra uses frame aspect ratio, theora uses pixel aspect ratio
				float pixel_aspect = asset->aspect_ratio / asset->width * asset->height;
				tf->ti.aspect_numerator = (unsigned int)(pixel_aspect * 1000000);
				tf->ti.aspect_denominator = 1000000;
			} else
			{
				tf->ti.aspect_numerator = 1000000;
				tf->ti.aspect_denominator = 1000000;
			}
			if(EQUIV(asset->frame_rate, 25) || EQUIV(asset->frame_rate, 50))
				tf->ti.colorspace = OC_CS_ITU_REC_470BG;
			else if((asset->frame_rate > 29 && asset->frame_rate < 31) || (asset->frame_rate > 59 && asset->frame_rate < 61) )
				tf->ti.colorspace = OC_CS_ITU_REC_470M;
			else
				tf->ti.colorspace = OC_CS_UNSPECIFIED;

			if (asset->theora_fix_bitrate)
			{
				tf->ti.target_bitrate = asset->theora_bitrate;
				tf->ti.quality = 0;
			} else
			{
				tf->ti.target_bitrate = 0;
				tf->ti.quality = asset->theora_quality;     // video quality 0-63
			}
			tf->ti.dropframes_p = 0;
			tf->ti.quick_p = 1;
			tf->ti.keyframe_auto_p = 1;
			tf->ti.keyframe_frequency = asset->theora_keyframe_frequency;
			tf->ti.keyframe_frequency_force = asset->theora_keyframe_force_frequency;
			tf->ti.keyframe_data_target_bitrate = (unsigned int) (tf->ti.target_bitrate * 1.5) ;
			tf->ti.keyframe_auto_threshold = 80;
			tf->ti.keyframe_mindistance = 8;
			tf->ti.noise_sensitivity = 1;
			tf->ti.sharpness = 2;


			if (theora_encode_init (&tf->td, &tf->ti))
			{
				eprintf(_("(FileOGG:file_open) initialization of theora codec failed\n"));
			}
		}
		/* init theora done */

		/* initialize Vorbis too, if we have audio. */
		if(asset->audio_data)
		{
			ogg_stream_init (&tf->vo, rand ());
			vorbis_info_init (&tf->vi);
			/* Encoding using a VBR quality mode.  */
			int ret;
			if(!asset->vorbis_vbr)
			{
				ret = vorbis_encode_init(&tf->vi,
			    				asset->channels,
			    				asset->sample_rate,
			    				asset->vorbis_max_bitrate,
			    				asset->vorbis_bitrate,
			    				asset->vorbis_min_bitrate);
			} else
			{
				// Set true VBR as demonstrated by http://svn.xiph.org/trunk/vorbis/doc/vorbisenc/examples.html
				ret = vorbis_encode_setup_managed(&tf->vi,
					asset->channels,
					asset->sample_rate,
					-1,
					asset->vorbis_bitrate,
					-1);
				ret |= vorbis_encode_ctl(&tf->vi, OV_ECTL_RATEMANAGE_AVG, NULL);
				ret |= vorbis_encode_setup_init(&tf->vi);
			}

			if (ret)
			{
				eprintf(_("The Vorbis encoder could not set up a mode according to\n"
					"the requested quality or bitrate.\n\n"));
				fclose (stream);
				stream = 0;
				return 1;
			}

			vorbis_comment_init (&tf->vc); // comment is cleared lateron
			vorbis_comment_add_tag (&tf->vc, (char*)"ENCODER", (char*)PROGRAM_NAME " " CINELERRA_VERSION);
			/* set up the analysis state and auxiliary encoding storage */
			vorbis_analysis_init (&tf->vd, &tf->vi);
			vorbis_block_init (&tf->vd, &tf->vb);

		}
		/* audio init done */

		/* write the bitstream header packets with proper page interleave */

		/* first packet will get its own page automatically */
		if(asset->video_data)
		{
			theora_encode_header (&tf->td, &tf->op);
			ogg_stream_packetin (&tf->to, &tf->op);
			if (ogg_stream_pageout (&tf->to, &tf->og) != 1)
			{
				eprintf(_("Internal Ogg library error.\n"));
				return 1;
			}
			fwrite (tf->og.header, 1, tf->og.header_len, stream);
			fwrite (tf->og.body, 1, tf->og.body_len, stream);

			/* create the remaining theora headers */
			theora_comment_init (&tf->tc);
			theora_comment_add_tag (&tf->tc, (char*)"ENCODER",
					(char*)PROGRAM_NAME " " CINELERRA_VERSION);
			theora_encode_comment (&tf->tc, &tf->op);
			ogg_stream_packetin (&tf->to, &tf->op);
			theora_comment_clear(&tf->tc);
			theora_encode_tables (&tf->td, &tf->op);
			ogg_stream_packetin (&tf->to, &tf->op);
		}
		if(asset->audio_data)
		{
			ogg_packet header;
			ogg_packet header_comm;
			ogg_packet header_code;

			vorbis_analysis_headerout (&tf->vd, &tf->vc, &header,
				       &header_comm, &header_code);
			ogg_stream_packetin (&tf->vo, &header);    /* automatically placed in its own page */
			vorbis_comment_clear(&tf->vc);
			if (ogg_stream_pageout (&tf->vo, &tf->og) != 1)
			{
				eprintf(_("Internal Ogg library error.\n"));
				return 1;
			}
			fwrite (tf->og.header, 1, tf->og.header_len, stream);
			fwrite (tf->og.body, 1, tf->og.body_len, stream);

			/* remaining vorbis header packets */
			ogg_stream_packetin (&tf->vo, &header_comm);
			ogg_stream_packetin (&tf->vo, &header_code);
		}

		/* Flush the rest of our headers. This ensures
		 * the actual data in each stream will start
		 * on a new page, as per spec. */
		while (1 && asset->video_data)
		{
			int result = ogg_stream_flush (&tf->to, &tf->og);
			if (result < 0)
			{
				/* can't get here */
				eprintf(_("Internal Ogg library error.\n"));
				return 1;
			}
			if (result == 0)
				break;
			fwrite (tf->og.header, 1, tf->og.header_len, stream);
			fwrite (tf->og.body, 1, tf->og.body_len, stream);
		}
		while (1 && asset->audio_data)
		{
			int result = ogg_stream_flush (&tf->vo, &tf->og);
			if (result < 0)
			{
				/* can't get here */
				eprintf(_("Internal Ogg library error.\n"));
				return 1;
			}
			if (result == 0)
				break;
			fwrite (tf->og.header, 1, tf->og.header_len, stream);
			fwrite (tf->og.body, 1, tf->og.body_len, stream);
		}
		flush_lock = new Mutex("OGGFile::Flush lock");
//		printf("End of headers at position: %lli\n", ftello(stream));
	} else
	if (rd)
	{

		if((stream = fopen(asset->path, "rb")) == 0)
		{
			eprintf(_("Error while opening %s for reading. %m\n"), asset->path);
			return 1;
		}

		/* get file length */
		struct stat file_stat;
		stat(asset->path, &file_stat);
		file_length = file_stat.st_size;

		/* start up Ogg stream synchronization layer */
		/* oy is used just here to parse header, we use separate syncs for video and audio*/
		sync_window_t oy;
		ogg_sync_init(&oy.sync);
		// make sure we init the position structures to zero
		read_buffer_at(stream, &oy, READ_SIZE, 0);


		/* init supporting Vorbis structures needed in header parsing */
		vorbis_info_init(&tf->vi);
		vorbis_comment_init(&tf->vc);


		/* init supporting Theora structures needed in header parsing */
		theora_comment_init(&tf->tc);
		theora_info_init(&tf->ti);



		/* Ogg file open; parse the headers */
		/* Only interested in Vorbis/Theora streams */
		int stateflag = 0;
		int theora_p = 0;
		int vorbis_p = 0;
		while(!stateflag)
		{


//			int ret = read_buffer(stream, &oy, 4096);
			TRACE("FileOGG::open_file 60")
//			if(ret == 0)
//				break;

			while(take_page_out_autoadvance(stream, &oy, &tf->og) > 0)
			{
				ogg_stream_state test;

				/* is this a mandated initial header? If not, stop parsing */
				if(!ogg_page_bos(&tf->og))
				{
					/* don't leak the page; get it into the appropriate stream */
				//	queue_page(&tf->og);
					if(theora_p)ogg_stream_pagein(&tf->to, &tf->og);
					if(vorbis_p)ogg_stream_pagein(&tf->vo, &tf->og);

					stateflag = 1;
					break;
				}

				ogg_stream_init(&test, ogg_page_serialno(&tf->og));
				ogg_stream_pagein(&test, &tf->og);
				ogg_stream_packetout(&test, &tf->op);

				/* identify the codec: try theora */
				if(!theora_p && theora_decode_header(&tf->ti, &tf->tc, &tf->op)>=0)
				{
					/* it is theora */
					memcpy(&tf->to, &test, sizeof(test));
					theora_p = 1;
	// find out granule shift - from liboggz's oggz_auto.c
					unsigned char * header = tf->op.packet;
					theora_keyframe_granule_shift = (char) ((header[40] & 0x03) << 3);
					theora_keyframe_granule_shift |= (header[41] & 0xe0) >> 5;

				} else if(!vorbis_p && vorbis_synthesis_headerin(&tf->vi, &tf->vc, &tf->op)>=0)
				{
					/* it is vorbis */
					memcpy(&tf->vo, &test, sizeof(test));
					vorbis_p = 1;
				} else
				{
					/* whatever it is, we don't care about it */
					ogg_stream_clear(&test);
				}
			}
		/* fall through to non-bos page parsing */
		}


		/* we're expecting more header packets. */
		while((theora_p && theora_p < 3) || (vorbis_p && vorbis_p < 3))
		{
			int ret;

			/* look for further theora headers */
			while(theora_p && (theora_p < 3) && (ret = ogg_stream_packetout(&tf->to, &tf->op)))
			{
				if(ret < 0)
				{
					eprintf(_("FileOGG: Error parsing Theora stream headers; corrupt stream?\n"));
					return 1;
				}
				if(theora_decode_header(&tf->ti, &tf->tc, &tf->op))
				{
					eprintf(_("FileOGG: Error parsing Theora stream headers; corrupt stream?\n"));
					return 1;
				}
				theora_p++;
				if(theora_p == 3)
					break;
			}

			/* look for more vorbis header packets */
			while(vorbis_p && (vorbis_p < 3) && (ret = ogg_stream_packetout(&tf->vo, &tf->op)))
			{
				if(ret<0)
				{
					eprintf(_("FileOGG: Error parsing Vorbis stream headers; corrupt stream?\n"));
					return 1;
				}
				if (vorbis_synthesis_headerin(&tf->vi, &tf->vc, &tf->op))
				{
					eprintf(_("FileOGG: Error parsing Vorbis stream headers; corrupt stream?\n"));
					return 1;
				}
				vorbis_p++;
				if (vorbis_p == 3)
					break;
			}

			if ((!vorbis_p || vorbis_p == 3) && (!theora_p || theora_p == 3))
				break;
			/* The header pages/packets will arrive before anything else we
			    care about, or the stream is not obeying spec */

			if(take_page_out_autoadvance(stream, &oy, &tf->og) > 0)
			{
//				queue_page(&tf->og); /* demux into the appropriate stream */
				if(theora_p) ogg_stream_pagein(&tf->to, &tf->og);
				if(vorbis_p) ogg_stream_pagein(&tf->vo, &tf->og);

			} else
			{
				eprintf(_("FileOGG: End of file while searching for codec headers.\n"));
				return 1;
			}
		}
		// Remember where the real data begins for later seeking purposes
		filedata_begin = oy.file_pagepos;



		/* and now we have it all.  initialize decoders */
		if(theora_p)
		{
			int ret;

// WORKAROUND for bug in alpha4 version of theora:
			tf->td.internal_encode = 0;

			ret = theora_decode_init(&tf->td, &tf->ti);
			if( ret ) printf("theora_decode_init ret=%d\n", ret);
			double fps = (double)tf->ti.fps_numerator/tf->ti.fps_denominator;
/*			printf("FileOGG: Ogg logical stream %x is Theora %dx%d %.02f fps\n",
				(unsigned int)tf->to.serialno, tf->ti.width, tf->ti.height,
				fps);
*/
/*
Not yet available in alpha4, we assume 420 for now

			switch(tf->ti.pixelformat)
			{
				case OC_PF_420: printf(" 4:2:0 video\n"); break;
				case OC_PF_422: printf(" 4:2:2 video\n"); break;
				case OC_PF_444: printf(" 4:4:4 video\n"); break;
				case OC_PF_RSVD:
				default:
					printf(" video\n  (UNKNOWN Chroma sampling!)\n");
				break;
			}
*/

			theora_cmodel = BC_YUV420P;

			if(tf->ti.width!=tf->ti.frame_width || tf->ti.height!=tf->ti.frame_height)
			{
				eprintf(_("Frame content is %dx%d with offset (%d,%d), We do not support this yet. You will get black border.\n"),
							tf->ti.frame_width, tf->ti.frame_height, tf->ti.offset_x, tf->ti.offset_y);
			}
			tf->videosync = new sync_window_t;
			ogg_sync_init(&tf->videosync->sync);
			tf->videosync->wlen = 0;

			ret = ogg_get_first_page(tf->videosync, tf->to.serialno, &tf->videopage);
			if( !ret ) printf("ogg_get_first_page ret=%d\n", ret);
			ogg_packet op;

			// we have headers already decoded, so just skip them
			ogg_stream_reset(&tf->to);
			ogg_stream_pagein(&tf->to, &tf->videopage);
			while (1)
			{
				while (ogg_stream_packetpeek(&tf->to, NULL) != 1)
				{
					if (!ogg_get_next_page(tf->videosync, tf->to.serialno, &tf->videopage))
					{
						printf(_("FileOGG: Cannot find next page while looking for first non-header packet\n"));
						return 1;
					}
					ogg_stream_pagein(&tf->to, &tf->videopage);
				}
				ogg_stream_packetout(&tf->to, &op);
				if (!theora_packet_isheader(&op))
					break;
			}
			// now get to the page of the finish of the first packet
			while (ogg_page_packets(&tf->videopage) == 0)
			{
				if (ogg_page_granulepos(&tf->videopage) != -1)
				{
					printf(_("FileOGG: Broken ogg file - broken page: ogg_page_packets == 0 and granulepos != -1\n"));
					return 1;
				}
				ogg_get_next_page(tf->videosync, tf->to.serialno, &tf->videopage);
			}
			// FIXME - LOW PRIORITY - start counting at first decodable keyframe!
			// but then we have to fix a/v sync somehow
			start_frame = (int64_t) (theora_granule_frame (&tf->td, ogg_page_granulepos(&tf->videopage)) - ogg_page_packets(&tf->videopage)) + 1;

			ret = ogg_get_last_page(tf->videosync, tf->to.serialno, &tf->videopage);
			last_frame = (int64_t) (theora_granule_frame (&tf->td, ogg_page_granulepos(&tf->videopage)));
			asset->video_length = last_frame - start_frame + 1;
//			printf("FileOGG:: first frame: %lli, last frame: %lli, video length: %lli\n", start_frame, last_frame, asset->video_length);

			asset->layers = 1;
			// FIXME - LOW PRIORITY Cinelerra does not honor the frame_width and frame_height
			asset->width = tf->ti.width;
			asset->height = tf->ti.height;
// Don't want a user configured frame rate to get destroyed
			if(!asset->frame_rate)
				asset->frame_rate = fps;
// All theora material is noninterlaced by definition
			if(!asset->interlace_mode)
				asset->interlace_mode = ILACE_MODE_NOTINTERLACED;

	/*		ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 0 +start_frame);
			ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 1 +start_frame);
			ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 5 +start_frame);
			ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 206 +start_frame);
			ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 207 +start_frame);
			ogg_get_page_of_frame(tf->videosync, tf->to.serialno, &og, 208 +start_frame);

			int64_t kf;
			ogg_seek_to_keyframe(tf->videosync, tf->to.serialno, 0 + start_frame, &kf);
			ogg_seek_to_keyframe(tf->videosync, tf->to.serialno, 1 + start_frame, &kf);
			ogg_seek_to_keyframe(tf->videosync, tf->to.serialno, 5 + start_frame, &kf);
			ogg_seek_to_keyframe(tf->videosync, tf->to.serialno, 66 + start_frame, &kf);
			//printf("Keyframe: %lli\n", kf);
			ogg_seek_to_keyframe(tf->videosync, tf->to.serialno, 1274 + start_frame, &kf);
*/

			set_video_position(0); // make sure seeking is done to the first sample
			ogg_frame_position = -10;
			asset->video_data = 1;
			strncpy(asset->vcodec, "theo", 4);


//		    report_colorspace(&ti);
//		    dump_comments(&tc);
		} else
		{
			/* tear down the partial theora setup */
			theora_info_clear(&tf->ti);
			theora_comment_clear(&tf->tc);
		}


		if(vorbis_p)
		{
			vorbis_synthesis_init(&tf->vd, &tf->vi);
			vorbis_block_init(&tf->vd, &tf->vb);
/*			eprintf(_("FileOGG: Ogg logical stream %x is Vorbis %d channel %d Hz audio.\n"),
				(unsigned int)tf->vo.serialno, tf->vi.channels, (int)tf->vi.rate);
*/
			/* init audio_sync structure */
			tf->audiosync = new sync_window_t;
			ogg_sync_init(&tf->audiosync->sync);
			tf->audiosync->wlen = 0;

			ogg_get_first_page(tf->audiosync, tf->vo.serialno, &tf->audiopage);
			ogg_packet op;
			ogg_stream_reset(&tf->vo);
			// FIXME - LOW PRIORITY should be getting pages until one has granulepos,
			//   probably never happens in pracitce
			ogg_ret2 = ogg_stream_pagein(&tf->vo, &tf->audiopage);
			ogg_int64_t accumulated = 0;
			long lastblock = -1;
			int result;
			while((result = ogg_stream_packetout(&tf->vo, &op)))
			{
				if(result > 0)
				{ // ignore holes
					long thisblock =  vorbis_packet_blocksize(&tf->vi, &op);
					if(lastblock != -1)
						accumulated += (lastblock + thisblock) >> 2;
					lastblock = thisblock;
				}
			}
			start_sample = ogg_page_granulepos(&tf->audiopage) - accumulated;
/*
			printf("Begin: %lli, To byte: %lli,  granule: %lli, serialno: %x\n",
					tf->audiosync->file_pagepos_found,
					tf->audiosync->file_pagepos_found + tf->audiopage.body_len + tf->audiopage.header_len,
					ogg_page_granulepos(&tf->audiopage),
					ogg_page_serialno(&tf->audiopage));
			while (ogg_get_next_page(tf->audiosync, tf->vo.serialno, &tf->audiopage))
				printf("At byte: %lli, To byte: %lli,  granule: %lli, serialno: %x\n",
					tf->audiosync->file_pagepos_found,
					tf->audiosync->file_pagepos_found + tf->audiopage.body_len + tf->audiopage.header_len,
					ogg_page_granulepos(&tf->audiopage),
					ogg_page_serialno(&tf->audiopage));
*/

			ogg_ret1 = ogg_get_last_page(tf->audiosync, tf->vo.serialno, &tf->audiopage);
			last_sample = ogg_page_granulepos(&tf->audiopage);
			asset->audio_length = last_sample - start_sample;

/*			printf("FileOGG:: First sample: %lli, last_sample: %lli\n", start_sample, last_sample);
			printf("FileOGG:: audio length: samples: %lli, playing time: %f\n", asset->audio_length, 1.0 * asset->audio_length / tf->vi.rate);
*/
/*			printf("End: %lli, To byte: %lli,  granule: %lli, serialno: %x\n",
					tf->audiosync->file_pagepos_found,
					tf->audiosync->file_pagepos_found + tf->audiopage.body_len + tf->audiopage.header_len,
					ogg_page_granulepos(&tf->audiopage),
					ogg_page_serialno(&tf->audiopage));
			while (ogg_get_prev_page(tf->audiosync, tf->vo.serialno, &tf->audiopage))
				printf("At byte: %lli, To byte: %lli,  granule: %lli, serialno: %x\n",
					tf->audiosync->file_pagepos_found,
					tf->audiosync->file_pagepos_found + tf->audiopage.body_len + tf->audiopage.header_len,
					ogg_page_granulepos(&tf->audiopage),
					ogg_page_serialno(&tf->audiopage));
*/

/*			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 0);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 1);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 50);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 5000);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 30000);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 50000);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 90000);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 95999);
			ogg_get_page_of_sample(tf->audiosync, tf->vo.serialno, &tf->audiopage, 96000);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 0);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 1);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 5000);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 30000);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 50000);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 90000);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 95999);
			ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, 96000);
*/
			asset->channels = tf->vi.channels;
			if(!asset->sample_rate)
				asset->sample_rate = tf->vi.rate;
			asset->audio_data = 1;


			ogg_sample_position = -10;
			set_audio_position(0); // make sure seeking is done to the first sample
			strncpy(asset->acodec, "vorb", 4);


		} else
		{
			/* tear down the partial vorbis setup */
			vorbis_info_clear(&tf->vi);
			vorbis_comment_clear(&tf->vc);
		}

		ogg_sync_clear(&oy.sync);

	}
	return 0;
}

int FileOGG::ogg_get_prev_page(sync_window_t *sw, long serialno, ogg_page *og)
{
	ogg_page page;
	off_t filepos = sw->file_pagepos_found - READ_SIZE;
	int first_page_offset = 0;
	int done = 0;
	int read_len = READ_SIZE;

//	printf("fp: %lli pagepos found: %lli\n", filepos, sw->file_pagepos_found);
	while (!done)
	{
		if (filepos < 0)
		{
//			read_len = read_len - (filedata_begin - filepos);
			read_len = read_len + filepos;
			filepos = 0;
		}
		if (read_len <= 0)
			return 0;
		int have_read = read_buffer_at(stream, sw, read_len, filepos);

//		printf("reading at %lli, len: %i, read: %i, pagepos: %lli, pageposfound: %lli\n", filepos, read_len, have_read, sw->file_pagepos, sw->file_pagepos_found);
//		printf("Buffer position: %lli\n", sw->file_bufpos);
//		printf("SS: storage: %i, fill: %i, returned: %i\n", sw->sync.storage, sw->sync.fill, sw->sync.returned);
//		printf("US: unsynced%i, headrebytes: %i, bodybyes: %i\n", sw->sync.unsynced, sw->sync.headerbytes, sw->sync.bodybytes);
//		printf("data: %c %c %c %c\n", sw->sync.data[0], sw->sync.data[1], sw->sync.data[2], sw->sync.data[3]);
		if (!have_read)
			return 0;

// read all pages in the buffer
		int page_offset = 0;
		int page_length = 0;
		int first_page = 1;
		while (first_page || page_length)
		{
			// if negative, skip bytes
			while ((page_length = sync_and_take_page_out(sw, &page)) < 0)
			{
				page_offset -= page_length;

//				if (filepos == 0)
//					printf("BBBb page_len: %i\n", page_length);
			}
//			if (filepos == 0 && page_length)
//			{
//				printf("AAAAAAAAAAAAAAAAAAAAAAAAAaaa\n");
//				printf("pp: %lli %x\n", sw->file_pagepos, ogg_page_serialno(&page));
//			}
			if (first_page)
				first_page_offset = page_offset;
			first_page = 0;
//			printf("pl: %i, serial: %x iscem: %x\n", page_length, ogg_page_serialno(&page), serialno);
			if (page_length && ogg_page_serialno(&page) == serialno)
			{
				// we will copy every page until last page in this buffer
				done = 1;

				sw->file_pagepos_found = sw->file_pagepos - page.header_len - page.body_len;
//				printf("got it : %lli %i %i\n", sw->file_pagepos, page.header_len, page.body_len);
				memcpy(og, &page, sizeof(page));
			}
		}
//		printf("fpo: %i\n", first_page_offset);
		filepos += first_page_offset - READ_SIZE;
	}

//	printf("finished\n");
	if (done)
		return 1;
	else
		return 0;
}

int FileOGG::ogg_get_last_page(sync_window_t *sw, long serialno, ogg_page *og)
{
	ogg_page page;
	off_t filepos = file_length - READ_SIZE;
	if (filepos < 0)
		filepos = 0;

	int first_page_offset = 0;
	int done = 0;
	while (!done && filepos >= 0)
	{
		//int readlen =
		  read_buffer_at(stream, sw, READ_SIZE, filepos);

// read all pages in the buffer
		int page_offset = 0;
		int page_length = 0;
		int first_page = 1;
		while (first_page || page_length)
		{
			// if negative, skip bytes
			while ((page_length = sync_and_take_page_out(sw, &page)) < 0)
					page_offset -= page_length;
			if (first_page)
				first_page_offset = page_offset;
			first_page = 0;
			if (page_length && ogg_page_serialno(&page) == serialno)
			{
				// we will copy every page until last page in this buffer
				done = 1;
				sw->file_pagepos_found = sw->file_pagepos - page.header_len - page.body_len;
				memcpy(og, &page, sizeof(page));
			}
		}
		filepos = filepos + first_page_offset - READ_SIZE;
	}

	if (done)
		return 1;
	else
		return 0;
}

int FileOGG::ogg_get_first_page(sync_window_t *sw, long serialno, ogg_page *og)
{
//	printf("FileOGG:: Seeking to first page at %lli\n", filedata_begin);
	read_buffer_at(stream, sw, READ_SIZE, 0);
// we don't even need to sync since we _know_ it is right
	return (ogg_get_next_page(sw, serialno, og));
}

int FileOGG::ogg_seek_to_databegin(sync_window_t *sw, long serialno)
{

//	printf("FileOGG:: Seeking to first page at %lli\n", filedata_begin);
	read_buffer_at(stream, sw, READ_SIZE, filedata_begin);
// we don't even need to sync since we _know_ it is right
	return (0);
}

int FileOGG::ogg_get_next_page(sync_window_t *sw, long serialno, ogg_page *og)
{
	while (take_page_out_autoadvance(stream, sw, og) > 0)
	{
		if (ogg_page_serialno(og) == serialno)
		{
			sw->file_pagepos_found = sw->file_pagepos - og->header_len - og->body_len;
			return 1;
		}
	}
	return 0;
}

int FileOGG::ogg_sync_and_get_next_page(sync_window_t *sw, long serialno, ogg_page *og)
{
// TODO: Put better error reporting inhere
	int ret;
	while ((ret = sync_and_take_page_out(sw, og)) < 0)
	{
		// do nothing;
	}
	if (ret == 0)
		return 0;
	if (ogg_page_serialno(og) == serialno)
	{
		sw->file_pagepos_found = sw->file_pagepos - og->header_len - og->body_len;
		return 1;
	}
	while (ogg_get_next_page(sw, serialno, og))
		if (ogg_page_serialno(og) == serialno)
		{
			sw->file_pagepos_found = sw->file_pagepos - og->header_len - og->body_len;
			return 1;
		}

	return 0;
}
// Returns:
// >= 0, number of sample within a page
// <  0 error
int FileOGG::ogg_get_page_of_sample(sync_window_t *sw, long serialno, ogg_page *og, int64_t sample)
{
// First make an educated guess about position
	if (sample >= asset->audio_length + start_sample)
	{
		printf(_("FileOGG: Illegal seek beyond end of samples\n"));
		return 0;
	}
	off_t educated_guess = filedata_begin + (file_length - filedata_begin) * (sample - start_sample) / asset->audio_length - READ_SIZE;
	if (educated_guess < 0)
		educated_guess = 0;
//	printf("My educated guess: %lli\n", educated_guess);
// now see if we won
	read_buffer_at(stream, sw, READ_SIZE, educated_guess);
	ogg_sync_and_get_next_page(sw, serialno, og);
	int64_t end_sample = ogg_page_granulepos(og);
	// linear seek to the sample
	int64_t start_sample = 0;
// TODO: Use bisection also
//	printf("Next page granulepos: %lli, pagepos: %lli\n", end_sample, sw->file_pagepos_found);
	if (end_sample <= sample)
	{
	// scan forward
		while (end_sample <= sample)
		{
			ogg_get_next_page(sw, serialno, og);
			start_sample = end_sample;
			end_sample = ogg_page_granulepos(og);
		}
		ogg_get_prev_page(sw, serialno, og);
		while (ogg_page_continued(og) && ogg_page_packets(og) == 1)
			ogg_get_prev_page(sw, serialno, og);
	} else
	{
	// scan backward
		start_sample = end_sample;
		while (start_sample > sample || (ogg_page_continued(og) &&
			ogg_page_packets(og) == 1))
		{
//			printf("get prev page: %lli pagepos:%lli\n", ogg_page_granulepos(og), sw->file_pagepos_found);
			ogg_get_prev_page(sw, serialno, og);
			end_sample = start_sample;
			start_sample = ogg_page_granulepos(og);
		}
	// go forward one page at the end

	}

//	printf("For sample %lli we need to start decoding on page with granulepos: %lli\n", sample, ogg_page_granulepos(og));
	return 1;
}

// seeks, so next sample returned will be the correct one
// sample here is still the vorbis sample number (= cinelerra sample number + start_sample)
// reinits the decoding engine

int FileOGG::ogg_seek_to_sample(sync_window_t *sw, long serialno, int64_t sample)
{
	// MAYBE FIXME - find out if we really are decoding previous two packets or not
	// get to the sample
	ogg_page og;
	ogg_packet op;
//	printf("Calling get page of sample\n");
	if (!ogg_get_page_of_sample(sw, serialno, &og, sample))
	{
		eprintf(_("FileOGG: Seeking to sample's page failed\n"));
		return 0;
	}
//	printf("Pagepos: %lli\n", sw->file_pagepos);
	vorbis_synthesis_restart(&tf->vd);
	ogg_stream_reset(&tf->vo);
	ogg_stream_pagein(&tf->vo, &og);
	int sync = 0;
//	printf("seeking to sample : %lli , starting at page with gpos: %lli\n", sample, ogg_page_granulepos(&og));

	int64_t current_comming_sample = -1;
	while (1)
	{

		// make sure we have a packet ready
		while (ogg_stream_packetpeek(&tf->vo, NULL) != 1)
		{
			if (!ogg_get_next_page(sw, serialno, &og))
			{
				eprintf(_("FileOGG: Cannot find next page while seeking\n"));
				return 0;
			}
			ogg_stream_pagein(&tf->vo, &og);
		}
		ogg_stream_packetout(&tf->vo, &op);
		if (sync)
		{

			if(!vorbis_synthesis(&tf->vb, &op))
			{
				ogg_ret0 = vorbis_synthesis_blockin(&tf->vd, &tf->vb);
				int64_t previous_comming_sample = current_comming_sample;
				current_comming_sample += vorbis_synthesis_pcmout(&tf->vd, NULL);
				if (current_comming_sample > sample)
				{
					if (previous_comming_sample > sample)
					{
						eprintf(_("Ogg decoding error while seeking sample\n"));
					}
					vorbis_synthesis_read(&tf->vd, (sample - previous_comming_sample));
//					printf("WE GOT IT, samples already decoded: %jd\n", vorbis_synthesis_pcmout(&tf->vd,NULL));
					return 1; // YAY next sample read is going to be ours, sexy!
				} else
				{
					// discard decoded data before current sample
					vorbis_synthesis_read(&tf->vd, (current_comming_sample - previous_comming_sample));

				}
 			}
		}
		if (!sync && op.granulepos >= 0)
		{
			sync = 1;
			current_comming_sample = op.granulepos;
			if(!vorbis_synthesis(&tf->vb, &op))
			{
				vorbis_synthesis_blockin(&tf->vd, &tf->vb);
				if (vorbis_synthesis_pcmout(&tf->vd, NULL) != 0)
				{
					eprintf(_("FileOGG: Something wrong while trying to seek\n"));
					return 0;
				}

			}

		}
	}


	return 0;
}

int FileOGG::ogg_get_page_of_frame(sync_window_t *sw, long serialno, ogg_page *og, int64_t frame)
{
	if (frame >= asset->video_length + start_frame)
	{
		eprintf(_("FileOGG: Illegal seek beyond end of frames\n"));
		return 0;
	}
//	printf("frame: %lli start frame: %lli\n", frame, start_frame);
//	printf("file_length: %lli filedata_begin: %lli\n", file_length, filedata_begin);
	off_t educated_guess = filedata_begin + (file_length - filedata_begin) * (frame - start_frame) / asset->video_length - READ_SIZE/2;
//	educated_guess += 100000;
	if (educated_guess > file_length - READ_SIZE)
		educated_guess = file_length - READ_SIZE;
	if (educated_guess < filedata_begin)
		educated_guess = filedata_begin;
//	printf("My educated guess: %lli\n", educated_guess);
// now see if we won
	read_buffer_at(stream, sw, READ_SIZE, educated_guess);
	if( !ogg_sync_and_get_next_page(sw, serialno, og) ) {
		printf(_("FileOGG: ogg_sync_and_get_next_page failed\n"));
		return 0;
	}
	int64_t pageend_frame;
	//int read_back = 0;
	// find the page with "real" ending
	while ((pageend_frame = ogg_page_granulepos(og)) == -1)
	{
		if (ogg_get_next_page(sw, serialno, og) == 0)
		{
			//read_back = 1;
			break;
		}
	}
	pageend_frame = theora_granule_frame(&tf->td, ogg_page_granulepos(og));

	// FIXME - MEDIUM PRIORITY: read back if we've gone too far and no page of our serialno at all can be found


	// linear seek to the sample
// TODO: Use bisection also
//	printf("Next page granulepos: %lli, pagepos: %lli\n", end_sample, sw->file_pagepos_found);
	//int discard_packets = 0;
	int missp = 0;
	int missm = 0;
	if (pageend_frame <= frame)
	{
	// scan forward
		while (pageend_frame < frame)
		{
			do {
				ogg_get_next_page(sw, serialno, og);
			} while (ogg_page_packets(og) == 0);
			pageend_frame = theora_granule_frame(&tf->td, ogg_page_granulepos(og));
			missp++;
		}
		// go back if this frame starts on previous page
		if (ogg_page_continued(og) && pageend_frame - ogg_page_packets(og) == frame - 1)
		{
			do {
				ogg_get_prev_page(sw, serialno, og);
			} while (ogg_page_packets(og) == 0 && ogg_page_continued(og));
		}
		pageend_frame = theora_granule_frame(&tf->td, ogg_page_granulepos(og));
	} else
	{
	// scan backward
		int64_t first_frame_on_page = theora_granule_frame(&tf->td, ogg_page_granulepos(og)) - ogg_page_packets(og) + 2;
		if (!ogg_page_continued(og))
			first_frame_on_page--;
		while (first_frame_on_page > frame)
		{
//			printf("get prev page: %lli pagepos:%lli\n", ogg_page_granulepos(og), sw->file_pagepos_found);
			do {
				ogg_get_prev_page(sw, serialno, og);
			} while (ogg_page_packets(og) == 0 && ogg_page_continued(og));
			missm++;
//			pageend_frame = theora_granule_frame(&tf->td, ogg_page_granulepos(og));
			first_frame_on_page = theora_granule_frame(&tf->td, ogg_page_granulepos(og)) - ogg_page_packets(og) + 2;
			if (!ogg_page_continued(og))
				first_frame_on_page--;
		}
	}
//	printf("Miss plus: %i, miss minus: %i\n", missp, missm);
//	printf("last frame of page with frame : %lli\n", pageend_frame);
	return 1;
}


int FileOGG::ogg_seek_to_keyframe(sync_window_t *sw, long serialno, int64_t frame, int64_t *position)
{
//printf("seek %jd\n", frame);
	ogg_page og;
	ogg_packet op;

	if( !ogg_get_page_of_frame(sw, serialno, &og, frame) ) {
		eprintf(_("FileOGG: seek to frame failed\n"));
		return 0;
	}
	// find a page with packets
	while( ogg_page_packets(&og) == 0 ) {
		ogg_get_prev_page(sw, serialno, &og);
	}
	int64_t granulepos = ogg_page_granulepos(&og);
	granulepos &= ~((1<<theora_keyframe_granule_shift)-1);
	int64_t iframe = theora_granule_frame(&tf->td, granulepos);
	// iframe based on granulepos
	if( frame < iframe || !ogg_get_page_of_frame(sw, serialno, &og, iframe) )  {
		eprintf(_("FileOGG: seek to iframe failed\n"));
		return 0;
	}
	while( ogg_page_packets(&og) == 0 ) {
		ogg_get_prev_page(sw, serialno, &og);
	}
	int64_t pageend_frame = theora_granule_frame(&tf->td, ogg_page_granulepos(&og));
	int64_t frames_on_page = ogg_page_packets(&og);
	if( ogg_page_continued(&og) ) --frames_on_page;
	// get frame before page with with iframe
	int64_t page_frame = pageend_frame - frames_on_page;
	if( page_frame < 0 ) page_frame = 0;
//printf("iframe %jd, page_frame %jd, frames_on_page %jd\n", iframe, page_frame, frames_on_page);
	ogg_stream_reset(&tf->to);
	ogg_stream_pagein(&tf->to, &og);

	while( ++page_frame < iframe ) {
		while( ogg_stream_packetpeek(&tf->to, NULL) != 1 ) {
			if( !ogg_get_next_page(sw, serialno, &og) ) {
				eprintf(_("FileOGG: Cannot find next page while seeking\n"));
				return 0;
			}
			ogg_stream_pagein(&tf->to, &og);
		}
		ogg_stream_packetout(&tf->to, &op);
	}

	*position = iframe - 1;
	return 1;
}


int FileOGG::check_sig(Asset *asset)
{

	FILE *fd = fopen(asset->path, "rb");

// Test for "OggS"
	fseek(fd, 0, SEEK_SET);
	char data[4];

	(void)fread(data, 4, 1, fd);

	if(data[0] == 'O' &&
		data[1] == 'g' &&
		data[2] == 'g' &&
		data[3] == 'S')
	{

		fclose(fd);
//		printf("Yay, we have an ogg file\n");
		return 1;
	}

	fclose(fd);

	return 0;

}

int FileOGG::close_file()
{

	if (file->wr)
	{
		if (final_write)
		{
			if (asset->audio_data)
				write_samples_vorbis(0, 0, 1); // set eos
			if (asset->video_data)
				write_frames_theora(0, 1, 1); // set eos
		}
		flush_ogg(1); // flush all

		if (asset->audio_data)
		{
			vorbis_block_clear (&tf->vb);
			vorbis_dsp_clear (&tf->vd);
			vorbis_info_clear (&tf->vi);
			ogg_stream_clear (&tf->vo);
		}
		if (asset->video_data)
		{
			theora_info_clear (&tf->ti);
			ogg_stream_clear (&tf->to);
			theora_clear (&tf->td);
		}

		if (stream) fclose(stream);
		stream = 0;
	}
	else
	if (file->rd)
	{
		if (asset->audio_data)
		{
			vorbis_block_clear (&tf->vb);
			vorbis_dsp_clear (&tf->vd);
			vorbis_comment_clear (&tf->vc);
			vorbis_info_clear (&tf->vi);
			ogg_stream_clear (&tf->vo);
		}
		theora_comment_clear(&tf->tc);
		if (asset->video_data)
		{
			theora_info_clear (&tf->ti);
			theora_comment_clear (&tf->tc);
			theora_clear (&tf->td);
			ogg_stream_clear (&tf->to);
		}


		if (stream) fclose(stream);
		stream = 0;

	}
	return 0;
}

int FileOGG::close_file_derived()
{
//printf("FileOGG::close_file_derived(): 1\n");
	if (stream) fclose(stream);
	stream = 0;
	return 0;
}

int64_t FileOGG::get_video_position()
{
//	printf("GVP\n");
	return next_frame_position - start_frame;
}

int64_t FileOGG::get_audio_position()
{
	return next_sample_position - start_sample;
}

int FileOGG::set_video_position(int64_t x)
{
//	x=0;
//	printf("SVP: %lli\n", x);

	next_frame_position = x + start_frame;
	return 1;
}


int FileOGG::colormodel_supported(int colormodel)
{
//	printf("CMS\n");

	if (colormodel == BC_YUV420P)
		return BC_YUV420P;
	else
		return colormodel;
}
int FileOGG::get_best_colormodel(Asset *asset, int driver)
{

	return BC_YUV420P;
}


int FileOGG::read_frame(VFrame *frame)
{

	if(!stream) return 1;


	// skip is cheaper than seek, do it...
	int decode_frames = 0;
	int expect_keyframe = 0;
	if (ogg_frame_position >= 0 &&
	    next_frame_position >= ogg_frame_position &&
	    next_frame_position - ogg_frame_position < 32)
	{
		decode_frames = next_frame_position - ogg_frame_position;
	} else
	if (next_frame_position != ogg_frame_position)
	{
		if (!ogg_seek_to_keyframe(tf->videosync, tf->to.serialno,
			next_frame_position, &ogg_frame_position)) {
			eprintf(_("FileOGG:: Error while seeking to frame's keyframe"
				" (frame: %jd, keyframe: %jd)\n"),
				next_frame_position, ogg_frame_position);
			return 1;
		}
//		printf("For frame: %lli, keyframe is: %lli\n", next_frame_position,ogg_frame_position);
		// skip frames must be > 0 here
		decode_frames = next_frame_position - ogg_frame_position;
		if (decode_frames <= 0)
		{
			eprintf(_("FileOGG:: Error while seeking to keyframe,"
				" wrong keyframe number (frame: %jd, keyframe: %jd)\n"),
				next_frame_position, ogg_frame_position);
			return 1;

		}
		expect_keyframe = 1;
	}

//	printf("Frames to decode: %i\n", decode_frames);

// THIS IS WHAT CAUSES SLOWNESS OF SEEKING, but we can do nothing about it.
	int ret = -1;
	while (decode_frames > 0)
	{
		ogg_page og;
		ogg_packet op;
		while (ogg_stream_packetpeek(&tf->to, NULL) != 1)
		{
			if (!ogg_get_next_page(tf->videosync, tf->to.serialno, &og))
			{
				eprintf(_("FileOGG: Cannot find next page while seeking\n"));
				return 1;
			}
			ogg_stream_pagein(&tf->to, &og);
		}
		ogg_stream_packetout(&tf->to, &op);
		if( theora_packet_isheader(&op) ) continue;
//printf("frame %jd, key %d\n", ogg_frame_position, theora_packet_iskeyframe(&op));
		if (expect_keyframe && !theora_packet_iskeyframe(&op))
		{
				eprintf(_("FileOGG: Expecting keyframe, but didn't get it\n"));
			//	return 1; this is generally not a fatal error
		}
		expect_keyframe = 0;

		// decode
		ret = theora_decode_packetin(&tf->td, &op);
//if(ret < 0 )printf("ret = %d\n", ret);
		decode_frames --;
		ogg_frame_position ++;
	}
	if( ret >= 0 ) {
		yuv_buffer yuv;
		int ret = theora_decode_YUVout (&tf->td, &yuv);
		if (ret)
		{
			eprintf(_("FileOGG: theora_decode_YUVout failed with code %i\n"), ret);
		}

// Dirty magic
/*		yuv.y += yuv.y_stride * (yuv.y_height - 1);
		yuv.u += yuv.uv_stride * (yuv.uv_height - 1);
		yuv.v += yuv.uv_stride * (yuv.uv_height - 1);
		yuv.y_stride = - yuv.y_stride;
		yuv.uv_stride = - yuv.uv_stride;*/
		VFrame *temp_frame = new VFrame(yuv.y, -1, 0,
					yuv.u - yuv.y, yuv.v - yuv.y, - yuv.y_stride,
					yuv.y_height, BC_YUV420P, - yuv.y_stride);
		// copy into temp frame...

		BC_CModels::transfer(frame->get_rows(),
			temp_frame->get_rows(),
			frame->get_y(),
			frame->get_u(),
			frame->get_v(),
			temp_frame->get_y(),
			temp_frame->get_u(),
			temp_frame->get_v(),
			0,
			0,
			yuv.y_width,
			yuv.y_height,
			0,
			0,
			yuv.y_width,  // temp_frame can be larger than frame if width not dividable by 16
			yuv.y_height,
			BC_YUV420P,
			frame->get_color_model(),
			0,
			-temp_frame->get_w(),
			frame->get_w());
		delete temp_frame;
	}

	next_frame_position ++;

	return 0;
}



int FileOGG::ogg_decode_more_samples(sync_window_t *sw, long serialno)
{
	ogg_page og;
	ogg_packet op;
	int done = 0;
	while (!done)
	{
		while (ogg_stream_packetpeek(&tf->vo, NULL) != 1)
		{
			if (!ogg_get_next_page(sw, serialno, &og))
			{
				eprintf(_("FileOGG: Cannot find next page while trying to decode more samples\n"));
				return 0;
			}
			ogg_stream_pagein(&tf->vo, &og);
		}
		ogg_stream_packetout(&tf->vo, &op);
		if(!vorbis_synthesis(&tf->vb, &op))
		{
			done = 1;
			vorbis_synthesis_blockin(&tf->vd, &tf->vb);
		}
	}
	return 1;
}

int FileOGG::set_audio_position(int64_t x)
{
	next_sample_position = x + start_sample;
	return 0;
}

int FileOGG::move_history(int from, int to, int len)
{
	if( len > 0 ) {
		for(int i = 0; i < asset->channels; i++)
			memmove(pcm_history[i] + to, pcm_history[i] + from, sizeof(float) * len);
	}
	history_start = history_start + from - to;
	if( history_start < 0 ) history_start = 0;
	return 0;
}

int FileOGG::read_samples(double *buffer, int64_t len)
{
	float **vorbis_buffer;
	if (len <= 0)
		return 0;
//	printf("Reading samples: Channel: %i, number of samples: %lli, reading at :%lli\n", file->current_channel, len, next_sample_position);
//		printf("\tnext_sample_position: %lli, length: %i\n", next_sample_position, len);
//		printf("\thistory_start: %lli, length: %i\n", history_start, history_size);

	if(len > HISTORY_MAX)
	{
		eprintf(_("max samples=%d\n"), HISTORY_MAX);
		return 1;
	}

	if(!pcm_history)
	{
		pcm_history = new float*[asset->channels];
		for(int i = 0; i < asset->channels; i++)
			pcm_history[i] = new float[HISTORY_MAX];
		history_start = -100000000; // insane value to trigger reload
		history_size = 0;
	}

	int64_t hole_start = -1;
	int64_t hole_len = -1;
	int64_t hole_absstart = -1;
	int64_t hole_fill = 0;

	if (history_start < next_sample_position && history_start + history_size > next_sample_position && history_start + history_size < next_sample_position + len)
	{
//		printf("a\n");
		hole_fill = 1;
		hole_start = history_start + history_size - next_sample_position;
		hole_len = history_size - hole_start;
		hole_absstart = next_sample_position + hole_start;
		move_history(next_sample_position - history_start,
				0,
				hole_start); //

	} else
	if (next_sample_position < history_start && history_start < next_sample_position + len)
	{
//		printf("b\n");
		hole_fill = 1;
		hole_start = 0;
		hole_len = history_start - next_sample_position;
		hole_absstart = next_sample_position;
//		printf("hs: %lli, histstart: %lli, next_sample_position: %lli\n", history_size, history_start, next_sample_position);
//		printf("to: 0, from: %lli, size: %lli\n",
 //				history_start - next_sample_position,
//				history_size - history_start + next_sample_position);
		move_history(0,
				history_start - next_sample_position,
				history_size - history_start + next_sample_position);

	} else
	if (next_sample_position >= history_start + history_size || next_sample_position + len <= history_start)
	{
//		printf("c\n");
		hole_fill = 1;
		hole_start = 0;
		hole_len = HISTORY_MAX;
		hole_absstart = next_sample_position;
		history_start = hole_absstart;
		history_size = hole_len;
	}

	if (hole_fill)
	{
		if (hole_start < 0 || hole_len <= 0 || hole_absstart < 0)
		{
			eprintf(_("FileOGG: Error at finding out what to read from file\n"));
			return 1;
		}

		if (hole_absstart + hole_len > asset->audio_length + start_sample)
		{
			hole_len = asset->audio_length + start_sample - hole_absstart;
			history_size = asset->audio_length + start_sample - history_start;
		} else
		{
			history_size = HISTORY_MAX;
		}


//		printf("Decode samples at position: %lli, samples to read: %lli\n", hole_absstart, hole_len);

		int64_t samples_read = 0;
		if (ogg_sample_position != hole_absstart)
		{
			ogg_sample_position = hole_absstart;
			if (!ogg_seek_to_sample(tf->audiosync, tf->vo.serialno, ogg_sample_position))
			{
				eprintf(_("Error while seeking to sample\n"));
				return 1;
			}
		}
		// now we have ogg_sample_positon aligned
		int64_t samples_to_read = hole_len;
		while (samples_read < hole_len)
		{
			int64_t waiting_samples = vorbis_synthesis_pcmout(&tf->vd, &vorbis_buffer);
			int64_t takeout_samples;
			if (waiting_samples > samples_to_read - samples_read)
				takeout_samples = samples_to_read - samples_read;
			else
				takeout_samples = waiting_samples;

//			printf("takeout samples: %lli, samples_read: %lli\n", takeout_samples, samples_read);

			if(waiting_samples)
			{
				for(int i = 0; i < asset->channels; i++)
				{
					float *input = vorbis_buffer[i];
					float *output = pcm_history[i] + hole_start;
					// TODO: use memcpy
					for(int j = 0; j < takeout_samples ; j++)
					{
						output[j] = input[j];
					}
				}
			}

			vorbis_synthesis_read(&tf->vd, takeout_samples);
			samples_read += takeout_samples;
			ogg_sample_position += takeout_samples;
			hole_start += takeout_samples;

			if (samples_read < hole_len)
				if (!ogg_decode_more_samples(tf->audiosync, tf->vo.serialno))
				{
					ogg_sample_position = -1;
					return 1;
				}


		}
	}

	// now we can be sure our history is correct, just copy it out
	if (next_sample_position < history_start || next_sample_position + len > history_start + history_size)
	{
		printf(_("FileOGG:: History not aligned properly \n"));
		printf(_("\tnext_sample_position: %jd, length: %jd\n"), next_sample_position, len);
		printf(_("\thistory_start: %jd, length: %jd\n"), history_start, history_size);
		return 1;
	}
	float *input = pcm_history[file->current_channel] + next_sample_position - history_start;
	for (int i = 0; i < len; i++)
		buffer[i] = input[i];

	next_sample_position += len;
	return 0;
}


int FileOGG::write_audio_page()
{
	int ret;

	ret = fwrite(tf->apage, 1, tf->apage_len, stream);
	if(ret < tf->apage_len)
	{
		eprintf(_("error writing audio page\n"));
	}
	tf->apage_valid = 0;
	tf->a_pkg -= ogg_page_packets((ogg_page *)&tf->apage);
	return ret;
}

int FileOGG::write_video_page()
{
	int ret;

	ret = fwrite(tf->vpage, 1, tf->vpage_len, stream);
	if(ret < tf->vpage_len)
	{
		eprintf(_("error writing video page\n"));
	}
	tf->vpage_valid = 0;
	tf->v_pkg -= ogg_page_packets((ogg_page *)&tf->vpage);
	return ret;
}

void FileOGG::flush_ogg (int e_o_s)
{
    int len;
    ogg_page og;

	flush_lock->lock();
    /* flush out the ogg pages  */
    while(1) {
      /* Get pages for both streams, if not already present, and if available.*/
      if(asset->video_data && !tf->vpage_valid) {
        // this way seeking is much better,
        // not sure if 23 packets  is a good value. it works though
        int v_next=0;
        if(tf->v_pkg>22 && ogg_stream_flush(&tf->to, &og) > 0) {
          v_next=1;
        }
        else if(ogg_stream_pageout(&tf->to, &og) > 0) {
          v_next=1;
        }
        if(v_next) {
          len = og.header_len + og.body_len;
          if(tf->vpage_buffer_length < len) {
            tf->vpage = (unsigned char *)realloc(tf->vpage, len);
            tf->vpage_buffer_length = len;
          }
          tf->vpage_len = len;
          memcpy(tf->vpage, og.header, og.header_len);
          memcpy(tf->vpage+og.header_len , og.body, og.body_len);

          tf->vpage_valid = 1;
          tf->videotime = theora_granule_time (&tf->td,
                  ogg_page_granulepos(&og));
        }
      }
      if(asset->audio_data && !tf->apage_valid) {
        // this way seeking is much better,
        // not sure if 23 packets  is a good value. it works though
        int a_next=0;
        if(tf->a_pkg>22 && ogg_stream_flush(&tf->vo, &og) > 0) {
          a_next=1;
        }
        else if(ogg_stream_pageout(&tf->vo, &og) > 0) {
          a_next=1;
        }
        if(a_next) {
          len = og.header_len + og.body_len;
          if(tf->apage_buffer_length < len) {
            tf->apage = (unsigned char *)realloc(tf->apage, len);
            tf->apage_buffer_length = len;
          }
          tf->apage_len = len;
          memcpy(tf->apage, og.header, og.header_len);
          memcpy(tf->apage+og.header_len , og.body, og.body_len);

          tf->apage_valid = 1;
          tf->audiotime= vorbis_granule_time (&tf->vd,
                  ogg_page_granulepos(&og));
        }
      }

      if(!asset->audio_data && tf->vpage_valid) {
        write_video_page();
      }
      else if(!asset->video_data && tf->apage_valid) {
        write_audio_page();
      }
      /* We're using both. We can output only:
       *  a) If we have valid pages for both
       *  b) At EOS, for the remaining stream.
       */
      else if(tf->vpage_valid && tf->apage_valid) {
        /* Make sure they're in the right order. */
        if(tf->videotime <= tf->audiotime)
          write_video_page();
        else
          write_audio_page();
      }
      else if(e_o_s && tf->vpage_valid) {
          write_video_page();
      }
      else if(e_o_s && tf->apage_valid) {
          write_audio_page();
      }
      else {
        break; /* Nothing more writable at the moment */
      }
    }
	flush_lock->unlock();
}


int FileOGG::write_samples_vorbis(double **buffer, int64_t len, int e_o_s)
{
	float **vorbis_buffer;
	static int samples = 0;
	samples += len;
	if(e_o_s)
	{
		vorbis_analysis_wrote (&tf->vd, 0);
	} else
	{
		vorbis_buffer = vorbis_analysis_buffer (&tf->vd, len);
		/* double to float conversion */
		for(int i = 0; i<asset->channels; i++)
		{
			for (int j = 0; j < len; j++)
			{
				vorbis_buffer[i][j] = buffer[i][j];
			}
		}
		vorbis_analysis_wrote (&tf->vd, len);
	}
	while(vorbis_analysis_blockout (&tf->vd, &tf->vb) == 1)
	{
	    /* analysis, assume we want to use bitrate management */
	    vorbis_analysis (&tf->vb, NULL);
	    vorbis_bitrate_addblock (&tf->vb);

	    /* weld packets into the bitstream */
	    while (vorbis_bitrate_flushpacket (&tf->vd, &tf->op))
	    {
		flush_lock->lock();
		ogg_stream_packetin (&tf->vo, &tf->op);
		tf->a_pkg++;
		flush_lock->unlock();
	    }

	}
	flush_ogg(0);
	return 0;


}

int FileOGG::write_samples(double **buffer, int64_t len)
{
	if (len > 0)
		return write_samples_vorbis(buffer, len, 0);
	return 0;
}

int FileOGG::write_frames_theora(VFrame ***frames, int len, int e_o_s)
{
	// due to clumsy theora's design we need to delay writing out by one frame
	// always stay one frame behind, so we can correctly encode e_o_s
	int result = 0;
	if(!stream) return 0;

	for(int j = 0; j < len && !result; j++)
	{
		if (temp_frame) // encode previous frame if available
		{
			yuv_buffer yuv;
			yuv.y_width = tf->ti.width;
			yuv.y_height = tf->ti.height;
			yuv.y_stride = temp_frame->get_bytes_per_line();

			yuv.uv_width = tf->ti.width / 2;
			yuv.uv_height = tf->ti.height / 2;
			yuv.uv_stride = temp_frame->get_bytes_per_line() /2;

			yuv.y = temp_frame->get_y();
			yuv.u = temp_frame->get_u();
			yuv.v = temp_frame->get_v();
			int ret = theora_encode_YUVin (&tf->td, &yuv);
			if (ret)
			{
				printf(_("FileOGG: theora_encode_YUVin failed with code %i\n"), ret);
				printf("yuv_buffer: y_width: %i, y_height: %i, y_stride: %i,"
					" uv_width: %i, uv_height: %i, uv_stride: %i\n",
					yuv.y_width, yuv.y_height, yuv.y_stride,
					yuv.uv_width, yuv.uv_height, yuv.uv_stride);
			}
			while(theora_encode_packetout (&tf->td, e_o_s, &tf->op)) {
				flush_lock->lock();
				ogg_stream_packetin (&tf->to, &tf->op);
				tf->v_pkg++;
				flush_lock->unlock();
            }
			flush_ogg(0);  // eos flush is done later at close_file
		}
// If we have e_o_s, don't encode any new frames
		if (e_o_s)
			break;

		if (!temp_frame)
		{
			temp_frame = new VFrame ( tf->ti.width, tf->ti.height, BC_YUV420P, 0);
		}
		VFrame *frame = frames[0][j];
		int in_color_model = frame->get_color_model();
		if (in_color_model == BC_YUV422P &&
		    temp_frame->get_w() == frame->get_w() &&
		    temp_frame->get_h() == frame->get_h() &&
		    temp_frame->get_bytes_per_line() == frame->get_bytes_per_line())
		{
			temp_frame->copy_from(frame);
		} else
		{

			BC_CModels::transfer(temp_frame->get_rows(),
				frame->get_rows(),
				temp_frame->get_y(),
				temp_frame->get_u(),
				temp_frame->get_v(),
				frame->get_y(),
				frame->get_u(),
				frame->get_v(),
				0,
				0,
				frame->get_w(),
				frame->get_h(),
				0,
				0,
				frame->get_w(),  // temp_frame can be larger than frame if width not dividable by 16
				frame->get_h(),
				frame->get_color_model(),
				BC_YUV420P,
				0,
				frame->get_w(),
				temp_frame->get_w());

		}
	}

	return 0;
}


int FileOGG::write_frames(VFrame ***frames, int len)
{

	return write_frames_theora(frames, len, 0);
}

OGGConfigAudio::OGGConfigAudio(BC_WindowBase *parent_window, Asset *asset)
 : BC_Window(_(PROGRAM_NAME ": Audio Compression"),
	parent_window->get_abs_cursor_x(1),
	parent_window->get_abs_cursor_y(1),
	350, 250)
{
	this->parent_window = parent_window;
	this->asset = asset;
}

OGGConfigAudio::~OGGConfigAudio()
{

}

void OGGConfigAudio::create_objects()
{
//	add_tool(new BC_Title(10, 10, _("There are no audio options for this format")));

	int x = 10, y = 10;
	int x1 = 150;
	char string[BCTEXTLEN];

	lock_window("OGGConfigAudio::create_objects");
	add_tool(fixed_bitrate = new OGGVorbisFixedBitrate(x, y, this));
	add_tool(variable_bitrate = new OGGVorbisVariableBitrate(x1, y, this));

	y += 30;
	sprintf(string, "%d", asset->vorbis_min_bitrate);
	add_tool(new BC_Title(x, y, _("Min bitrate:")));
	add_tool(new OGGVorbisMinBitrate(x1, y, this, string));

	y += 30;
	add_tool(new BC_Title(x, y, _("Avg bitrate:")));
	sprintf(string, "%d", asset->vorbis_bitrate);
	add_tool(new OGGVorbisAvgBitrate(x1, y, this, string));

	y += 30;
	add_tool(new BC_Title(x, y, _("Max bitrate:")));
	sprintf(string, "%d", asset->vorbis_max_bitrate);
	add_tool(new OGGVorbisMaxBitrate(x1, y, this, string));


	add_subwindow(new BC_OKButton(this));
	show_window(1);
	unlock_window();
}

int OGGConfigAudio::close_event()
{
	set_done(0);
	return 1;
}

OGGVorbisFixedBitrate::OGGVorbisFixedBitrate(int x, int y, OGGConfigAudio *gui)
 : BC_Radial(x, y, !gui->asset->vorbis_vbr, _("Average bitrate"))
{
	this->gui = gui;
}
int OGGVorbisFixedBitrate::handle_event()
{
	gui->asset->vorbis_vbr = 0;
	gui->variable_bitrate->update(0);
	return 1;
}

OGGVorbisVariableBitrate::OGGVorbisVariableBitrate(int x, int y, OGGConfigAudio *gui)
 : BC_Radial(x, y, gui->asset->vorbis_vbr, _("Variable bitrate"))
{
	this->gui = gui;
}
int OGGVorbisVariableBitrate::handle_event()
{
	gui->asset->vorbis_vbr = 1;
	gui->fixed_bitrate->update(0);
	return 1;
}


OGGVorbisMinBitrate::OGGVorbisMinBitrate(int x,
	int y,
	OGGConfigAudio *gui,
	char *text)
 : BC_TextBox(x, y, 180, 1, text)
{
	this->gui = gui;
}
int OGGVorbisMinBitrate::handle_event()
{
	gui->asset->vorbis_min_bitrate = atol(get_text());
	return 1;
}



OGGVorbisMaxBitrate::OGGVorbisMaxBitrate(int x,
	int y,
	OGGConfigAudio *gui,
	char *text)
 : BC_TextBox(x, y, 180, 1, text)
{
	this->gui = gui;
}
int OGGVorbisMaxBitrate::handle_event()
{
	gui->asset->vorbis_max_bitrate = atol(get_text());
	return 1;
}



OGGVorbisAvgBitrate::OGGVorbisAvgBitrate(int x, int y, OGGConfigAudio *gui, char *text)
 : BC_TextBox(x, y, 180, 1, text)
{
	this->gui = gui;
}
int OGGVorbisAvgBitrate::handle_event()
{
	gui->asset->vorbis_bitrate = atol(get_text());
	return 1;
}





OGGConfigVideo::OGGConfigVideo(BC_WindowBase *parent_window, Asset *asset)
 : BC_Window(_(PROGRAM_NAME ": Video Compression"),
	parent_window->get_abs_cursor_x(1),
	parent_window->get_abs_cursor_y(1),
	450, 220)
{
	this->parent_window = parent_window;
	this->asset = asset;
}

OGGConfigVideo::~OGGConfigVideo()
{

}

void OGGConfigVideo::create_objects()
{
//	add_tool(new BC_Title(10, 10, _("There are no video options for this format")));
	int x = 10, y = 10;
	int x1 = x + 150;
	int x2 = x + 300;

	lock_window("OGGConfigVideo::create_objects");
	add_subwindow(new BC_Title(x, y + 5, _("Bitrate:")));
	add_subwindow(new OGGTheoraBitrate(x1, y, this));
	add_subwindow(fixed_bitrate = new OGGTheoraFixedBitrate(x2, y, this));
	y += 30;

	add_subwindow(new BC_Title(x, y, _("Quality:")));
	add_subwindow(new BC_ISlider(x + 80, y, 0,
		200, 200, 0, 63,
		asset->theora_quality, 0,
		0, &asset->theora_quality));

	add_subwindow(fixed_quality = new OGGTheoraFixedQuality(x2, y, this));
	y += 30;

	add_subwindow(new BC_Title(x, y, _("Keyframe frequency:")));
	OGGTheoraKeyframeFrequency *keyframe_frequency =
		new OGGTheoraKeyframeFrequency(x1 + 60, y, this);
	keyframe_frequency->create_objects();
	y += 30;

	add_subwindow(new BC_Title(x, y, _("Keyframe force frequency:")));
	OGGTheoraKeyframeForceFrequency *keyframe_force_frequency =
		new OGGTheoraKeyframeForceFrequency(x1 + 60, y, this);
	keyframe_force_frequency->create_objects();
	y += 30;

	add_subwindow(new BC_Title(x, y, _("Sharpness:")));
	OGGTheoraSharpness *sharpness =
		new OGGTheoraSharpness(x1 + 60, y, this);
	sharpness->create_objects();
	y += 30;


	add_subwindow(new BC_OKButton(this));
	show_window(1);
	unlock_window();
}


int OGGConfigVideo::close_event()
{
	set_done(0);
	return 1;
}

OGGTheoraBitrate::OGGTheoraBitrate(int x, int y, OGGConfigVideo *gui)
 : BC_TextBox(x, y, 100, 1, gui->asset->theora_bitrate)
{
	this->gui = gui;
}


int OGGTheoraBitrate::handle_event()
{
	// TODO: MIN / MAX check
	gui->asset->theora_bitrate = atol(get_text());
	return 1;
};




OGGTheoraFixedBitrate::OGGTheoraFixedBitrate(int x, int y, OGGConfigVideo *gui)
 : BC_Radial(x, y, gui->asset->theora_fix_bitrate, _("Fixed bitrate"))
{
	this->gui = gui;
}

int OGGTheoraFixedBitrate::handle_event()
{
	update(1);
	gui->asset->theora_fix_bitrate = 1;
	gui->fixed_quality->update(0);
	return 1;
};

OGGTheoraFixedQuality::OGGTheoraFixedQuality(int x, int y, OGGConfigVideo *gui)
 : BC_Radial(x, y, !gui->asset->theora_fix_bitrate, _("Fixed quality"))
{
	this->gui = gui;
}

int OGGTheoraFixedQuality::handle_event()
{
	update(1);
	gui->asset->theora_fix_bitrate = 0;
	gui->fixed_bitrate->update(0);
	return 1;
};

OGGTheoraKeyframeFrequency::OGGTheoraKeyframeFrequency(int x, int y, OGGConfigVideo *gui)
 : BC_TumbleTextBox(gui,
 	(int64_t)gui->asset->theora_keyframe_frequency,
	(int64_t)1,
	(int64_t)500,
	x,
	y,
	40)
{
	this->gui = gui;
}

int OGGTheoraKeyframeFrequency::handle_event()
{
	gui->asset->theora_keyframe_frequency = atol(get_text());
	return 1;
}

OGGTheoraKeyframeForceFrequency::OGGTheoraKeyframeForceFrequency(int x, int y, OGGConfigVideo *gui)
 : BC_TumbleTextBox(gui,
 	(int64_t)gui->asset->theora_keyframe_frequency,
	(int64_t)1,
	(int64_t)500,
	x,
	y,
	40)
{
	this->gui = gui;
}

int OGGTheoraKeyframeForceFrequency::handle_event()
{
	gui->asset->theora_keyframe_frequency = atol(get_text());
	return 1;
}


OGGTheoraSharpness::OGGTheoraSharpness(int x, int y, OGGConfigVideo *gui)
 : BC_TumbleTextBox(gui,
 	(int64_t)gui->asset->theora_sharpness,
	(int64_t)0,
	(int64_t)2,
	x,
	y,
	40)
{
	this->gui = gui;
}

int OGGTheoraSharpness::handle_event()
{
	gui->asset->theora_sharpness = atol(get_text());
	return 1;
}


PackagingEngineOGG::PackagingEngineOGG()
{
	packages = 0;
	default_asset = 0;
}

PackagingEngineOGG::~PackagingEngineOGG()
{
	if(packages)
	{
		for(int i = 0; i < total_packages; i++)
			delete packages[i];
		delete [] packages;
	}
	if (default_asset)
		default_asset->remove_user();
}



int PackagingEngineOGG::create_packages_single_farm(
		EDL *edl,
		Preferences *preferences,
		Asset *default_asset,
		double total_start,
		double total_end)
{
	this->total_start = total_start;
	this->total_end = total_end;
	this->edl = edl;

	this->preferences = preferences;

// We make A COPY of the asset, because we set audio_data = 0 on local asset which is the same copy as default_asset...
// Should be taken care of somewhere else actually
	this->default_asset = new Asset(*default_asset);

	audio_start = Units::to_int64(total_start * default_asset->sample_rate);
	video_start = Units::to_int64(total_start * default_asset->frame_rate);
	audio_position = audio_start;
	video_position = video_start;
	audio_end = Units::to_int64(total_end * default_asset->sample_rate);
	video_end = Units::to_int64(total_end * default_asset->frame_rate);
	current_package = 0;

	double total_len = total_end - total_start;
//printf("PackageDispatcher::create_packages: %f / %d = %f\n", total_len, total_packages, package_len);

	total_packages = 0;
	if (default_asset->audio_data)
		total_packages++;
	if (default_asset->video_data)
		total_packages += preferences->renderfarm_job_count;

	packages = new RenderPackage*[total_packages];

	int local_current_package = 0;
	if (default_asset->audio_data)
	{
		packages[local_current_package] = new RenderPackage;
		snprintf(packages[current_package]->path,
			sizeof(packages[current_package]->path),
			"%s.audio", default_asset->path);
		local_current_package++;
	}

	if (default_asset->video_data)
	{
		video_package_len = (total_len) / preferences->renderfarm_job_count;
		int current_number;    // The number being injected into the filename.
		int number_start;      // Character in the filename path at which the number begins
		int total_digits;      // Total number of digits including padding the user specified.

		Render::get_starting_number(default_asset->path,
			current_number,
			number_start,
			total_digits,
			3);

		for(int i = 0; i < preferences->renderfarm_job_count; i++)
		{
			RenderPackage *package = packages[local_current_package] = new RenderPackage;
			Render::create_filename(package->path,
				default_asset->path,
				current_number,
				total_digits,
				number_start);
			current_number++;
			local_current_package++;
		}
	}
	return 0;
}

RenderPackage* PackagingEngineOGG::get_package_single_farm(double frames_per_second,
		int client_number,
		int use_local_rate)
{

//printf("PackageDispatcher::get_package %ld %ld %ld %ld\n", audio_position, video_position, audio_end, video_end);
	if (current_package == total_packages)
		return 0;

	RenderPackage *result = 0;
	if (current_package == 0 && default_asset->audio_data)
	{
		result = packages[0];
		result->audio_start = audio_start;
		result->video_start = video_start;
		result->audio_end = audio_end;
		result->video_end = video_end;
		result->audio_do = 1;
		result->video_do = 0;
	} else if (default_asset->video_data)
	{
		// Do not do any scaling according to node speed, so we know we can get evenly distributed 'forced' keyframes
		result = packages[current_package];
		result->audio_do = 0;
		result->video_do = 1;

		result->audio_start = audio_position;
		result->video_start = video_position;
		result->audio_end = audio_position +
			Units::round(video_package_len * default_asset->sample_rate);
		result->video_end = video_position +
			Units::round(video_package_len * default_asset->frame_rate);

// Last package... take it all!
		if (current_package == total_packages -1 )
		{
			result->audio_end = audio_end;
			result->video_end = video_end;
		}

		audio_position = result->audio_end;
		video_position = result->video_end;

	}

	current_package ++;
	return result;

}

void PackagingEngineOGG::get_package_paths(ArrayList<char*> *path_list)
{
	for(int i = 0; i < total_packages; i++)
	{
		path_list->append(strdup(packages[i]->path));
	}
// We will mux to the the final file at the end!
	path_list->append(strdup(default_asset->path));
	path_list->set_free();
}

int64_t PackagingEngineOGG::get_progress_max()
{
	return Units::to_int64(default_asset->sample_rate *
			(total_end - total_start)) * 2+
		Units::to_int64(preferences->render_preroll *
			total_packages *
			default_asset->sample_rate);
}

int PackagingEngineOGG::packages_are_done()
{


// Mux audio and video into one file

// First fix our asset... have to workaround the bug of corruption of local asset
//	Render::check_asset(edl, *default_asset);

	Asset *video_asset = 0, *audio_asset = 0;
	File *audio_file_gen = 0, *video_file_gen = 0;
	FileOGG *video_file = 0, *audio_file = 0;
	ogg_stream_state audio_in_stream, video_in_stream;

	int local_current_package = 0;
	if (default_asset->audio_data)
	{
		audio_asset = new Asset(packages[local_current_package]->path);
		audio_asset->format = FILE_OGG;
		local_current_package++;

		audio_file_gen = new File();
		audio_file_gen->open_file(preferences, audio_asset, 1, 0);
		audio_file = (FileOGG*) audio_file_gen->file;
		ogg_stream_init(&audio_in_stream, audio_file->tf->vo.serialno);
		audio_file->ogg_seek_to_databegin(audio_file->tf->audiosync, audio_file->tf->vo.serialno);
	}

	if (default_asset->video_data)
	{
		video_asset = new Asset(packages[local_current_package]->path);
		video_asset->format = FILE_OGG;
		local_current_package++;

		video_file_gen = new File();
		video_file_gen->open_file(preferences, video_asset, 1, 0);
		video_file = (FileOGG*) video_file_gen->file;
		ogg_stream_init(&video_in_stream, video_file->tf->to.serialno);
		video_file->ogg_seek_to_databegin(video_file->tf->videosync, video_file->tf->to.serialno);
	}

// Output file
	File *output_file_gen = new File();
	output_file_gen->open_file(preferences, default_asset, 0, 1);
	FileOGG *output_file = (FileOGG*) output_file_gen->file;

	//ogg_page og;    /* one Ogg bitstream page.  Vorbis packets are inside */
	ogg_packet op;  /* one raw packet of data for decode */


	int audio_ready = default_asset->audio_data;
	int video_ready = default_asset->video_data;
	int64_t video_packetno = 1;
	int64_t audio_packetno = 1;
	int64_t frame_offset = 0;
	int64_t current_frame = 0;
	while ((default_asset->audio_data && audio_ready) || (default_asset->video_data && video_ready))
	{
		if (video_ready)
		{
			while (ogg_stream_packetpeek(&video_in_stream, NULL) != 1) // get as many pages as needed for one package
			{
				if (!video_file->ogg_get_next_page(video_file->tf->videosync, video_file->tf->to.serialno, &video_file->tf->videopage))
				{
					// We are at the end of our file, see if it is more and open more if there is
					if (local_current_package < total_packages)
					{
						frame_offset = current_frame +1;
						ogg_stream_clear(&video_in_stream);
						video_file_gen->close_file();
						delete video_file_gen;
						if( video_asset ) video_asset->remove_user();
						video_asset = new Asset(packages[local_current_package]->path);
						video_asset->format = FILE_OGG;
						local_current_package++;

						video_file_gen = new File();
						video_file_gen->open_file(preferences, video_asset, 1, 0);
						video_file = (FileOGG*) video_file_gen->file;
						ogg_stream_init(&video_in_stream, video_file->tf->to.serialno);
						video_file->ogg_seek_to_databegin(video_file->tf->videosync, video_file->tf->to.serialno);

					} else
						video_ready = 0;
					break;
				}
				ogg_stream_pagein(&video_in_stream, &video_file->tf->videopage);
			}
			while (ogg_stream_packetpeek(&video_in_stream, NULL) == 1) // get all packets out of the page
			{
				ogg_stream_packetout(&video_in_stream, &op);
				if (local_current_package != total_packages) // keep it from closing the stream
					op.e_o_s = 0;
				if (video_packetno != 1)		     // if this is not the first video package do not start with b_o_s
					op.b_o_s = 0;
				else
					op.b_o_s = 1;
				op.packetno = video_packetno;
				video_packetno ++;
				int64_t granulepos = op.granulepos;
				if (granulepos != -1)
				{
				// Fix granulepos!
					int64_t rel_iframe = granulepos >> video_file->theora_keyframe_granule_shift;
					int64_t rel_pframe = granulepos - (rel_iframe << video_file->theora_keyframe_granule_shift);
					int64_t rel_current_frame = rel_iframe + rel_pframe;
					current_frame = frame_offset + rel_current_frame;
					int64_t abs_iframe = current_frame - rel_pframe;

					op.granulepos = (abs_iframe << video_file->theora_keyframe_granule_shift) + rel_pframe;

//					printf("iframe: %i, pframe: %i, granulepos: %i, op.packetno %lli, abs_iframe: %i\n", rel_iframe, rel_pframe, granulepos, op.packetno, abs_iframe);

				}
				ogg_stream_packetin (&output_file->tf->to, &op);
				output_file->tf->v_pkg++;
			}
		}
		if (audio_ready)
		{
			while (ogg_stream_packetpeek(&audio_in_stream, NULL) != 1) // get as many pages as needed for one package
			{
				if (!audio_file->ogg_get_next_page(audio_file->tf->audiosync, audio_file->tf->vo.serialno, &audio_file->tf->audiopage))
				{
					audio_ready = 0;
					break;
				}
				ogg_stream_pagein(&audio_in_stream, &audio_file->tf->audiopage);
			}
			while (ogg_stream_packetpeek(&audio_in_stream, NULL) == 1) // get all packets out of the page
			{
				ogg_stream_packetout(&audio_in_stream, &op);
				ogg_stream_packetin (&output_file->tf->vo, &op);
				audio_packetno++;
				output_file->tf->a_pkg++;
			}
		}

		output_file->flush_ogg(0);


	}

// flush_ogg(1) is called on file closing time...
//	output_file->flush_ogg(1);

// Just prevent thet write_samples and write_frames are called
	output_file->final_write = 0;

	if (default_asset->audio_data)
	{
		ogg_stream_clear(&audio_in_stream);
		audio_file_gen->close_file();
		delete audio_file_gen;
		if( audio_asset )
			audio_asset->remove_user();
	}
	if (default_asset->video_data)
	{
		ogg_stream_clear(&video_in_stream);
		video_file_gen->close_file();
		delete video_file_gen;
		if( video_asset )
			video_asset->remove_user();
	}

	output_file_gen->close_file();
	delete output_file_gen;

// don't delete the temp files, for now
//	for(int i = 0; i < total_packages; i++)
//		unlink(packages[i]->path);

	return 0;
}