[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 19/32] include: move coroutine IO functions to coroutine.h
From: |
marcandre . lureau |
Subject: |
[PATCH 19/32] include: move coroutine IO functions to coroutine.h |
Date: |
Wed, 23 Mar 2022 19:57:30 +0400 |
From: Marc-André Lureau <marcandre.lureau@redhat.com>
Signed-off-by: Marc-André Lureau <marcandre.lureau@redhat.com>
---
include/qemu-common.h | 23 -----------------------
include/qemu/coroutine.h | 23 +++++++++++++++++++++++
2 files changed, 23 insertions(+), 23 deletions(-)
diff --git a/include/qemu-common.h b/include/qemu-common.h
index 2e1e76014a5f..fdb0b16166a5 100644
--- a/include/qemu-common.h
+++ b/include/qemu-common.h
@@ -45,29 +45,6 @@ bool set_preferred_target_page_bits(int bits);
*/
void finalize_target_page_bits(void);
-/**
- * Sends a (part of) iovec down a socket, yielding when the socket is full, or
- * Receives data into a (part of) iovec from a socket,
- * yielding when there is no data in the socket.
- * The same interface as qemu_sendv_recvv(), with added yielding.
- * XXX should mark these as coroutine_fn
- */
-ssize_t qemu_co_sendv_recvv(int sockfd, struct iovec *iov, unsigned iov_cnt,
- size_t offset, size_t bytes, bool do_send);
-#define qemu_co_recvv(sockfd, iov, iov_cnt, offset, bytes) \
- qemu_co_sendv_recvv(sockfd, iov, iov_cnt, offset, bytes, false)
-#define qemu_co_sendv(sockfd, iov, iov_cnt, offset, bytes) \
- qemu_co_sendv_recvv(sockfd, iov, iov_cnt, offset, bytes, true)
-
-/**
- * The same as above, but with just a single buffer
- */
-ssize_t qemu_co_send_recv(int sockfd, void *buf, size_t bytes, bool do_send);
-#define qemu_co_recv(sockfd, buf, bytes) \
- qemu_co_send_recv(sockfd, buf, bytes, false)
-#define qemu_co_send(sockfd, buf, bytes) \
- qemu_co_send_recv(sockfd, buf, bytes, true)
-
void qemu_progress_init(int enabled, float min_skip);
void qemu_progress_end(void);
void qemu_progress_print(float delta, int max);
diff --git a/include/qemu/coroutine.h b/include/qemu/coroutine.h
index c828a95ee092..284571badb8a 100644
--- a/include/qemu/coroutine.h
+++ b/include/qemu/coroutine.h
@@ -343,4 +343,27 @@ void qemu_coroutine_decrease_pool_batch_size(unsigned int
additional_pool_size);
#include "qemu/lockable.h"
+/**
+ * Sends a (part of) iovec down a socket, yielding when the socket is full, or
+ * Receives data into a (part of) iovec from a socket,
+ * yielding when there is no data in the socket.
+ * The same interface as qemu_sendv_recvv(), with added yielding.
+ * XXX should mark these as coroutine_fn
+ */
+ssize_t qemu_co_sendv_recvv(int sockfd, struct iovec *iov, unsigned iov_cnt,
+ size_t offset, size_t bytes, bool do_send);
+#define qemu_co_recvv(sockfd, iov, iov_cnt, offset, bytes) \
+ qemu_co_sendv_recvv(sockfd, iov, iov_cnt, offset, bytes, false)
+#define qemu_co_sendv(sockfd, iov, iov_cnt, offset, bytes) \
+ qemu_co_sendv_recvv(sockfd, iov, iov_cnt, offset, bytes, true)
+
+/**
+ * The same as above, but with just a single buffer
+ */
+ssize_t qemu_co_send_recv(int sockfd, void *buf, size_t bytes, bool do_send);
+#define qemu_co_recv(sockfd, buf, bytes) \
+ qemu_co_send_recv(sockfd, buf, bytes, false)
+#define qemu_co_send(sockfd, buf, bytes) \
+ qemu_co_send_recv(sockfd, buf, bytes, true)
+
#endif /* QEMU_COROUTINE_H */
--
2.35.1.273.ge6ebfd0e8cbb
- Re: [PATCH 10/32] tests: replace free_all() usage with g_auto, (continued)
- [PATCH 12/32] qga: replace deprecated g_get_current_time(), marcandre . lureau, 2022/03/23
- [PATCH 11/32] Replace qemu_real_host_page variables with inlined functions, marcandre . lureau, 2022/03/23
- [PATCH 14/32] util: rename qemu-error.c to match its header name, marcandre . lureau, 2022/03/23
- [PATCH 13/32] error-report: replace deprecated g_get_current_time() with glib >= 2.62, marcandre . lureau, 2022/03/23
- [PATCH 15/32] error-report: use error_printf() for program prefix, marcandre . lureau, 2022/03/23
- [PATCH 16/32] include: move TFR to osdep.h, marcandre . lureau, 2022/03/23
- [PATCH 18/32] include: move qemu_pipe() to osdep.h, marcandre . lureau, 2022/03/23
- [PATCH 17/32] include: move qemu_write_full() declaration to osdep.h, marcandre . lureau, 2022/03/23
- [PATCH 19/32] include: move coroutine IO functions to coroutine.h,
marcandre . lureau <=
- [PATCH 20/32] include: move dump_in_progress() to runstate.h, marcandre . lureau, 2022/03/23
- [PATCH 21/32] include: move C/util-related declarations to cutils.h, marcandre . lureau, 2022/03/23
- [PATCH 22/32] include: move cpu_exec* declarations to cpu-common.h, marcandre . lureau, 2022/03/23
- [PATCH 23/32] include: move target page bits declaration to page-vary.h, marcandre . lureau, 2022/03/23
- [PATCH 24/32] include: move progress API to qemu-progress.h, marcandre . lureau, 2022/03/23
- [PATCH 25/32] include: move qemu_get_vm_name() to sysemu.h, marcandre . lureau, 2022/03/23
- [PATCH 26/32] include: move os_*() to os-foo.h, marcandre . lureau, 2022/03/23