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