Lines Matching defs:wr
109 int32_t wr; // write index into the event_queue
532 printf("add_fsevent: watcher %s %p: rd %4d wr %4d q_size %4d flags 0x%x\n",
535 watcher_table[ii]->rd, watcher_table[ii]->wr,
909 watcher->wr = 0;
989 // 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);
1010 while(watcher->rd != watcher->wr) {
1051 if (watcher_table[i] != NULL && watcher_table[i]->rd != watcher_table[i]->wr) {
1095 if (((watcher->wr + 1) % watcher->eventq_size) == watcher->rd) {
1102 watcher->event_queue[watcher->wr] = kfse;
1104 watcher->wr = (watcher->wr + 1) % watcher->eventq_size;
1113 if (watcher->rd < watcher->wr) {
1114 num_pending = watcher->wr - watcher->rd;
1117 if (watcher->rd > watcher->wr) {
1118 num_pending = watcher->wr + watcher->eventq_size - watcher->rd;
1124 while (watcher->rd != watcher->wr) {
1136 printf("fsevents: watcher falling behind: %s (pid: %d) rd: %4d wr: %4d q_size: %4d flags: 0x%x\n",
1137 watcher->proc_name, watcher->pid, watcher->rd, watcher->wr,
1404 if (watcher->rd == watcher->wr) {
1448 while (uio_resid(uio) > 0 && watcher->rd != watcher->wr) {
1725 if (fseh->watcher->rd != fseh->watcher->wr) {
1792 int32_t rd, wr, amt;
1800 wr = fseh->watcher->wr;
1801 if (rd <= wr) {
1802 amt = wr - rd;
1804 amt = fseh->watcher->eventq_size - (rd - wr);