Class Compressor

common/frameut.cpp:304–411

class Compressor : public Runnable
{
	public:

		Compressor(Decompressor *decompressor_, Blitter *blitter_) : findex(0),
			deadYet(false), thread(NULL), decompressor(decompressor_)
			#ifdef USEXV
			, blitter(blitter_)
			#endif
		{
			thread = new Thread(this);
			thread->start();
			#ifdef USEHELGRIND
			ANNOTATE_BENIGN_RACE_SIZED(&deadYet, sizeof(bool), );
			#endif
		}

		virtual ~Compressor(void)
		{
			if(thread) thread->stop();
		}

		Frame &get(int width, int height, int pixelFormat)
		{
			Frame &frame = frames[findex];
			findex = (findex + 1) % NFRAMES;
			if(thread) thread->checkError();
			if(!deadYet) frame.waitUntilComplete();
			if(thread) thread->checkError();
			rrframeheader hdr;
			memset(&hdr, 0, sizeof(rrframeheader));
			hdr.framew = hdr.width = width + BORDER;
			hdr.frameh = hdr.height = height + BORDER;
			hdr.x = hdr.y = BORDER;
			hdr.qual = 80;
			hdr.subsamp = 2;
			hdr.compress = useRGB ? RRCOMP_RGB : RRCOMP_JPEG;
			if(useXV) hdr.compress = RRCOMP_YUV;
			frame.init(hdr, pixelFormat, 0);
			return frame;
		}

		void put(Frame &frame)
		{
			if(thread) thread->checkError();
			frame.signalReady();
		}

		void shutdown(void)
		{
			deadYet = true;
			int i;
			for(i = 0; i < NFRAMES; i++)
				frames[i].signalReady();  // Release my thread
			if(thread)
			{
				thread->stop();  delete thread;  thread = NULL;
			}