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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
22 #include "wine/port.h"
30 #define WIN32_NO_STATUS
40 struct object obj
; /* object header */
41 int manual_reset
; /* is it a manual reset event? */
42 int signaled
; /* event has been signaled */
45 static void event_dump( struct object
*obj
, int verbose
);
46 static int event_signaled( struct object
*obj
, struct thread
*thread
);
47 static int event_satisfied( struct object
*obj
, struct thread
*thread
);
48 static unsigned int event_map_access( struct object
*obj
, unsigned int access
);
49 static int event_signal( struct object
*obj
, unsigned int access
);
51 static const struct object_ops event_ops
=
53 sizeof(struct event
), /* size */
54 event_dump
, /* dump */
55 add_queue
, /* add_queue */
56 remove_queue
, /* remove_queue */
57 event_signaled
, /* signaled */
58 event_satisfied
, /* satisfied */
59 event_signal
, /* signal */
60 no_get_fd
, /* get_fd */
61 event_map_access
, /* map_access */
62 default_get_sd
, /* get_sd */
63 default_set_sd
, /* set_sd */
64 no_lookup_name
, /* lookup_name */
65 no_open_file
, /* open_file */
66 no_close_handle
, /* close_handle */
67 no_destroy
/* destroy */
71 struct event
*create_event( struct directory
*root
, const struct unicode_str
*name
,
72 unsigned int attr
, int manual_reset
, int initial_state
)
76 if ((event
= create_named_object_dir( root
, name
, attr
, &event_ops
)))
78 if (get_error() != STATUS_OBJECT_NAME_EXISTS
)
80 /* initialize it if it didn't already exist */
81 event
->manual_reset
= manual_reset
;
82 event
->signaled
= initial_state
;
88 struct event
*get_event_obj( struct process
*process
, obj_handle_t handle
, unsigned int access
)
90 return (struct event
*)get_handle_obj( process
, handle
, access
, &event_ops
);
93 void pulse_event( struct event
*event
)
96 /* wake up all waiters if manual reset, a single one otherwise */
97 wake_up( &event
->obj
, !event
->manual_reset
);
101 void set_event( struct event
*event
)
104 /* wake up all waiters if manual reset, a single one otherwise */
105 wake_up( &event
->obj
, !event
->manual_reset
);
108 void reset_event( struct event
*event
)
113 static void event_dump( struct object
*obj
, int verbose
)
115 struct event
*event
= (struct event
*)obj
;
116 assert( obj
->ops
== &event_ops
);
117 fprintf( stderr
, "Event manual=%d signaled=%d ",
118 event
->manual_reset
, event
->signaled
);
119 dump_object_name( &event
->obj
);
120 fputc( '\n', stderr
);
123 static int event_signaled( struct object
*obj
, struct thread
*thread
)
125 struct event
*event
= (struct event
*)obj
;
126 assert( obj
->ops
== &event_ops
);
127 return event
->signaled
;
130 static int event_satisfied( struct object
*obj
, struct thread
*thread
)
132 struct event
*event
= (struct event
*)obj
;
133 assert( obj
->ops
== &event_ops
);
134 /* Reset if it's an auto-reset event */
135 if (!event
->manual_reset
) event
->signaled
= 0;
136 return 0; /* Not abandoned */
139 static unsigned int event_map_access( struct object
*obj
, unsigned int access
)
141 if (access
& GENERIC_READ
) access
|= STANDARD_RIGHTS_READ
| SYNCHRONIZE
| EVENT_QUERY_STATE
;
142 if (access
& GENERIC_WRITE
) access
|= STANDARD_RIGHTS_WRITE
;
143 if (access
& GENERIC_EXECUTE
) access
|= STANDARD_RIGHTS_EXECUTE
;
144 if (access
& GENERIC_ALL
) access
|= STANDARD_RIGHTS_ALL
| EVENT_ALL_ACCESS
;
145 return access
& ~(GENERIC_READ
| GENERIC_WRITE
| GENERIC_EXECUTE
| GENERIC_ALL
);
148 static int event_signal( struct object
*obj
, unsigned int access
)
150 struct event
*event
= (struct event
*)obj
;
151 assert( obj
->ops
== &event_ops
);
153 if (!(access
& EVENT_MODIFY_STATE
))
155 set_error( STATUS_ACCESS_DENIED
);
162 /* create an event */
163 DECL_HANDLER(create_event
)
166 struct unicode_str name
;
167 struct directory
*root
= NULL
;
170 get_req_unicode_str( &name
);
171 if (req
->rootdir
&& !(root
= get_directory_obj( current
->process
, req
->rootdir
, 0 )))
174 if ((event
= create_event( root
, &name
, req
->attributes
, req
->manual_reset
, req
->initial_state
)))
176 reply
->handle
= alloc_handle( current
->process
, event
, req
->access
, req
->attributes
);
177 release_object( event
);
180 if (root
) release_object( root
);
183 /* open a handle to an event */
184 DECL_HANDLER(open_event
)
186 struct unicode_str name
;
187 struct directory
*root
= NULL
;
190 get_req_unicode_str( &name
);
191 if (req
->rootdir
&& !(root
= get_directory_obj( current
->process
, req
->rootdir
, 0 )))
194 if ((event
= open_object_dir( root
, &name
, req
->attributes
, &event_ops
)))
196 reply
->handle
= alloc_handle( current
->process
, &event
->obj
, req
->access
, req
->attributes
);
197 release_object( event
);
200 if (root
) release_object( root
);
203 /* do an event operation */
204 DECL_HANDLER(event_op
)
208 if (!(event
= get_event_obj( current
->process
, req
->handle
, EVENT_MODIFY_STATE
))) return;
212 pulse_event( event
);
218 reset_event( event
);
221 set_error( STATUS_INVALID_PARAMETER
);
224 release_object( event
);