Lines Matching defs:worker
83 * are exported to several worker processes. While one worker writes the
95 #define WORKERS 3 /* 1 worker writing, 1 reading, 1 for slack */
96 struct worker {
102 int fd; /* FD for this worker */
103 int pid; /* PID for this worker */
104 int sent; /* 1 == we've sent this worker requests */
108 struct worker *wp;
295 /* Read results back from next worker */
460 struct worker *twp;
469 * be replayed on the next tape. Use the extra worker buffers
471 * each worker in turn.
478 * For each request in the current worker, copy it to twp.
761 signal(SIGUSR2, proceed); /* Slave sends SIGUSR2 to next worker */
826 quite(errno, "worker couldn't reopen disk");
829 * Need the pid of the next worker in the loop...
833 quit("master/worker protocol botched - didn't get pid"
834 " of next worker");
852 quit("master/worker protocol botched");
880 fprintf(stderr, "worker %d wrote %d werror %d\n",
893 "worker %d only wrote %d out of %d bytes and gave up.\n",
922 * If partial write, don't want next worker to go.
Indexes created Tue Sep 30 10:09:55 GMT 2025