server/change.c

   1 /*
   2  * Server-side change notification management
   3  *
   4  * Copyright (C) 1998 Alexandre Julliard
   5  */
   6
   7 #include <assert.h>
   8 #include <stdio.h>
   9 #include <stdlib.h>
  10
  11 #include "winerror.h"
  12 #include "winnt.h"
  13
  14 #include "handle.h"
  15 #include "thread.h"
  16 #include "request.h"
  17
  18 struct change
  19 {
  20     struct object  obj;      /* object header */
  21     int            subtree;  /* watch all the subtree */
  22     int            filter;   /* notification filter */
  23 };
  24
  25 static void change_dump( struct object *obj, int verbose );
  26 static int change_signaled( struct object *obj, struct thread *thread );
  27
  28 static const struct object_ops change_ops =
  29 {
  30     sizeof(struct change),
  31     change_dump,
  32     add_queue,
  33     remove_queue,
  34     change_signaled,
  35     no_satisfied,
  36     no_read_fd,
  37     no_write_fd,
  38     no_flush,
  39     no_get_file_info,
  40     no_destroy
  41 };
  42
  43
  44 static struct change *create_change_notification( int subtree, int filter )
  45 {
  46     struct change *change;
  47     if ((change = alloc_object( &change_ops )))
  48     {
  49         change->subtree = subtree;
  50         change->filter  = filter;
  51     }
  52     return change;
  53 }
  54
  55 static void change_dump( struct object *obj, int verbose )
  56 {
  57     struct change *change = (struct change *)obj;
  58     assert( obj->ops == &change_ops );
  59     fprintf( stderr, "Change notification sub=%d filter=%08x\n",
  60              change->subtree, change->filter );
  61 }
  62
  63 static int change_signaled( struct object *obj, struct thread *thread )
  64 {
  65 /*    struct change *change = (struct change *)obj;*/
  66     assert( obj->ops == &change_ops );
  67     return 0;  /* never signaled for now */
  68 }
  69
  70 /* create a change notification */
  71 DECL_HANDLER(create_change_notification)
  72 {
  73     struct change *change;
  74
  75     req->handle = -1;
  76     if ((change = create_change_notification( req->subtree, req->filter )))
  77     {
  78         req->handle = alloc_handle( current->process, change,
  79                                     STANDARD_RIGHTS_REQUIRED|SYNCHRONIZE, 0 );
  80         release_object( change );
  81     }
  82 }