bsd/vfs/vfs_fsevents.c

108     int32_t      rd;                     // read 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,
908     watcher->rd           = 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) {
1011 	    kfse = watcher->event_queue[watcher->rd];
1012 	    watcher->event_queue[watcher->rd] = NULL;
1013 	    watcher->rd = (watcher->rd+1) % watcher->eventq_size;
1051 	if (watcher_table[i] != NULL && watcher_table[i]->rd != watcher_table[i]->wr) {
1095     if (((watcher->wr + 1) % watcher->eventq_size) == watcher->rd) {
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) {
1125 	kfse = watcher->event_queue[watcher->rd];
1126 	watcher->event_queue[watcher->rd] = NULL;
1127 	watcher->rd = (watcher->rd+1) % watcher->eventq_size;
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) {
1458 	kfse = watcher->event_queue[watcher->rd];
1497 	watcher->event_queue[watcher->rd] = NULL;
1498 	watcher->rd = (watcher->rd + 1) % watcher->eventq_size;
1725     if (fseh->watcher->rd != fseh->watcher->wr) {
1792 	int32_t rd, wr, amt;
1799 	rd = fseh->watcher->rd;
1801 	if (rd <= wr) {
1802 	    amt = wr - rd;
1804 	    amt = fseh->watcher->eventq_size - (rd - wr);