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 "winnt.h"
  12
  13 #include "handle.h"
  14 #include "thread.h"
  15 #include "request.h"
  16
  17 struct change
  18 {
  19     struct object  obj;      /* object header */
  20     int            subtree;  /* watch all the subtree */
  21     int            filter;   /* notification filter */
  22 };
  23
  24 static void change_dump( struct object *obj, int verbose );
  25 static int change_signaled( struct object *obj, struct thread *thread );
  26
  27 static const struct object_ops change_ops =
  28 {
  29     sizeof(struct change),    /* size */
  30     change_dump,              /* dump */
  31     add_queue,                /* add_queue */
  32     remove_queue,             /* remove_queue */
  33     change_signaled,          /* signaled */
  34     no_satisfied,             /* satisfied */
  35     NULL,                     /* get_poll_events */
  36     NULL,                     /* poll_event */
  37     no_get_fd,                /* get_fd */
  38     no_flush,                 /* flush */
  39     no_get_file_info,         /* get_file_info */
  40     no_destroy                /* 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, -1 )))
  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 = 0;
  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 }