102 struct dataPub dp;  variable
150 	fsize = dp.nclnt * (maxClients + 1);  in validationResults()
166 		fcntl(dp.fd, F_GETLK, &request);  in validationResults()
178 	P("Master opens %s\n", dp.fname);  in initTest()
179 	dp.fd = open(dp.fname, OPENFLAGS, MANDMODES);  in initTest()
180 	if (dp.fd < 0) {  in initTest()
184 	P("fd=%d\n", dp.fd);  in initTest()
197 	df->dp = &dp;  in initClientFork()
200 	dp.lclnt[i] = malloc(sizeof(int) * 2);  in initClientFork()
201 	if (pipe(dp.lclnt[i]) < 0) {  in initClientFork()
215 	dp.nclnt = clnt;  in initialize()
216 	dp.lclnt = malloc(sizeof(int *) * clnt);  in initialize()
217 	dp.lthreads = malloc(sizeof(pthread_t) * clnt);  in initialize()
220 	if (pipe(dp.master) < 0) {  in initialize()
235 	free(dp.lclnt[i]);  in cleanClient()
242 	free(dp.lthreads);  in clean()
243 	free(dp.lclnt);  in clean()
250 	for (i = 0; i < dp.nclnt; i++) {  in loadProcess()
308 	for (i = 0; i < dp.nclnt; i++)  in serverSendLocal()
309 		write(dp.lclnt[i][1], message, M_SIZE);  in serverSendLocal()
323 		for (i = 0; i < dp.nclnt; i++) {  in serverReceiveNet()
333 	for (i = 0; i < dp.nclnt; i++)  in serverReceiveLocal()
426 	return write(dp.lclnt[slave][1], message, M_SIZE);  in serverSendLockLocal()
464 		for (i = 0; i < dp.nclnt; i++) {  in getResults()
472 	for (i = 0; i < dp.nclnt; i++) {  in getResults()
499 	masterReader = dp.master[0];  in masterClient()
530 				for (i = 0; i < dp.nclnt; i++) {  in masterClient()
533 					write(dp.lclnt[i][1], message, M_SIZE);  in masterClient()
552 			for (i = 0; i < dp.nclnt; i++) {  in masterClient()
590 	clnt = dp.nclnt;  in master()
591 	masterReader = dp.master[0];  in master()
634 			write(dp.fd, phraseTest, strlen(phraseTest));  in master()
636 			if (fcntl(dp.fd, F_SETLK, &request) < 0) {  in master()
670 			write(dp.fd, buf, clnt);  in master()
725 			close(dp.fd);  in master()
768 	slaveReader = dp.lclnt[i][0];  in slave()
769 	slaveWriter = dp.master[1];  in slave()
785 			if ((ftest = open(dp.fname, O_RDONLY | O_NONBLOCK)) < 0) {  in slave()
788 				if (dp.verbose)  in slave()
804 			if ((ftest = open(dp.fname, O_WRONLY | O_NONBLOCK)) < 0) {  in slave()
807 				if (dp.verbose)  in slave()
824 			if ((ftest = open(dp.fname, O_RDONLY | O_NONBLOCK)) < 0) {  in slave()
827 				if (dp.verbose)  in slave()
840 				if (dp.verbose || errno != EAGAIN)  in slave()
851 			if ((ftest = open(dp.fname, O_WRONLY | O_NONBLOCK)) < 0) {  in slave()
854 				if (dp.verbose)  in slave()
866 				if (dp.verbose || errno != EAGAIN)  in slave()
888 			if ((ftest = open(dp.fname, O_RDWR | O_NONBLOCK)) < 0) {  in slave()
891 				if (dp.verbose)  in slave()
897 				if (dp.verbose || errno != EAGAIN)  in slave()
963 	dp.fname = NULL;  in main()
964 	dp.verbose = 0;  in main()
981 			if (!(dp.fname = nextArg(argc, argv, &i)))  in main()
986 			dp.verbose = TRUE;  in main()
1005 		if (!(dp.fname && nThread))  in main()
1009 			setupClients(type, dp.fname, nThread);  in main()
1013 		dp.fname = malloc(512);  in main()
1014 		memset(dp.fname, 0, 512);  in main()
1015 		getConfiguration(&type, dp.fname, &nThread);  in main()
1018 	if (dp.verbose)  in main()
1029 		free(dp.fname);  in main()