Class Decompressor

common/frameut.cpp:216–301

class Decompressor : public Runnable
{
	public:

		Decompressor(Blitter *blitter_, Display *dpy_, Window win_, int myID_) :
			blitter(blitter_), findex(0), deadYet(false), dpy(dpy_), win(win_),
			myID(myID_), thread(NULL)
		{
			thread = new Thread(this);
			thread->start();
			#ifdef USEHELGRIND
			ANNOTATE_BENIGN_RACE_SIZED(&deadYet, sizeof(bool), );
			#endif
		}

		virtual ~Decompressor(void) { shutdown(); }

		CompressedFrame &get(void)
		{
			CompressedFrame &cframe = cframes[findex];
			findex = (findex + 1) % NFRAMES;
			if(deadYet) return cframe;
			if(thread) thread->checkError();
			if(!deadYet) cframe.waitUntilComplete();
			if(thread) thread->checkError();
			return cframe;
		}

		void put(CompressedFrame &cframe)
		{
			if(thread) thread->checkError();
			cframe.signalReady();
		}

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

	private:

		void run(void)
		{
			int index = 0;  Frame *frame = NULL;
			try
			{
				while(!deadYet)
				{
					CompressedFrame &cframe = cframes[index];