[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [RFC][PATCH v2 05/19] virtproxy, add vp_channel_send_all
From: |
Michael Roth |
Subject: |
[Qemu-devel] [RFC][PATCH v2 05/19] virtproxy, add vp_channel_send_all |
Date: |
Wed, 10 Nov 2010 16:28:01 -0600 |
This handles sending of data to channel fd (qemu-vp in guest) or the
device associated with the virtproxy chardev for the host depending on
the context. vp_chr_read() wraps qemu_chr_read(), it'll be defined later
in virtproxy-builtin.c, and noop'd in the guest agent via qemu-vp.c.
Signed-off-by: Michael Roth <address@hidden>
---
virtproxy.c | 31 +++++++++++++++++++++++++++++++
virtproxy.h | 1 +
2 files changed, 32 insertions(+), 0 deletions(-)
diff --git a/virtproxy.c b/virtproxy.c
index 2cfd905..edca62e 100644
--- a/virtproxy.c
+++ b/virtproxy.c
@@ -152,6 +152,37 @@ static QemuOptsList vp_socket_opts = {
},
};
+static int vp_channel_send_all(VPDriver *drv, uint8_t *buf, int count)
+{
+ int ret;
+ CharDriverState *chr = drv->chr;
+
+ if (drv->chr != NULL) {
+ /* send data to guest via channel device's read handler */
+ vp_chr_read(chr, buf, count);
+ /* TODO: we assume here the full buffer was written to device
+ * due to the dev write handler being a void function.
+ * can we confirm? Do we need to?
+ */
+ ret = count;
+ } else if (drv->channel_fd != -1) {
+ /* send data to host via channel fd */
+ ret = vp_send_all(drv->channel_fd, buf, count);
+ if (ret == -1) {
+ LOG("error sending data");
+ goto out_bad;
+ }
+ } else {
+ LOG("driver in unknown state");
+ goto out_bad;
+ }
+
+ return ret;
+out_bad:
+ LOG("unable to send to channel");
+ return -1;
+}
+
/* get VPConn by fd, "client" denotes whether to look for client or server */
static VPConn *get_conn(const VPDriver *drv, int fd, bool client)
{
diff --git a/virtproxy.h b/virtproxy.h
index 0203421..1a5e56a 100644
--- a/virtproxy.h
+++ b/virtproxy.h
@@ -30,5 +30,6 @@ int vp_set_fd_handler(int fd,
IOHandler *fd_read,
IOHandler *fd_write,
void *opaque);
+void vp_chr_read(CharDriverState *s, uint8_t *buf, int len);
#endif /* VIRTPROXY_H */
--
1.7.0.4
- [Qemu-devel] [RFC][PATCH v2 17/19] virtproxy: qemu integration, add virtproxy to Makefile.targets, (continued)
- [Qemu-devel] [RFC][PATCH v2 17/19] virtproxy: qemu integration, add virtproxy to Makefile.targets, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 15/19] virtproxy: add virtproxy-builtin.c for compat defs, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 16/19] virtproxy: qemu integration, add virtproxy chardev, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 14/19] virtproxy: add read handler for proxied connections, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 13/19] virtproxy: interfaces to set/remove VPIForwards, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 09/19] virtproxy: interfaces to set/remove/handle VPOForwards, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 11/19] virtproxy: add handler for control packet, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 08/19] virtproxy: add vp_new() VPDriver constructor, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 06/19] virtproxy: add accept handler for communication channel, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 07/19] virtproxy: add read handler for communication channel, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 05/19] virtproxy, add vp_channel_send_all,
Michael Roth <=
- [Qemu-devel] [RFC][PATCH v2 10/19] virtproxy: add handler for data packets, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 03/19] virtproxy: add debug functions for virtproxy core, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 04/19] virtproxy: list look-up functions conns/oforwards/iforwards, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 01/19] virtproxy: base data structures and constants, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 02/19] virtproxy: qemu-vp, standalone daemon skeleton, Michael Roth, 2010/11/10
- [Qemu-devel] [RFC][PATCH v2 12/19] virtproxy: add vp_handle_packet(), Michael Roth, 2010/11/10
- Re: [Qemu-devel] [RFC][PATCH v2 00/19] virtproxy: host/guest communication layer, Michael Roth, 2010/11/10