#include "common.h"
#include "ZFarmScanner.h"
#include <unistd.h>

bool ZFarmScanner::openTo(int n,const char* sInterpreter,const char* sScript)
{
	pOut = new FILE*[n];
	nKids = n;
	for (int i=0; i<nKids; ++i) {
		int f[2];
		VERIFY(0 == pipe(f));
		int pid = fork();
		if (0 == pid) {
			dup2(f[0],0);
			close(f[1]);
			execl(sInterpreter,sInterpreter,sScript,(char*)0);
			onError(sInterpreter,errno);
			exit(2);
		} else {
			pOut[i] = fdopen(f[1],"w");
			if (!pOut[i]) {
				onError("fdopen-pipe",errno);
				return false;
			}
		}
	}
	return true;
}

void ZFarmScanner::onLine(const char* sLine) 
{
	++nLines;
	cbFile += strlen(sLine);
	FILE* f = pOut[nLines % nKids];
	fputs(sLine,f);
	fputc('\n',f);
}