bsd/vfs/vfs_fsevents.c

114     struct fsevent_handle *fseh;
882 add_watcher(int8_t *event_list, int32_t num_events, int32_t eventq_size, fs_event_watcher **watcher_out, void *fseh)
913     watcher->fseh         = fseh;
1549     fsevent_handle *fseh = (struct fsevent_handle *)fp->f_fglob->fg_data;
1552     error = fmod_watch(fseh->watcher, uio);
1593     fsevent_handle *fseh = (struct fsevent_handle *)fp->f_fglob->fg_data;
1623     OSAddAtomic(1, &fseh->active);
1624     if (fseh->flags & FSEH_CLOSING) {
1625 	OSAddAtomic(-1, &fseh->active);
1635 	    fseh->watcher->flags |= WATCHER_WANTS_COMPACT_EVENTS;
1640 	    fseh->watcher->flags |= WATCHER_WANTS_EXTENDED_INFO;
1645 		*(uint64_t *)data = fseh->watcher->max_event_id;
1661 		tmp = fseh->watcher->devices_not_to_watch;
1664 		fseh->watcher->devices_not_to_watch = NULL;
1665 		fseh->watcher->num_devices = new_num_devices;
1691 	    fseh->watcher->num_devices = new_num_devices;
1692 	    tmp = fseh->watcher->devices_not_to_watch;
1693 	    fseh->watcher->devices_not_to_watch = devices_not_to_watch;
1708     OSAddAtomic(-1, &fseh->active);
1716     fsevent_handle *fseh = (struct fsevent_handle *)fp->f_fglob->fg_data;
1719     if ((which != FREAD) || (fseh->watcher->flags & WATCHER_CLOSING)) {
1725     if (fseh->watcher->rd != fseh->watcher->wr) {
1730 	selrecord(vfs_context_proc(ctx), &fseh->si, wql);
1748     fsevent_handle *fseh = (struct fsevent_handle *)fg->fg_data;
1751     OSBitOrAtomic(FSEH_CLOSING, &fseh->flags);
1752     while (OSAddAtomic(0, &fseh->active) > 0) {
1753 	tsleep((caddr_t)fseh->watcher, PRIBIO, "fsevents-close", 1);
1756     watcher = fseh->watcher;
1758     fseh->watcher = NULL;
1761     FREE(fseh, M_TEMP);
1769 	fsevent_handle *fseh = (struct fsevent_handle *)kn->kn_hook;
1773 	KNOTE_DETACH(&fseh->knotes, kn);
1790 	fsevent_handle *fseh = (struct fsevent_handle *)kn->kn_hook;
1799 	rd = fseh->watcher->rd;
1800 	wr = fseh->watcher->wr;
1804 	    amt = fseh->watcher->eventq_size - (rd - wr);
1844     fsevent_handle *fseh = (struct fsevent_handle *)fp->f_fglob->fg_data;
1846     kn->kn_hook = (void*)fseh;
1852     KNOTE_ATTACH(&fseh->knotes, kn);
1863     fsevent_handle *fseh = (struct fsevent_handle *)fp->f_fglob->fg_data;
1865     fseh->watcher->flags |= WATCHER_CLOSING;
1871     while(fseh->watcher->blockers && counter++ < 500) {
1879 	fsevents_wakeup(fseh->watcher);
1882 	tsleep((caddr_t)fseh->watcher, PRIBIO, "watcher-close", 1);
2116     fsevent_handle *fseh = NULL;
2155 	    MALLOC(fseh, fsevent_handle *, sizeof(fsevent_handle),
2157 	    if (fseh == NULL) {
2160 	    memset(fseh, 0, sizeof(fsevent_handle));
2162 	    klist_init(&fseh->knotes);
2168 		FREE(fseh, M_TEMP);
2177 		FREE(fseh, M_TEMP);
2184 			        &fseh->watcher,
2185 			        fseh);
2188 		FREE(fseh, M_TEMP);
2192 	    fseh->watcher->fseh = fseh;
2197 		FREE(fseh, M_TEMP);
2204 	    f->f_fglob->fg_data = (caddr_t) fseh;
2228     selwakeup(&watcher->fseh->si);
2229     KNOTE(&watcher->fseh->knotes, NOTE_WRITE|NOTE_NONE);