?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
comctl32/listbox: Use a helper function to check the selection state of an item.
[wine.git] / server / change.c
blob3dd52aa167d8ae86fcc51d7b4d6055f677ef2bfa
1 /*
2 * Server-side change notification management
3 *
4 * Copyright (C) 1998 Alexandre Julliard
5 * Copyright (C) 2006 Mike McCormack
6 *
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2.1 of the License, or (at your option) any later version.
11 *
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
20 */
21
22 #include "config.h"
23 #include "wine/port.h"
24
25 #include <assert.h>
26 #include <fcntl.h>
27 #include <stdio.h>
28 #include <stdlib.h>
29 #include <signal.h>
30 #include <sys/stat.h>
31 #include <sys/types.h>
32 #include <limits.h>
33 #include <dirent.h>
34 #include <errno.h>
35 #ifdef HAVE_POLL_H
36 # include <poll.h>
37 #endif
38
39 #include "ntstatus.h"
40 #define WIN32_NO_STATUS
41 #include "windef.h"
42
43 #include "file.h"
44 #include "handle.h"
45 #include "thread.h"
46 #include "request.h"
47 #include "process.h"
48 #include "security.h"
49 #include "winternl.h"
50
51 /* dnotify support */
52
53 #ifdef linux
54 #ifndef F_NOTIFY
55 #define F_NOTIFY 1026
56 #define DN_ACCESS 0x00000001 /* File accessed */
57 #define DN_MODIFY 0x00000002 /* File modified */
58 #define DN_CREATE 0x00000004 /* File created */
59 #define DN_DELETE 0x00000008 /* File removed */
60 #define DN_RENAME 0x00000010 /* File renamed */
61 #define DN_ATTRIB 0x00000020 /* File changed attributes */
62 #define DN_MULTISHOT 0x80000000 /* Don't remove notifier */
63 #endif
64 #endif
65
66 /* inotify support */
67
68 #ifdef HAVE_SYS_INOTIFY_H
69 #include <sys/inotify.h>
70 #define USE_INOTIFY
71 #elif defined(__linux__) && defined(__i386__)
72
73 #define SYS_inotify_init 291
74 #define SYS_inotify_add_watch 292
75 #define SYS_inotify_rm_watch 293
76
77 struct inotify_event {
78 int wd;
79 unsigned int mask;
80 unsigned int cookie;
81 unsigned int len;
82 char name[1];
83 };
84
85 #define IN_ACCESS 0x00000001
86 #define IN_MODIFY 0x00000002
87 #define IN_ATTRIB 0x00000004
88 #define IN_CLOSE_WRITE 0x00000008
89 #define IN_CLOSE_NOWRITE 0x00000010
90 #define IN_OPEN 0x00000020
91 #define IN_MOVED_FROM 0x00000040
92 #define IN_MOVED_TO 0x00000080
93 #define IN_CREATE 0x00000100
94 #define IN_DELETE 0x00000200
95 #define IN_DELETE_SELF 0x00000400
96
97 #define IN_ISDIR 0x40000000
98
99 static inline int inotify_init( void )
100 {
101 return syscall( SYS_inotify_init );
102 }
103
104 static inline int inotify_add_watch( int fd, const char *name, unsigned int mask )
105 {
106 return syscall( SYS_inotify_add_watch, fd, name, mask );
107 }
108
109 static inline int inotify_rm_watch( int fd, int wd )
110 {
111 return syscall( SYS_inotify_rm_watch, fd, wd );
112 }
113
114 #define USE_INOTIFY
115
116 #endif
117
118 struct inode;
119
120 static void free_inode( struct inode *inode );
121
122 static struct fd *inotify_fd;
123
124 struct change_record {
125 struct list entry;
126 unsigned int cookie;
127 struct filesystem_event event;
128 };
129
130 struct dir
131 {
132 struct object obj; /* object header */
133 struct fd *fd; /* file descriptor to the directory */
134 mode_t mode; /* file stat.st_mode */
135 uid_t uid; /* file stat.st_uid */
136 struct list entry; /* entry in global change notifications list */
137 unsigned int filter; /* notification filter */
138 int notified; /* SIGIO counter */
139 int want_data; /* return change data */
140 int subtree; /* do we want to watch subdirectories? */
141 struct list change_records; /* data for the change */
142 struct list in_entry; /* entry in the inode dirs list */
143 struct inode *inode; /* inode of the associated directory */
144 struct process *client_process; /* client process that has a cache for this directory */
145 int client_entry; /* entry in client process cache */
146 };
147
148 static struct fd *dir_get_fd( struct object *obj );
149 static struct security_descriptor *dir_get_sd( struct object *obj );
150 static int dir_set_sd( struct object *obj, const struct security_descriptor *sd,
151 unsigned int set_info );
152 static void dir_dump( struct object *obj, int verbose );
153 static struct object_type *dir_get_type( struct object *obj );
154 static int dir_close_handle( struct object *obj, struct process *process, obj_handle_t handle );
155 static void dir_destroy( struct object *obj );
156
157 static const struct object_ops dir_ops =
158 {
159 sizeof(struct dir), /* size */
160 dir_dump, /* dump */
161 dir_get_type, /* get_type */
162 add_queue, /* add_queue */
163 remove_queue, /* remove_queue */
164 default_fd_signaled, /* signaled */
165 no_satisfied, /* satisfied */
166 no_signal, /* signal */
167 dir_get_fd, /* get_fd */
168 default_fd_map_access, /* map_access */
169 dir_get_sd, /* get_sd */
170 dir_set_sd, /* set_sd */
171 no_lookup_name, /* lookup_name */
172 no_link_name, /* link_name */
173 NULL, /* unlink_name */
174 no_open_file, /* open_file */
175 dir_close_handle, /* close_handle */
176 dir_destroy /* destroy */
177 };
178
179 static int dir_get_poll_events( struct fd *fd );
180 static enum server_fd_type dir_get_fd_type( struct fd *fd );
181
182 static const struct fd_ops dir_fd_ops =
183 {
184 dir_get_poll_events, /* get_poll_events */
185 default_poll_event, /* poll_event */
186 dir_get_fd_type, /* get_fd_type */
187 no_fd_read, /* read */
188 no_fd_write, /* write */
189 no_fd_flush, /* flush */
190 default_fd_get_file_info, /* get_file_info */
191 no_fd_get_volume_info, /* get_volume_info */
192 default_fd_ioctl, /* ioctl */
193 default_fd_queue_async, /* queue_async */
194 default_fd_reselect_async /* reselect_async */
195 };
196
197 static struct list change_list = LIST_INIT(change_list);
198
199 /* per-process structure to keep track of cache entries on the client size */
200 struct dir_cache
201 {
202 unsigned int size;
203 unsigned int count;
204 unsigned char state[1];
205 };
206
207 enum dir_cache_state
208 {
209 DIR_CACHE_STATE_FREE,
210 DIR_CACHE_STATE_INUSE,
211 DIR_CACHE_STATE_RELEASED
212 };
213
214 /* return an array of cache entries that can be freed on the client side */
215 static int *get_free_dir_cache_entries( struct process *process, data_size_t *size )
216 {
217 int *ret;
218 struct dir_cache *cache = process->dir_cache;
219 unsigned int i, j, count;
220
221 if (!cache) return NULL;
222 for (i = count = 0; i < cache->count && count < *size / sizeof(*ret); i++)
223 if (cache->state[i] == DIR_CACHE_STATE_RELEASED) count++;
224 if (!count) return NULL;
225
226 if ((ret = malloc( count * sizeof(*ret) )))
227 {
228 for (i = j = 0; j < count; i++)
229 {
230 if (cache->state[i] != DIR_CACHE_STATE_RELEASED) continue;
231 cache->state[i] = DIR_CACHE_STATE_FREE;
232 ret[j++] = i;
233 }
234 *size = count * sizeof(*ret);
235 }
236 return ret;
237 }
238
239 /* allocate a new client-side directory cache entry */
240 static int alloc_dir_cache_entry( struct dir *dir, struct process *process )
241 {
242 unsigned int i = 0;
243 struct dir_cache *cache = process->dir_cache;
244
245 if (cache)
246 for (i = 0; i < cache->count; i++)
247 if (cache->state[i] == DIR_CACHE_STATE_FREE) goto found;
248
249 if (!cache || cache->count == cache->size)
250 {
251 unsigned int size = cache ? cache->size * 2 : 256;
252 if (!(cache = realloc( cache, offsetof( struct dir_cache, state[size] ))))
253 {
254 set_error( STATUS_NO_MEMORY );
255 return -1;
256 }
257 process->dir_cache = cache;
258 cache->size = size;
259 }
260 cache->count = i + 1;
261
262 found:
263 cache->state[i] = DIR_CACHE_STATE_INUSE;
264 return i;
265 }
266
267 /* release a directory cache entry; it will be freed on the client side on the next cache request */
268 static void release_dir_cache_entry( struct dir *dir )
269 {
270 struct dir_cache *cache;
271
272 if (!dir->client_process) return;
273 cache = dir->client_process->dir_cache;
274 cache->state[dir->client_entry] = DIR_CACHE_STATE_RELEASED;
275 release_object( dir->client_process );
276 dir->client_process = NULL;
277 }
278
279 static void dnotify_adjust_changes( struct dir *dir )
280 {
281 #if defined(F_SETSIG) && defined(F_NOTIFY)
282 int fd = get_unix_fd( dir->fd );
283 unsigned int filter = dir->filter;
284 unsigned int val;
285 if ( 0 > fcntl( fd, F_SETSIG, SIGIO) )
286 return;
287
288 val = DN_MULTISHOT;
289 if (filter & FILE_NOTIFY_CHANGE_FILE_NAME)
290 val |= DN_RENAME | DN_DELETE | DN_CREATE;
291 if (filter & FILE_NOTIFY_CHANGE_DIR_NAME)
292 val |= DN_RENAME | DN_DELETE | DN_CREATE;
293 if (filter & FILE_NOTIFY_CHANGE_ATTRIBUTES)
294 val |= DN_ATTRIB;
295 if (filter & FILE_NOTIFY_CHANGE_SIZE)
296 val |= DN_MODIFY;
297 if (filter & FILE_NOTIFY_CHANGE_LAST_WRITE)
298 val |= DN_MODIFY;
299 if (filter & FILE_NOTIFY_CHANGE_LAST_ACCESS)
300 val |= DN_ACCESS;
301 if (filter & FILE_NOTIFY_CHANGE_CREATION)
302 val |= DN_CREATE;
303 if (filter & FILE_NOTIFY_CHANGE_SECURITY)
304 val |= DN_ATTRIB;
305 fcntl( fd, F_NOTIFY, val );
306 #endif
307 }
308
309 /* insert change in the global list */
310 static inline void insert_change( struct dir *dir )
311 {
312 sigset_t sigset;
313
314 sigemptyset( &sigset );
315 sigaddset( &sigset, SIGIO );
316 sigprocmask( SIG_BLOCK, &sigset, NULL );
317 list_add_head( &change_list, &dir->entry );
318 sigprocmask( SIG_UNBLOCK, &sigset, NULL );
319 }
320
321 /* remove change from the global list */
322 static inline void remove_change( struct dir *dir )
323 {
324 sigset_t sigset;
325
326 sigemptyset( &sigset );
327 sigaddset( &sigset, SIGIO );
328 sigprocmask( SIG_BLOCK, &sigset, NULL );
329 list_remove( &dir->entry );
330 sigprocmask( SIG_UNBLOCK, &sigset, NULL );
331 }
332
333 static void dir_dump( struct object *obj, int verbose )
334 {
335 struct dir *dir = (struct dir *)obj;
336 assert( obj->ops == &dir_ops );
337 fprintf( stderr, "Dirfile fd=%p filter=%08x\n", dir->fd, dir->filter );
338 }
339
340 static struct object_type *dir_get_type( struct object *obj )
341 {
342 static const WCHAR name[] = {'F','i','l','e'};
343 static const struct unicode_str str = { name, sizeof(name) };
344 return get_object_type( &str );
345 }
346
347 /* enter here directly from SIGIO signal handler */
348 void do_change_notify( int unix_fd )
349 {
350 struct dir *dir;
351
352 /* FIXME: this is O(n) ... probably can be improved */
353 LIST_FOR_EACH_ENTRY( dir, &change_list, struct dir, entry )
354 {
355 if (get_unix_fd( dir->fd ) != unix_fd) continue;
356 interlocked_xchg_add( &dir->notified, 1 );
357 break;
358 }
359 }
360
361 /* SIGIO callback, called synchronously with the poll loop */
362 void sigio_callback(void)
363 {
364 struct dir *dir;
365
366 LIST_FOR_EACH_ENTRY( dir, &change_list, struct dir, entry )
367 {
368 if (interlocked_xchg( &dir->notified, 0 ))
369 fd_async_wake_up( dir->fd, ASYNC_TYPE_WAIT, STATUS_ALERTED );
370 }
371 }
372
373 static struct fd *dir_get_fd( struct object *obj )
374 {
375 struct dir *dir = (struct dir *)obj;
376 assert( obj->ops == &dir_ops );
377 return (struct fd *)grab_object( dir->fd );
378 }
379
380 static int get_dir_unix_fd( struct dir *dir )
381 {
382 return get_unix_fd( dir->fd );
383 }
384
385 static struct security_descriptor *dir_get_sd( struct object *obj )
386 {
387 struct dir *dir = (struct dir *)obj;
388 int unix_fd;
389 struct stat st;
390 struct security_descriptor *sd;
391 assert( obj->ops == &dir_ops );
392
393 unix_fd = get_dir_unix_fd( dir );
394
395 if (unix_fd == -1 || fstat( unix_fd, &st ) == -1)
396 return obj->sd;
397
398 /* mode and uid the same? if so, no need to re-generate security descriptor */
399 if (obj->sd &&
400 (st.st_mode & (S_IRWXU|S_IRWXO)) == (dir->mode & (S_IRWXU|S_IRWXO)) &&
401 (st.st_uid == dir->uid))
402 return obj->sd;
403
404 sd = mode_to_sd( st.st_mode,
405 security_unix_uid_to_sid( st.st_uid ),
406 token_get_primary_group( current->process->token ));
407 if (!sd) return obj->sd;
408
409 dir->mode = st.st_mode;
410 dir->uid = st.st_uid;
411 free( obj->sd );
412 obj->sd = sd;
413 return sd;
414 }
415
416 static int dir_set_sd( struct object *obj, const struct security_descriptor *sd,
417 unsigned int set_info )
418 {
419 struct dir *dir = (struct dir *)obj;
420 const SID *owner;
421 struct stat st;
422 mode_t mode;
423 int unix_fd;
424
425 assert( obj->ops == &dir_ops );
426
427 unix_fd = get_dir_unix_fd( dir );
428
429 if (unix_fd == -1 || fstat( unix_fd, &st ) == -1) return 1;
430
431 if (set_info & OWNER_SECURITY_INFORMATION)
432 {
433 owner = sd_get_owner( sd );
434 if (!owner)
435 {
436 set_error( STATUS_INVALID_SECURITY_DESCR );
437 return 0;
438 }
439 if (!obj->sd || !security_equal_sid( owner, sd_get_owner( obj->sd ) ))
440 {
441 /* FIXME: get Unix uid and call fchown */
442 }
443 }
444 else if (obj->sd)
445 owner = sd_get_owner( obj->sd );
446 else
447 owner = token_get_user( current->process->token );
448
449 if (set_info & DACL_SECURITY_INFORMATION)
450 {
451 /* keep the bits that we don't map to access rights in the ACL */
452 mode = st.st_mode & (S_ISUID|S_ISGID|S_ISVTX);
453 mode |= sd_to_mode( sd, owner );
454
455 if (((st.st_mode ^ mode) & (S_IRWXU|S_IRWXG|S_IRWXO)) && fchmod( unix_fd, mode ) == -1)
456 {
457 file_set_error();
458 return 0;
459 }
460 }
461 return 1;
462 }
463
464 static struct change_record *get_first_change_record( struct dir *dir )
465 {
466 struct list *ptr = list_head( &dir->change_records );
467 if (!ptr) return NULL;
468 list_remove( ptr );
469 return LIST_ENTRY( ptr, struct change_record, entry );
470 }
471
472 static int dir_close_handle( struct object *obj, struct process *process, obj_handle_t handle )
473 {
474 struct dir *dir = (struct dir *)obj;
475
476 if (!fd_close_handle( obj, process, handle )) return 0;
477 if (obj->handle_count == 1) release_dir_cache_entry( dir ); /* closing last handle, release cache */
478 return 1; /* ok to close */
479 }
480
481 static void dir_destroy( struct object *obj )
482 {
483 struct change_record *record;
484 struct dir *dir = (struct dir *)obj;
485 assert (obj->ops == &dir_ops);
486
487 if (dir->filter)
488 remove_change( dir );
489
490 if (dir->inode)
491 {
492 list_remove( &dir->in_entry );
493 free_inode( dir->inode );
494 }
495
496 while ((record = get_first_change_record( dir ))) free( record );
497
498 release_dir_cache_entry( dir );
499 release_object( dir->fd );
500
501 if (inotify_fd && list_empty( &change_list ))
502 {
503 release_object( inotify_fd );
504 inotify_fd = NULL;
505 }
506 }
507
508 struct dir *get_dir_obj( struct process *process, obj_handle_t handle, unsigned int access )
509 {
510 return (struct dir *)get_handle_obj( process, handle, access, &dir_ops );
511 }
512
513 static int dir_get_poll_events( struct fd *fd )
514 {
515 return 0;
516 }
517
518 static enum server_fd_type dir_get_fd_type( struct fd *fd )
519 {
520 return FD_TYPE_DIR;
521 }
522
523 #ifdef USE_INOTIFY
524
525 #define HASH_SIZE 31
526
527 struct inode {
528 struct list ch_entry; /* entry in the children list */
529 struct list children; /* children of this inode */
530 struct inode *parent; /* parent of this inode */
531 struct list dirs; /* directory handles watching this inode */
532 struct list ino_entry; /* entry in the inode hash */
533 struct list wd_entry; /* entry in the watch descriptor hash */
534 dev_t dev; /* device number */
535 ino_t ino; /* device's inode number */
536 int wd; /* inotify's watch descriptor */
537 char *name; /* basename name of the inode */
538 };
539
540 static struct list inode_hash[ HASH_SIZE ];
541 static struct list wd_hash[ HASH_SIZE ];
542
543 static int inotify_add_dir( char *path, unsigned int filter );
544
545 static struct inode *inode_from_wd( int wd )
546 {
547 struct list *bucket = &wd_hash[ wd % HASH_SIZE ];
548 struct inode *inode;
549
550 LIST_FOR_EACH_ENTRY( inode, bucket, struct inode, wd_entry )
551 if (inode->wd == wd)
552 return inode;
553
554 return NULL;
555 }
556
557 static inline struct list *get_hash_list( dev_t dev, ino_t ino )
558 {
559 return &inode_hash[ (ino ^ dev) % HASH_SIZE ];
560 }
561
562 static struct inode *find_inode( dev_t dev, ino_t ino )
563 {
564 struct list *bucket = get_hash_list( dev, ino );
565 struct inode *inode;
566
567 LIST_FOR_EACH_ENTRY( inode, bucket, struct inode, ino_entry )
568 if (inode->ino == ino && inode->dev == dev)
569 return inode;
570
571 return NULL;
572 }
573
574 static struct inode *create_inode( dev_t dev, ino_t ino )
575 {
576 struct inode *inode;
577
578 inode = malloc( sizeof *inode );
579 if (inode)
580 {
581 list_init( &inode->children );
582 list_init( &inode->dirs );
583 inode->ino = ino;
584 inode->dev = dev;
585 inode->wd = -1;
586 inode->parent = NULL;
587 inode->name = NULL;
588 list_add_tail( get_hash_list( dev, ino ), &inode->ino_entry );
589 }
590 return inode;
591 }
592
593 static struct inode *get_inode( dev_t dev, ino_t ino )
594 {
595 struct inode *inode;
596
597 inode = find_inode( dev, ino );
598 if (inode)
599 return inode;
600 return create_inode( dev, ino );
601 }
602
603 static void inode_set_wd( struct inode *inode, int wd )
604 {
605 if (inode->wd != -1)
606 list_remove( &inode->wd_entry );
607 inode->wd = wd;
608 list_add_tail( &wd_hash[ wd % HASH_SIZE ], &inode->wd_entry );
609 }
610
611 static void inode_set_name( struct inode *inode, const char *name )
612 {
613 free (inode->name);
614 inode->name = name ? strdup( name ) : NULL;
615 }
616
617 static void free_inode( struct inode *inode )
618 {
619 int subtree = 0, watches = 0;
620 struct inode *tmp, *next;
621 struct dir *dir;
622
623 LIST_FOR_EACH_ENTRY( dir, &inode->dirs, struct dir, in_entry )
624 {
625 subtree |= dir->subtree;
626 watches++;
627 }
628
629 if (!subtree && !inode->parent)
630 {
631 LIST_FOR_EACH_ENTRY_SAFE( tmp, next, &inode->children,
632 struct inode, ch_entry )
633 {
634 assert( tmp != inode );
635 assert( tmp->parent == inode );
636 free_inode( tmp );
637 }
638 }
639
640 if (watches)
641 return;
642
643 if (inode->parent)
644 list_remove( &inode->ch_entry );
645
646 /* disconnect remaining children from the parent */
647 LIST_FOR_EACH_ENTRY_SAFE( tmp, next, &inode->children, struct inode, ch_entry )
648 {
649 list_remove( &tmp->ch_entry );
650 tmp->parent = NULL;
651 }
652
653 if (inode->wd != -1)
654 {
655 inotify_rm_watch( get_unix_fd( inotify_fd ), inode->wd );
656 list_remove( &inode->wd_entry );
657 }
658 list_remove( &inode->ino_entry );
659
660 free( inode->name );
661 free( inode );
662 }
663
664 static struct inode *inode_add( struct inode *parent,
665 dev_t dev, ino_t ino, const char *name )
666 {
667 struct inode *inode;
668
669 inode = get_inode( dev, ino );
670 if (!inode)
671 return NULL;
672
673 if (!inode->parent)
674 {
675 list_add_tail( &parent->children, &inode->ch_entry );
676 inode->parent = parent;
677 assert( inode != parent );
678 }
679 inode_set_name( inode, name );
680
681 return inode;
682 }
683
684 static struct inode *inode_from_name( struct inode *inode, const char *name )
685 {
686 struct inode *i;
687
688 LIST_FOR_EACH_ENTRY( i, &inode->children, struct inode, ch_entry )
689 if (i->name && !strcmp( i->name, name ))
690 return i;
691 return NULL;
692 }
693
694 static int inotify_get_poll_events( struct fd *fd );
695 static void inotify_poll_event( struct fd *fd, int event );
696
697 static const struct fd_ops inotify_fd_ops =
698 {
699 inotify_get_poll_events, /* get_poll_events */
700 inotify_poll_event, /* poll_event */
701 NULL, /* flush */
702 NULL, /* get_fd_type */
703 NULL, /* ioctl */
704 NULL, /* queue_async */
705 NULL /* reselect_async */
706 };
707
708 static int inotify_get_poll_events( struct fd *fd )
709 {
710 return POLLIN;
711 }
712
713 static void inotify_do_change_notify( struct dir *dir, unsigned int action,
714 unsigned int cookie, const char *relpath )
715 {
716 struct change_record *record;
717
718 assert( dir->obj.ops == &dir_ops );
719
720 if (dir->want_data)
721 {
722 size_t len = strlen(relpath);
723 record = malloc( offsetof(struct change_record, event.name[len]) );
724 if (!record)
725 return;
726
727 record->cookie = cookie;
728 record->event.action = action;
729 memcpy( record->event.name, relpath, len );
730 record->event.len = len;
731
732 list_add_tail( &dir->change_records, &record->entry );
733 }
734
735 fd_async_wake_up( dir->fd, ASYNC_TYPE_WAIT, STATUS_ALERTED );
736 }
737
738 static unsigned int filter_from_event( struct inotify_event *ie )
739 {
740 unsigned int filter = 0;
741
742 if (ie->mask & (IN_MOVED_FROM | IN_MOVED_TO | IN_DELETE | IN_CREATE))
743 filter |= FILE_NOTIFY_CHANGE_FILE_NAME | FILE_NOTIFY_CHANGE_DIR_NAME;
744 if (ie->mask & IN_MODIFY)
745 filter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE | FILE_NOTIFY_CHANGE_LAST_ACCESS;
746 if (ie->mask & IN_ATTRIB)
747 filter |= FILE_NOTIFY_CHANGE_ATTRIBUTES | FILE_NOTIFY_CHANGE_SECURITY;
748 if (ie->mask & IN_CREATE)
749 filter |= FILE_NOTIFY_CHANGE_CREATION;
750
751 if (ie->mask & IN_ISDIR)
752 filter &= ~FILE_NOTIFY_CHANGE_FILE_NAME;
753 else
754 filter &= ~FILE_NOTIFY_CHANGE_DIR_NAME;
755
756 return filter;
757 }
758
759 /* scan up the parent directories for watches */
760 static unsigned int filter_from_inode( struct inode *inode, int is_parent )
761 {
762 unsigned int filter = 0;
763 struct dir *dir;
764
765 /* combine filters from parents watching subtrees */
766 while (inode)
767 {
768 LIST_FOR_EACH_ENTRY( dir, &inode->dirs, struct dir, in_entry )
769 if (dir->subtree || !is_parent)
770 filter |= dir->filter;
771 is_parent = 1;
772 inode = inode->parent;
773 }
774
775 return filter;
776 }
777
778 static char *inode_get_path( struct inode *inode, int sz )
779 {
780 struct list *head;
781 char *path;
782 int len;
783
784 if (!inode)
785 return NULL;
786
787 head = list_head( &inode->dirs );
788 if (head)
789 {
790 int unix_fd = get_unix_fd( LIST_ENTRY( head, struct dir, in_entry )->fd );
791 path = malloc ( 32 + sz );
792 if (path)
793 sprintf( path, "/proc/self/fd/%u/", unix_fd );
794 return path;
795 }
796
797 if (!inode->name)
798 return NULL;
799
800 len = strlen( inode->name );
801 path = inode_get_path( inode->parent, sz + len + 1 );
802 if (!path)
803 return NULL;
804
805 strcat( path, inode->name );
806 strcat( path, "/" );
807
808 return path;
809 }
810
811 static void inode_check_dir( struct inode *parent, const char *name )
812 {
813 char *path;
814 unsigned int filter;
815 struct inode *inode;
816 struct stat st;
817 int wd = -1;
818
819 path = inode_get_path( parent, strlen(name) );
820 if (!path)
821 return;
822
823 strcat( path, name );
824
825 if (stat( path, &st ) < 0)
826 goto end;
827
828 filter = filter_from_inode( parent, 1 );
829 if (!filter)
830 goto end;
831
832 inode = inode_add( parent, st.st_dev, st.st_ino, name );
833 if (!inode || inode->wd != -1)
834 goto end;
835
836 wd = inotify_add_dir( path, filter );
837 if (wd != -1)
838 inode_set_wd( inode, wd );
839 else
840 free_inode( inode );
841
842 end:
843 free( path );
844 }
845
846 static int prepend( char **path, const char *segment )
847 {
848 int extra;
849 char *p;
850
851 extra = strlen( segment ) + 1;
852 if (*path)
853 {
854 int len = strlen( *path ) + 1;
855 p = realloc( *path, len + extra );
856 if (!p) return 0;
857 memmove( &p[ extra ], p, len );
858 p[ extra - 1 ] = '/';
859 memcpy( p, segment, extra - 1 );
860 }
861 else
862 {
863 p = malloc( extra );
864 if (!p) return 0;
865 memcpy( p, segment, extra );
866 }
867
868 *path = p;
869
870 return 1;
871 }
872
873 static void inotify_notify_all( struct inotify_event *ie )
874 {
875 unsigned int filter, action;
876 struct inode *inode, *i;
877 char *path = NULL;
878 struct dir *dir;
879
880 inode = inode_from_wd( ie->wd );
881 if (!inode)
882 {
883 fprintf( stderr, "no inode matches %d\n", ie->wd);
884 return;
885 }
886
887 filter = filter_from_event( ie );
888
889 if (ie->mask & IN_CREATE)
890 {
891 if (ie->mask & IN_ISDIR)
892 inode_check_dir( inode, ie->name );
893
894 action = FILE_ACTION_ADDED;
895 }
896 else if (ie->mask & IN_DELETE)
897 action = FILE_ACTION_REMOVED;
898 else if (ie->mask & IN_MOVED_FROM)
899 action = FILE_ACTION_RENAMED_OLD_NAME;
900 else if (ie->mask & IN_MOVED_TO)
901 action = FILE_ACTION_RENAMED_NEW_NAME;
902 else
903 action = FILE_ACTION_MODIFIED;
904
905 /*
906 * Work our way up the inode hierarchy
907 * extending the relative path as we go
908 * and notifying all recursive watches.
909 */
910 if (!prepend( &path, ie->name ))
911 return;
912
913 for (i = inode; i; i = i->parent)
914 {
915 LIST_FOR_EACH_ENTRY( dir, &i->dirs, struct dir, in_entry )
916 if ((filter & dir->filter) && (i==inode || dir->subtree))
917 inotify_do_change_notify( dir, action, ie->cookie, path );
918
919 if (!i->name || !prepend( &path, i->name ))
920 break;
921 }
922
923 free( path );
924
925 if (ie->mask & IN_DELETE)
926 {
927 i = inode_from_name( inode, ie->name );
928 if (i)
929 free_inode( i );
930 }
931 }
932
933 static void inotify_poll_event( struct fd *fd, int event )
934 {
935 int r, ofs, unix_fd;
936 char buffer[0x1000];
937 struct inotify_event *ie;
938
939 unix_fd = get_unix_fd( fd );
940 r = read( unix_fd, buffer, sizeof buffer );
941 if (r < 0)
942 {
943 fprintf(stderr,"inotify_poll_event(): inotify read failed!\n");
944 return;
945 }
946
947 for( ofs = 0; ofs < r - offsetof(struct inotify_event, name); )
948 {
949 ie = (struct inotify_event*) &buffer[ofs];
950 ofs += offsetof( struct inotify_event, name[ie->len] );
951 if (ofs > r) break;
952 if (ie->len) inotify_notify_all( ie );
953 }
954 }
955
956 static inline struct fd *create_inotify_fd( void )
957 {
958 int unix_fd;
959
960 unix_fd = inotify_init();
961 if (unix_fd<0)
962 return NULL;
963 return create_anonymous_fd( &inotify_fd_ops, unix_fd, NULL, 0 );
964 }
965
966 static int map_flags( unsigned int filter )
967 {
968 unsigned int mask;
969
970 /* always watch these so we can track subdirectories in recursive watches */
971 mask = (IN_MOVED_FROM | IN_MOVED_TO | IN_DELETE | IN_CREATE | IN_DELETE_SELF);
972
973 if (filter & FILE_NOTIFY_CHANGE_ATTRIBUTES)
974 mask |= IN_ATTRIB;
975 if (filter & FILE_NOTIFY_CHANGE_SIZE)
976 mask |= IN_MODIFY;
977 if (filter & FILE_NOTIFY_CHANGE_LAST_WRITE)
978 mask |= IN_MODIFY;
979 if (filter & FILE_NOTIFY_CHANGE_LAST_ACCESS)
980 mask |= IN_MODIFY;
981 if (filter & FILE_NOTIFY_CHANGE_SECURITY)
982 mask |= IN_ATTRIB;
983
984 return mask;
985 }
986
987 static int inotify_add_dir( char *path, unsigned int filter )
988 {
989 int wd = inotify_add_watch( get_unix_fd( inotify_fd ),
990 path, map_flags( filter ) );
991 if (wd != -1)
992 set_fd_events( inotify_fd, POLLIN );
993 return wd;
994 }
995
996 static int init_inotify( void )
997 {
998 int i;
999
1000 if (inotify_fd)
1001 return 1;
1002
1003 inotify_fd = create_inotify_fd();
1004 if (!inotify_fd)
1005 return 0;
1006
1007 for (i=0; i<HASH_SIZE; i++)
1008 {
1009 list_init( &inode_hash[i] );
1010 list_init( &wd_hash[i] );
1011 }
1012
1013 return 1;
1014 }
1015
1016 static int inotify_adjust_changes( struct dir *dir )
1017 {
1018 unsigned int filter;
1019 struct inode *inode;
1020 struct stat st;
1021 char path[32];
1022 int wd, unix_fd;
1023
1024 if (!inotify_fd)
1025 return 0;
1026
1027 unix_fd = get_unix_fd( dir->fd );
1028
1029 inode = dir->inode;
1030 if (!inode)
1031 {
1032 /* check if this fd is already being watched */
1033 if (-1 == fstat( unix_fd, &st ))
1034 return 0;
1035
1036 inode = get_inode( st.st_dev, st.st_ino );
1037 if (!inode)
1038 inode = create_inode( st.st_dev, st.st_ino );
1039 if (!inode)
1040 return 0;
1041 list_add_tail( &inode->dirs, &dir->in_entry );
1042 dir->inode = inode;
1043 }
1044
1045 filter = filter_from_inode( inode, 0 );
1046
1047 sprintf( path, "/proc/self/fd/%u", unix_fd );
1048 wd = inotify_add_dir( path, filter );
1049 if (wd == -1) return 0;
1050
1051 inode_set_wd( inode, wd );
1052
1053 return 1;
1054 }
1055
1056 static char *get_basename( const char *link )
1057 {
1058 char *buffer, *name = NULL;
1059 int r, n = 0x100;
1060
1061 while (1)
1062 {
1063 buffer = malloc( n );
1064 if (!buffer) return NULL;
1065
1066 r = readlink( link, buffer, n );
1067 if (r < 0)
1068 break;
1069
1070 if (r < n)
1071 {
1072 name = buffer;
1073 break;
1074 }
1075 free( buffer );
1076 n *= 2;
1077 }
1078
1079 if (name)
1080 {
1081 while (r > 0 && name[ r - 1 ] == '/' )
1082 r--;
1083 name[ r ] = 0;
1084
1085 name = strrchr( name, '/' );
1086 if (name)
1087 name = strdup( &name[1] );
1088 }
1089
1090 free( buffer );
1091 return name;
1092 }
1093
1094 static int dir_add_to_existing_notify( struct dir *dir )
1095 {
1096 struct inode *inode, *parent;
1097 unsigned int filter = 0;
1098 struct stat st, st_new;
1099 char link[35], *name;
1100 int wd, unix_fd;
1101
1102 if (!inotify_fd)
1103 return 0;
1104
1105 unix_fd = get_unix_fd( dir->fd );
1106
1107 /* check if it's in the list of inodes we want to watch */
1108 if (-1 == fstat( unix_fd, &st_new ))
1109 return 0;
1110 inode = find_inode( st_new.st_dev, st_new.st_ino );
1111 if (inode)
1112 return 0;
1113
1114 /* lookup the parent */
1115 sprintf( link, "/proc/self/fd/%u/..", unix_fd );
1116 if (-1 == stat( link, &st ))
1117 return 0;
1118
1119 /*
1120 * If there's no parent, stop. We could keep going adding
1121 * ../ to the path until we hit the root of the tree or
1122 * find a recursively watched ancestor.
1123 * Assume it's too expensive to search up the tree for now.
1124 */
1125 parent = find_inode( st.st_dev, st.st_ino );
1126 if (!parent)
1127 return 0;
1128
1129 if (parent->wd == -1)
1130 return 0;
1131
1132 filter = filter_from_inode( parent, 1 );
1133 if (!filter)
1134 return 0;
1135
1136 sprintf( link, "/proc/self/fd/%u", unix_fd );
1137 name = get_basename( link );
1138 if (!name)
1139 return 0;
1140 inode = inode_add( parent, st_new.st_dev, st_new.st_ino, name );
1141 free( name );
1142 if (!inode)
1143 return 0;
1144
1145 /* Couldn't find this inode at the start of the function, must be new */
1146 assert( inode->wd == -1 );
1147
1148 wd = inotify_add_dir( link, filter );
1149 if (wd != -1)
1150 inode_set_wd( inode, wd );
1151
1152 return 1;
1153 }
1154
1155 #else
1156
1157 static int init_inotify( void )
1158 {
1159 return 0;
1160 }
1161
1162 static int inotify_adjust_changes( struct dir *dir )
1163 {
1164 return 0;
1165 }
1166
1167 static void free_inode( struct inode *inode )
1168 {
1169 assert( 0 );
1170 }
1171
1172 static int dir_add_to_existing_notify( struct dir *dir )
1173 {
1174 return 0;
1175 }
1176
1177 #endif /* USE_INOTIFY */
1178
1179 struct object *create_dir_obj( struct fd *fd, unsigned int access, mode_t mode )
1180 {
1181 struct dir *dir;
1182
1183 dir = alloc_object( &dir_ops );
1184 if (!dir)
1185 return NULL;
1186
1187 list_init( &dir->change_records );
1188 dir->filter = 0;
1189 dir->notified = 0;
1190 dir->want_data = 0;
1191 dir->inode = NULL;
1192 grab_object( fd );
1193 dir->fd = fd;
1194 dir->mode = mode;
1195 dir->uid = ~(uid_t)0;
1196 dir->client_process = NULL;
1197 set_fd_user( fd, &dir_fd_ops, &dir->obj );
1198
1199 dir_add_to_existing_notify( dir );
1200
1201 return &dir->obj;
1202 }
1203
1204 /* retrieve (or allocate) the client-side directory cache entry */
1205 DECL_HANDLER(get_directory_cache_entry)
1206 {
1207 struct dir *dir;
1208 int *free_entries;
1209 data_size_t free_size;
1210
1211 if (!(dir = get_dir_obj( current->process, req->handle, 0 ))) return;
1212
1213 if (!dir->client_process)
1214 {
1215 if ((dir->client_entry = alloc_dir_cache_entry( dir, current->process )) == -1) goto done;
1216 dir->client_process = (struct process *)grab_object( current->process );
1217 }
1218
1219 if (dir->client_process == current->process) reply->entry = dir->client_entry;
1220 else set_error( STATUS_SHARING_VIOLATION );
1221
1222 done: /* allow freeing entries even on failure */
1223 free_size = get_reply_max_size();
1224 free_entries = get_free_dir_cache_entries( current->process, &free_size );
1225 if (free_entries) set_reply_data_ptr( free_entries, free_size );
1226
1227 release_object( dir );
1228 }
1229
1230 /* enable change notifications for a directory */
1231 DECL_HANDLER(read_directory_changes)
1232 {
1233 struct dir *dir;
1234 struct async *async;
1235
1236 if (!req->filter)
1237 {
1238 set_error(STATUS_INVALID_PARAMETER);
1239 return;
1240 }
1241
1242 dir = get_dir_obj( current->process, req->async.handle, 0 );
1243 if (!dir)
1244 return;
1245
1246 /* requests don't timeout */
1247 if (!(async = create_async( dir->fd, current, &req->async, NULL ))) goto end;
1248 fd_queue_async( dir->fd, async, ASYNC_TYPE_WAIT );
1249
1250 /* assign it once */
1251 if (!dir->filter)
1252 {
1253 init_inotify();
1254 insert_change( dir );
1255 dir->filter = req->filter;
1256 dir->subtree = req->subtree;
1257 dir->want_data = req->want_data;
1258 }
1259
1260 /* if there's already a change in the queue, send it */
1261 if (!list_empty( &dir->change_records ))
1262 fd_async_wake_up( dir->fd, ASYNC_TYPE_WAIT, STATUS_ALERTED );
1263
1264 /* setup the real notification */
1265 if (!inotify_adjust_changes( dir ))
1266 dnotify_adjust_changes( dir );
1267
1268 set_error(STATUS_PENDING);
1269
1270 release_object( async );
1271 end:
1272 release_object( dir );
1273 }
1274
1275 DECL_HANDLER(read_change)
1276 {
1277 struct change_record *record, *next;
1278 struct dir *dir;
1279 struct list events;
1280 char *data, *event;
1281 int size = 0;
1282
1283 dir = get_dir_obj( current->process, req->handle, 0 );
1284 if (!dir)
1285 return;
1286
1287 list_init( &events );
1288 list_move_tail( &events, &dir->change_records );
1289 release_object( dir );
1290
1291 if (list_empty( &events ))
1292 {
1293 set_error( STATUS_NO_DATA_DETECTED );
1294 return;
1295 }
1296
1297 LIST_FOR_EACH_ENTRY( record, &events, struct change_record, entry )
1298 {
1299 size += (offsetof(struct filesystem_event, name[record->event.len])
1300 + sizeof(int)-1) / sizeof(int) * sizeof(int);
1301 }
1302
1303 if (size > get_reply_max_size())
1304 set_error( STATUS_BUFFER_TOO_SMALL );
1305 else if ((data = mem_alloc( size )) != NULL)
1306 {
1307 event = data;
1308 LIST_FOR_EACH_ENTRY( record, &events, struct change_record, entry )
1309 {
1310 data_size_t len = offsetof( struct filesystem_event, name[record->event.len] );
1311
1312 /* FIXME: rename events are sometimes reported as delete/create */
1313 if (record->event.action == FILE_ACTION_RENAMED_OLD_NAME)
1314 {
1315 struct list *elem = list_next( &events, &record->entry );
1316 if (elem)
1317 next = LIST_ENTRY(elem, struct change_record, entry);
1318
1319 if (elem && next->cookie == record->cookie)
1320 next->cookie = 0;
1321 else
1322 record->event.action = FILE_ACTION_REMOVED;
1323 }
1324 else if (record->event.action == FILE_ACTION_RENAMED_NEW_NAME && record->cookie)
1325 record->event.action = FILE_ACTION_ADDED;
1326
1327 memcpy( event, &record->event, len );
1328 event += len;
1329 if (len % sizeof(int))
1330 {
1331 memset( event, 0, sizeof(int) - len % sizeof(int) );
1332 event += sizeof(int) - len % sizeof(int);
1333 }
1334 }
1335 set_reply_data_ptr( data, size );
1336 }
1337
1338 LIST_FOR_EACH_ENTRY_SAFE( record, next, &events, struct change_record, entry )
1339 {
1340 list_remove( &record->entry );
1341 free( record );
1342 }
1343 }
Windows API implementation