Class Compressor

server/VGLTrans.h:70–146

			rrversion version;

		class Compressor : public util::Runnable
		{
			public:

				Compressor(int myRank_, VGLTrans *parent_) : bytes(0),
					storedFrames(0), cframes(NULL), frame(NULL), lastFrame(NULL),
					myRank(myRank_), deadYet(false), parent(parent_)
				{
					if(parent) nprocs = parent->nprocs;
					ready.wait();  complete.wait();
					char temps[20];
					snprintf(temps, 20, "Compress %d", myRank);
					profComp.setName(temps);
					#ifdef USEHELGRIND
					ANNOTATE_BENIGN_RACE_SIZED(&deadYet, sizeof(bool), );
					#endif
				}

				virtual ~Compressor(void)
				{
					shutdown();
					free(cframes);  cframes = NULL;
				}

				void run(void)
				{
					while(!deadYet)
					{
						try
						{
							ready.wait();  if(deadYet) break;
							compressSend(frame, lastFrame);
							complete.signal();
						}
						catch(...)
						{
							complete.signal();  throw;
						}
					}
				}

				void go(common::Frame *frame_, common::Frame *lastFrame_)
				{
					frame = frame_;  lastFrame = lastFrame_;
					ready.signal();
				}

				void stop(void)
				{
					complete.wait();
				}

				void shutdown(void) { deadYet = true;  ready.signal(); }
				void compressSend(common::Frame *frame, common::Frame *lastFrame);
				void send(void);

				long bytes;