server/event.c

   1 /*
   2  * Server-side event 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 #include "server/thread.h"
  14
  15 struct event
  16 {
  17     struct object  obj;             /* object header */
  18     int            manual_reset;    /* is it a manual reset event? */
  19     int            signaled;        /* event has been signaled */
  20 };
  21
  22 static void event_dump( struct object *obj, int verbose );
  23 static int event_signaled( struct object *obj, struct thread *thread );
  24 static int event_satisfied( struct object *obj, struct thread *thread );
  25 static void event_destroy( struct object *obj );
  26
  27 static const struct object_ops event_ops =
  28 {
  29     event_dump,
  30     add_queue,
  31     remove_queue,
  32     event_signaled,
  33     event_satisfied,
  34     event_destroy
  35 };
  36
  37
  38 struct object *create_event( const char *name, int manual_reset, int initial_state )
  39 {
  40     struct event *event;
  41
  42     if (!(event = (struct event *)create_named_object( name, &event_ops, sizeof(*event) )))
  43         return NULL;
  44     if (GET_ERROR() != ERROR_ALREADY_EXISTS)
  45     {
  46         /* initialize it if it didn't already exist */
  47         event->manual_reset = manual_reset;
  48         event->signaled     = initial_state;
  49     }
  50     return &event->obj;
  51 }
  52
  53 int open_event( unsigned int access, int inherit, const char *name )
  54 {
  55     return open_object( name, &event_ops, access, inherit );
  56 }
  57
  58 int pulse_event( int handle )
  59 {
  60     struct event *event;
  61
  62     if (!(event = (struct event *)get_handle_obj( current->process, handle,
  63                                                   EVENT_MODIFY_STATE, &event_ops )))
  64         return 0;
  65     event->signaled = 1;
  66     /* wake up all waiters if manual reset, a single one otherwise */
  67     wake_up( &event->obj, !event->manual_reset );
  68     event->signaled = 0;
  69     release_object( event );
  70     return 1;
  71 }
  72
  73 int set_event( int handle )
  74 {
  75     struct event *event;
  76
  77     if (!(event = (struct event *)get_handle_obj( current->process, handle,
  78                                                   EVENT_MODIFY_STATE, &event_ops )))
  79         return 0;
  80     event->signaled = 1;
  81     /* wake up all waiters if manual reset, a single one otherwise */
  82     wake_up( &event->obj, !event->manual_reset );
  83     release_object( event );
  84     return 1;
  85 }
  86
  87 int reset_event( int handle )
  88 {
  89     struct event *event;
  90
  91     if (!(event = (struct event *)get_handle_obj( current->process, handle,
  92                                                   EVENT_MODIFY_STATE, &event_ops )))
  93         return 0;
  94     event->signaled = 0;
  95     release_object( event );
  96     return 1;
  97 }
  98
  99 static void event_dump( struct object *obj, int verbose )
 100 {
 101     struct event *event = (struct event *)obj;
 102     assert( obj->ops == &event_ops );
 103     printf( "Event manual=%d signaled=%d\n", event->manual_reset, event->signaled );
 104 }
 105
 106 static int event_signaled( struct object *obj, struct thread *thread )
 107 {
 108     struct event *event = (struct event *)obj;
 109     assert( obj->ops == &event_ops );
 110     return event->signaled;
 111 }
 112
 113 static int event_satisfied( struct object *obj, struct thread *thread )
 114 {
 115     struct event *event = (struct event *)obj;
 116     assert( obj->ops == &event_ops );
 117     /* Reset if it's an auto-reset event */
 118     if (!event->manual_reset) event->signaled = 0;
 119     return 0;  /* Not abandoned */
 120 }
 121
 122 static void event_destroy( struct object *obj )
 123 {
 124     struct event *event = (struct event *)obj;
 125     assert( obj->ops == &event_ops );
 126     free( event );
 127 }