]>
git.proxmox.com Git - mirror_qemu.git/blob - iohandler.c
2 * QEMU System Emulator - managing I/O handler
4 * Copyright (c) 2003-2008 Fabrice Bellard
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
25 #include "config-host.h"
26 #include "qemu-common.h"
27 #include "qemu/queue.h"
28 #include "block/aio.h"
29 #include "qemu/main-loop.h"
35 typedef struct IOHandlerRecord
{
36 IOCanReadHandler
*fd_read_poll
;
40 QLIST_ENTRY(IOHandlerRecord
) next
;
46 static QLIST_HEAD(, IOHandlerRecord
) io_handlers
=
47 QLIST_HEAD_INITIALIZER(io_handlers
);
50 /* XXX: fd_read_poll should be suppressed, but an API change is
51 necessary in the character devices to suppress fd_can_read(). */
52 int qemu_set_fd_handler2(int fd
,
53 IOCanReadHandler
*fd_read_poll
,
62 if (!fd_read
&& !fd_write
) {
63 QLIST_FOREACH(ioh
, &io_handlers
, next
) {
70 QLIST_FOREACH(ioh
, &io_handlers
, next
) {
74 ioh
= g_malloc0(sizeof(IOHandlerRecord
));
75 QLIST_INSERT_HEAD(&io_handlers
, ioh
, next
);
78 ioh
->fd_read_poll
= fd_read_poll
;
79 ioh
->fd_read
= fd_read
;
80 ioh
->fd_write
= fd_write
;
82 ioh
->pollfds_idx
= -1;
89 int qemu_set_fd_handler(int fd
,
94 return qemu_set_fd_handler2(fd
, NULL
, fd_read
, fd_write
, opaque
);
97 void qemu_iohandler_fill(GArray
*pollfds
)
101 QLIST_FOREACH(ioh
, &io_handlers
, next
) {
107 (!ioh
->fd_read_poll
||
108 ioh
->fd_read_poll(ioh
->opaque
) != 0)) {
109 events
|= G_IO_IN
| G_IO_HUP
| G_IO_ERR
;
112 events
|= G_IO_OUT
| G_IO_ERR
;
119 ioh
->pollfds_idx
= pollfds
->len
;
120 g_array_append_val(pollfds
, pfd
);
122 ioh
->pollfds_idx
= -1;
127 void qemu_iohandler_poll(GArray
*pollfds
, int ret
)
130 IOHandlerRecord
*pioh
, *ioh
;
132 QLIST_FOREACH_SAFE(ioh
, &io_handlers
, next
, pioh
) {
135 if (!ioh
->deleted
&& ioh
->pollfds_idx
!= -1) {
136 GPollFD
*pfd
= &g_array_index(pollfds
, GPollFD
,
138 revents
= pfd
->revents
;
141 if (!ioh
->deleted
&& ioh
->fd_read
&&
142 (revents
& (G_IO_IN
| G_IO_HUP
| G_IO_ERR
))) {
143 ioh
->fd_read(ioh
->opaque
);
145 if (!ioh
->deleted
&& ioh
->fd_write
&&
146 (revents
& (G_IO_OUT
| G_IO_ERR
))) {
147 ioh
->fd_write(ioh
->opaque
);
150 /* Do this last in case read/write handlers marked it for deletion */
152 QLIST_REMOVE(ioh
, next
);
159 /* reaping of zombies. right now we're not passing the status to
160 anyone, but it would be possible to add a callback. */
162 typedef struct ChildProcessRecord
{
164 QLIST_ENTRY(ChildProcessRecord
) next
;
165 } ChildProcessRecord
;
167 static QLIST_HEAD(, ChildProcessRecord
) child_watches
=
168 QLIST_HEAD_INITIALIZER(child_watches
);
170 static QEMUBH
*sigchld_bh
;
172 static void sigchld_handler(int signal
)
174 qemu_bh_schedule(sigchld_bh
);
177 static void sigchld_bh_handler(void *opaque
)
179 ChildProcessRecord
*rec
, *next
;
181 QLIST_FOREACH_SAFE(rec
, &child_watches
, next
, next
) {
182 if (waitpid(rec
->pid
, NULL
, WNOHANG
) == rec
->pid
) {
183 QLIST_REMOVE(rec
, next
);
189 static void qemu_init_child_watch(void)
191 struct sigaction act
;
192 sigchld_bh
= qemu_bh_new(sigchld_bh_handler
, NULL
);
194 act
.sa_handler
= sigchld_handler
;
195 act
.sa_flags
= SA_NOCLDSTOP
;
196 sigaction(SIGCHLD
, &act
, NULL
);
199 int qemu_add_child_watch(pid_t pid
)
201 ChildProcessRecord
*rec
;
204 qemu_init_child_watch();
207 QLIST_FOREACH(rec
, &child_watches
, next
) {
208 if (rec
->pid
== pid
) {
212 rec
= g_malloc0(sizeof(ChildProcessRecord
));
214 QLIST_INSERT_HEAD(&child_watches
, rec
, next
);