2 * Server-side event management
4 * Copyright (C) 1998 Alexandre Julliard
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
33 struct object obj; /* object header */
34 int manual_reset; /* is it a manual reset event? */
35 int signaled; /* event has been signaled */
38 static void event_dump( struct object *obj, int verbose );
39 static int event_signaled( struct object *obj, struct thread *thread );
40 static int event_satisfied( struct object *obj, struct thread *thread );
42 static const struct object_ops event_ops =
44 sizeof(struct event), /* size */
45 event_dump, /* dump */
46 add_queue, /* add_queue */
47 remove_queue, /* remove_queue */
48 event_signaled, /* signaled */
49 event_satisfied, /* satisfied */
50 NULL, /* get_poll_events */
51 NULL, /* poll_event */
52 no_get_fd, /* get_fd */
54 no_get_file_info, /* get_file_info */
55 NULL, /* queue_async */
56 no_destroy /* destroy */
60 struct event *create_event( const WCHAR *name, size_t len,
61 int manual_reset, int initial_state )
65 if ((event = create_named_object( &event_ops, name, len )))
67 if (get_error() != STATUS_OBJECT_NAME_COLLISION)
69 /* initialize it if it didn't already exist */
70 event->manual_reset = manual_reset;
71 event->signaled = initial_state;
77 struct event *get_event_obj( struct process *process, handle_t handle, unsigned int access )
79 return (struct event *)get_handle_obj( process, handle, access, &event_ops );
82 void pulse_event( struct event *event )
85 /* wake up all waiters if manual reset, a single one otherwise */
86 wake_up( &event->obj, !event->manual_reset );
90 void set_event( struct event *event )
93 /* wake up all waiters if manual reset, a single one otherwise */
94 wake_up( &event->obj, !event->manual_reset );
97 void reset_event( struct event *event )
102 static void event_dump( struct object *obj, int verbose )
104 struct event *event = (struct event *)obj;
105 assert( obj->ops == &event_ops );
106 fprintf( stderr, "Event manual=%d signaled=%d ",
107 event->manual_reset, event->signaled );
108 dump_object_name( &event->obj );
109 fputc( '\n', stderr );
112 static int event_signaled( struct object *obj, struct thread *thread )
114 struct event *event = (struct event *)obj;
115 assert( obj->ops == &event_ops );
116 return event->signaled;
119 static int event_satisfied( struct object *obj, struct thread *thread )
121 struct event *event = (struct event *)obj;
122 assert( obj->ops == &event_ops );
123 /* Reset if it's an auto-reset event */
124 if (!event->manual_reset) event->signaled = 0;
125 return 0; /* Not abandoned */
128 /* create an event */
129 DECL_HANDLER(create_event)
134 if ((event = create_event( get_req_data(), get_req_data_size(),
135 req->manual_reset, req->initial_state )))
137 reply->handle = alloc_handle( current->process, event, EVENT_ALL_ACCESS, req->inherit );
138 release_object( event );
142 /* open a handle to an event */
143 DECL_HANDLER(open_event)
145 reply->handle = open_object( get_req_data(), get_req_data_size(),
146 &event_ops, req->access, req->inherit );
149 /* do an event operation */
150 DECL_HANDLER(event_op)
154 if (!(event = get_event_obj( current->process, req->handle, EVENT_MODIFY_STATE ))) return;
158 pulse_event( event );
164 reset_event( event );
167 fatal_protocol_error( current, "event_op: invalid operation %d\n", req->op );
169 release_object( event );