Lines Matching refs:slaves
105 } slaves[SLAVES+1]; variable
146 slaves[i].tblock = (char (*)[TP_BSIZE]) in alloctape()
148 slaves[i].req = (struct req *)slaves[i].tblock - ntrec - 1; in alloctape()
150 slp = &slaves[0]; in alloctape()
240 if (++slp >= &slaves[SLAVES]) in flushtape()
241 slp = &slaves[0]; in flushtape()
261 if (slaves[i].sent) { in flushtape()
262 if (atomic(read, slaves[i].fd, in flushtape()
268 slaves[i].sent = 0; in flushtape()
317 if (slaves[f].sent) { in trewind()
318 if (atomic(read, slaves[f].fd, (char *)&got, sizeof got) in trewind()
323 slaves[f].sent = 0; in trewind()
330 (void) close(slaves[f].fd); in trewind()
396 tslp = &slaves[SLAVES]; in rollforward()
447 if (++slp >= &slaves[SLAVES]) in rollforward()
448 slp = &slaves[0]; in rollforward()
708 if (i == slp - &slaves[0]) { in enslave()
715 (slaves[i].pid = fork()) < 0) in enslave()
719 slaves[i].fd = cmd[1]; in enslave()
720 slaves[i].sent = 0; in enslave()
721 if (slaves[i].pid == 0) { /* Slave starts up here */ in enslave()
723 (void) close(slaves[j].fd); in enslave()
731 (void) atomic(write, slaves[i].fd, in enslave()
732 (char *) &slaves[(i + 1) % SLAVES].pid, in enslave()
733 sizeof slaves[0].pid); in enslave()
744 if (slaves[i].pid > 0) { in killall()
745 (void) kill(slaves[i].pid, SIGKILL); in killall()
746 slaves[i].sent = 0; in killall()