mirror of https://gitlab.com/qemu-project/qemu
io: mark mixed functions that can suspend
There should be no paths from a coroutine_fn to aio_poll, however in practice coroutine_mixed_fn will call aio_poll in the !qemu_in_coroutine() path. By marking mixed functions, we can track accurately the call paths that execute entirely in coroutine context, and find more missing coroutine_fn markers. This results in more accurate checks that coroutine code does not end up blocking. If the marking were extended transitively to all functions that call these ones, static analysis could be done much more efficiently. However, this is a start and makes it possible to use vrc's path-based searches to find potential bugs where coroutine_fns call blocking functions. Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
This commit is contained in:
parent
cf9d4e68d7
commit
1dd91b22a6
|
@ -301,7 +301,7 @@ ssize_t qio_channel_writev_full(QIOChannel *ioc,
|
|||
* Returns: 1 if all bytes were read, 0 if end-of-file
|
||||
* occurs without data, or -1 on error
|
||||
*/
|
||||
int qio_channel_readv_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_all_eof(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp);
|
||||
|
@ -328,7 +328,7 @@ int qio_channel_readv_all_eof(QIOChannel *ioc,
|
|||
*
|
||||
* Returns: 0 if all bytes were read, or -1 on error
|
||||
*/
|
||||
int qio_channel_readv_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp);
|
||||
|
@ -353,7 +353,7 @@ int qio_channel_readv_all(QIOChannel *ioc,
|
|||
*
|
||||
* Returns: 0 if all bytes were written, or -1 on error
|
||||
*/
|
||||
int qio_channel_writev_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_writev_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp);
|
||||
|
@ -437,7 +437,7 @@ ssize_t qio_channel_write(QIOChannel *ioc,
|
|||
* Returns: 1 if all bytes were read, 0 if end-of-file occurs
|
||||
* without data, or -1 on error
|
||||
*/
|
||||
int qio_channel_read_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_read_all_eof(QIOChannel *ioc,
|
||||
char *buf,
|
||||
size_t buflen,
|
||||
Error **errp);
|
||||
|
@ -457,7 +457,7 @@ int qio_channel_read_all_eof(QIOChannel *ioc,
|
|||
*
|
||||
* Returns: 0 if all bytes were read, or -1 on error
|
||||
*/
|
||||
int qio_channel_read_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_read_all(QIOChannel *ioc,
|
||||
char *buf,
|
||||
size_t buflen,
|
||||
Error **errp);
|
||||
|
@ -476,7 +476,7 @@ int qio_channel_read_all(QIOChannel *ioc,
|
|||
*
|
||||
* Returns: 0 if all bytes were written, or -1 on error
|
||||
*/
|
||||
int qio_channel_write_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_write_all(QIOChannel *ioc,
|
||||
const char *buf,
|
||||
size_t buflen,
|
||||
Error **errp);
|
||||
|
@ -812,7 +812,7 @@ void qio_channel_set_aio_fd_handler(QIOChannel *ioc,
|
|||
* occurs without data, or -1 on error
|
||||
*/
|
||||
|
||||
int qio_channel_readv_full_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_full_all_eof(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int **fds, size_t *nfds,
|
||||
|
@ -838,7 +838,7 @@ int qio_channel_readv_full_all_eof(QIOChannel *ioc,
|
|||
* Returns: 0 if all bytes were read, or -1 on error
|
||||
*/
|
||||
|
||||
int qio_channel_readv_full_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_full_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int **fds, size_t *nfds,
|
||||
|
@ -872,7 +872,7 @@ int qio_channel_readv_full_all(QIOChannel *ioc,
|
|||
* Returns: 0 if all bytes were written, or -1 on error
|
||||
*/
|
||||
|
||||
int qio_channel_writev_full_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_writev_full_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int *fds, size_t nfds,
|
||||
|
|
18
io/channel.c
18
io/channel.c
|
@ -109,7 +109,7 @@ ssize_t qio_channel_writev_full(QIOChannel *ioc,
|
|||
}
|
||||
|
||||
|
||||
int qio_channel_readv_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_all_eof(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp)
|
||||
|
@ -117,7 +117,7 @@ int qio_channel_readv_all_eof(QIOChannel *ioc,
|
|||
return qio_channel_readv_full_all_eof(ioc, iov, niov, NULL, NULL, errp);
|
||||
}
|
||||
|
||||
int qio_channel_readv_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp)
|
||||
|
@ -125,7 +125,7 @@ int qio_channel_readv_all(QIOChannel *ioc,
|
|||
return qio_channel_readv_full_all(ioc, iov, niov, NULL, NULL, errp);
|
||||
}
|
||||
|
||||
int qio_channel_readv_full_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_full_all_eof(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int **fds, size_t *nfds,
|
||||
|
@ -215,7 +215,7 @@ next_iter:
|
|||
return ret;
|
||||
}
|
||||
|
||||
int qio_channel_readv_full_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_readv_full_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int **fds, size_t *nfds,
|
||||
|
@ -234,7 +234,7 @@ int qio_channel_readv_full_all(QIOChannel *ioc,
|
|||
return ret;
|
||||
}
|
||||
|
||||
int qio_channel_writev_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_writev_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
Error **errp)
|
||||
|
@ -242,7 +242,7 @@ int qio_channel_writev_all(QIOChannel *ioc,
|
|||
return qio_channel_writev_full_all(ioc, iov, niov, NULL, 0, 0, errp);
|
||||
}
|
||||
|
||||
int qio_channel_writev_full_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_writev_full_all(QIOChannel *ioc,
|
||||
const struct iovec *iov,
|
||||
size_t niov,
|
||||
int *fds, size_t nfds,
|
||||
|
@ -325,7 +325,7 @@ ssize_t qio_channel_write(QIOChannel *ioc,
|
|||
}
|
||||
|
||||
|
||||
int qio_channel_read_all_eof(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_read_all_eof(QIOChannel *ioc,
|
||||
char *buf,
|
||||
size_t buflen,
|
||||
Error **errp)
|
||||
|
@ -335,7 +335,7 @@ int qio_channel_read_all_eof(QIOChannel *ioc,
|
|||
}
|
||||
|
||||
|
||||
int qio_channel_read_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_read_all(QIOChannel *ioc,
|
||||
char *buf,
|
||||
size_t buflen,
|
||||
Error **errp)
|
||||
|
@ -345,7 +345,7 @@ int qio_channel_read_all(QIOChannel *ioc,
|
|||
}
|
||||
|
||||
|
||||
int qio_channel_write_all(QIOChannel *ioc,
|
||||
int coroutine_mixed_fn qio_channel_write_all(QIOChannel *ioc,
|
||||
const char *buf,
|
||||
size_t buflen,
|
||||
Error **errp)
|
||||
|
|
Loading…
Reference in New Issue