Lines Matching defs:rd
108 int32_t rd; // read index into the event_queue
672 printf("add_fsevent: watcher %p: num dropped %d rd %4d wr %4d q_size %4d flags 0x%x\n",
674 watcher_table[ii]->rd, watcher_table[ii]->wr,
1258 watcher->rd = 0;
1327 // printf("fsevents: removing watcher %p (rd %d wr %d num_readers %d flags 0x%x)\n", watcher, watcher->rd, watcher->wr, watcher->num_readers, watcher->flags);
1344 while(watcher->rd != watcher->wr) {
1347 kfse = watcher->event_queue[watcher->rd];
1349 panic("remove_watcher: bogus kfse %p during cleanup (type %d refcount %d rd %d wr %d)\n", kfse, kfse->type, kfse->refcount, watcher->rd, watcher->wr);
1354 watcher->rd = (watcher->rd+1) % watcher->eventq_size;
1391 if (watcher_table[i] != NULL && watcher_table[i]->rd != watcher_table[i]->wr) {
1431 if (((watcher->wr + 1) % watcher->eventq_size) == watcher->rd) {
1448 if ( (watcher->rd < watcher->wr && (watcher->wr - watcher->rd) > MAX_NUM_PENDING)
1449 || (watcher->rd > watcher->wr && (watcher->wr + watcher->eventq_size - watcher->rd) > MAX_NUM_PENDING)) {
1725 if (watcher->rd == watcher->wr) {
1767 while (uio_resid(uio) > 0 && watcher->rd != watcher->wr) {
1779 kfse = watcher->event_queue[watcher->rd];
1781 panic("fmod_watch: someone left me a bogus kfse %p (type %d refcount %d rd %d wr %d)\n", kfse, kfse->type, kfse->refcount, watcher->rd, watcher->wr);
1807 watcher->rd = (watcher->rd + 1) % watcher->eventq_size;
1811 panic("fmod_watch:2: my kfse became bogus! kfse %p (type %d refcount %d rd %d wr %d)\n", kfse, kfse->type, kfse->refcount, watcher->rd, watcher->wr);
2011 if (fseh->watcher->rd != fseh->watcher->wr) {