Method run

common/frameut.cpp:368–402

	private:

		void run(void)
		{
			int index = 0;
			try
			{
				while(!deadYet)
				{
					Frame &frame = frames[index];
					index = (index + 1) % NFRAMES;
					frame.waitUntilReady();  if(deadYet) break;
					#ifdef USEXV
					if(useXV)
					{
						XVFrame *xvframe = (XVFrame *)blitter->get();  if(deadYet) break;
						*xvframe = frame;
						blitter->put(xvframe);
					}
					else
					#endif
					{
						CompressedFrame &cframe = decompressor->get();  if(deadYet) break;
						cframe = frame;
						decompressor->put(cframe);
					}
					frame.signalComplete();
				}
			}
			catch(std::exception &e)
			{
				if(thread) thread->setError(e);
				for(int i = 0; i < NFRAMES; i++) frames[i].signalComplete();
				throw;
			}
			fprintf(stderr, "Compressor exiting ...\n");
		}

		int findex;  bool deadYet;
		Thread *thread;