[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH 02/18] Introduce read() to FdMigrationState.
From: |
Yoshiaki Tamura |
Subject: |
Re: [Qemu-devel] [PATCH 02/18] Introduce read() to FdMigrationState. |
Date: |
Thu, 10 Feb 2011 19:00:44 +0900 |
2011/2/10 Anthony Liguori <address@hidden>:
> On 02/10/2011 10:30 AM, Yoshiaki Tamura wrote:
>>
>> Currently FdMigrationState doesn't support read(), and this patch
>> introduces it to get response from the other side.
>>
>> Signed-off-by: Yoshiaki Tamura<address@hidden>
>>
>
> Migration is unidirectional. Changing this is fundamental and not something
> to be done lightly.
>
> I thought we previously discussed using a protocol wrapper around the
> existing migration protocol?
AFAIR, I don't think we had that discussion before. I applied
comments from Stefan though. If I missed the discussion, could
you please give me the link?
Thanks,
Yoshi
>
> Regards,
>
> Anthony Liguori
>
>> ---
>> migration-tcp.c | 15 +++++++++++++++
>> migration.c | 13 +++++++++++++
>> migration.h | 3 +++
>> 3 files changed, 31 insertions(+), 0 deletions(-)
>>
>> diff --git a/migration-tcp.c b/migration-tcp.c
>> index b55f419..55777c8 100644
>> --- a/migration-tcp.c
>> +++ b/migration-tcp.c
>> @@ -39,6 +39,20 @@ static int socket_write(FdMigrationState *s, const void
>> * buf, size_t size)
>> return send(s->fd, buf, size, 0);
>> }
>>
>> +static int socket_read(FdMigrationState *s, const void * buf, size_t
>> size)
>> +{
>> + ssize_t len;
>> +
>> + do {
>> + len = recv(s->fd, (void *)buf, size, 0);
>> + } while (len == -1&& socket_error() == EINTR);
>> + if (len == -1) {
>> + len = -socket_error();
>> + }
>> +
>> + return len;
>> +}
>> +
>> static int tcp_close(FdMigrationState *s)
>> {
>> DPRINTF("tcp_close\n");
>> @@ -94,6 +108,7 @@ MigrationState *tcp_start_outgoing_migration(Monitor
>> *mon,
>>
>> s->get_error = socket_errno;
>> s->write = socket_write;
>> + s->read = socket_read;
>> s->close = tcp_close;
>> s->mig_state.cancel = migrate_fd_cancel;
>> s->mig_state.get_status = migrate_fd_get_status;
>> diff --git a/migration.c b/migration.c
>> index 3612572..f0df5fc 100644
>> --- a/migration.c
>> +++ b/migration.c
>> @@ -340,6 +340,19 @@ ssize_t migrate_fd_put_buffer(void *opaque, const
>> void *data, size_t size)
>> return ret;
>> }
>>
>> +int migrate_fd_get_buffer(void *opaque, uint8_t *data, int64_t pos,
>> size_t size)
>> +{
>> + FdMigrationState *s = opaque;
>> + int ret;
>> +
>> + ret = s->read(s, data, size);
>> + if (ret == -1) {
>> + ret = -(s->get_error(s));
>> + }
>> +
>> + return ret;
>> +}
>> +
>> void migrate_fd_connect(FdMigrationState *s)
>> {
>> int ret;
>> diff --git a/migration.h b/migration.h
>> index 2170792..88a6987 100644
>> --- a/migration.h
>> +++ b/migration.h
>> @@ -48,6 +48,7 @@ struct FdMigrationState
>> int (*get_error)(struct FdMigrationState*);
>> int (*close)(struct FdMigrationState*);
>> int (*write)(struct FdMigrationState*, const void *, size_t);
>> + int (*read)(struct FdMigrationState *, const void *, size_t);
>> void *opaque;
>> };
>>
>> @@ -116,6 +117,8 @@ void migrate_fd_put_notify(void *opaque);
>>
>> ssize_t migrate_fd_put_buffer(void *opaque, const void *data, size_t
>> size);
>>
>> +int migrate_fd_get_buffer(void *opaque, uint8_t *data, int64_t pos,
>> size_t size);
>> +
>> void migrate_fd_connect(FdMigrationState *s);
>>
>> void migrate_fd_put_ready(void *opaque);
>>
>
> --
> To unsubscribe from this list: send the line "unsubscribe kvm" in
> the body of a message to address@hidden
> More majordomo info at http://vger.kernel.org/majordomo-info.html
>
- [Qemu-devel] [PATCH 00/18] Kemari for KVM v0.2.10, Yoshiaki Tamura, 2011/02/10
- [Qemu-devel] [PATCH 12/18] Insert event_tap_mmio() to cpu_physical_memory_rw() in exec.c., Yoshiaki Tamura, 2011/02/10
- [Qemu-devel] [PATCH 13/18] net: insert event-tap to qemu_send_packet() and qemu_sendv_packet_async()., Yoshiaki Tamura, 2011/02/10
- [Qemu-devel] [PATCH 01/18] Make QEMUFile buf expandable, and introduce qemu_realloc_buffer() and qemu_clear_buffer()., Yoshiaki Tamura, 2011/02/10
- [Qemu-devel] [PATCH 18/18] Introduce "kemari:" to enable FT migration mode (Kemari)., Yoshiaki Tamura, 2011/02/10
- [Qemu-devel] [PATCH 02/18] Introduce read() to FdMigrationState., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 08/18] savevm: introduce util functions to control ft_trans_file from savevm layer., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 03/18] Introduce skip_header parameter to qemu_loadvm_state()., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 16/18] migration: introduce migrate_ft_trans_{put, get}_ready(), and modify migrate_fd_put_ready() when ft_mode is on., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 17/18] migration-tcp: modify tcp_accept_incoming_migration() to handle ft_mode, and add a hack not to close fd when ft_mode is enabled., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 11/18] ioport: insert event_tap_ioport() to ioport_write()., Yoshiaki Tamura, 2011/02/10
[Qemu-devel] [PATCH 07/18] Introduce fault tolerant VM transaction QEMUFile and ft_mode., Yoshiaki Tamura, 2011/02/10