Method run

server/VGLTrans.cpp:153–250

void VGLTrans::run(void)
{
	Frame *lastf = NULL, *f = NULL;
	long bytes = 0;
	Timer timer, sleepTimer;  double err = 0.;  bool first = true;
	int i;

	try
	{
		VGLTrans::Compressor *comp[MAXPROCS];  Thread *cthread[MAXPROCS];
		if(fconfig.verbose)
			vglout.println("[VGL] Using %d compression threads on %d CPU cores",
				nprocs, NumProcs());
		for(i = 0; i < nprocs; i++)
			comp[i] = new VGLTrans::Compressor(i, this);
		if(nprocs > 1) for(i = 1; i < nprocs; i++)
		{
			cthread[i] = new Thread(comp[i]);
			cthread[i]->start();
		}

		while(!deadYet)
		{
			int np;
			void *ftemp = NULL;

			q.get(&ftemp);  f = (Frame *)ftemp;  if(deadYet) break;
			if(!f) THROW("Queue has been shut down");
			ready.signal();
			np = nprocs;  if(f->hdr.compress == RRCOMP_YUV) np = 1;
			if(np > 1)
			{
				for(i = 1; i < np; i++)
				{
					cthread[i]->checkError();  comp[i]->go(f, lastf);
				}
			}
			comp[0]->compressSend(f, lastf);
			bytes += comp[0]->bytes;
			if(np > 1)
			{
				for(i = 1; i < np; i++)
				{
					comp[i]->stop();  cthread[i]->checkError();  comp[i]->send();
					bytes += comp[i]->bytes;
				}
			}
			sendHeader(f->hdr, true);

			profTotal.endFrame(f->hdr.width * f->hdr.height, bytes, 1);
			bytes = 0;
			profTotal.startFrame();

			if(fconfig.flushdelay > 0.)
			{
				long usec = (long)(fconfig.flushdelay * 1000000.);
				if(usec > 0) usleep(usec);
			}