Revision 2350e13c migration.c
| b/migration.c | ||
|---|---|---|
| 313 | 313 |
|
| 314 | 314 |
qemu_set_fd_handler2(s->fd, NULL, NULL, NULL, NULL); |
| 315 | 315 |
qemu_file_put_notify(s->file); |
| 316 |
if (qemu_file_has_error(s->file)) {
|
|
| 317 |
migrate_fd_error(s); |
|
| 318 |
} |
|
| 316 | 319 |
} |
| 317 | 320 |
|
| 318 | 321 |
ssize_t migrate_fd_put_buffer(void *opaque, const void *data, size_t size) |
| ... | ... | |
| 329 | 332 |
|
| 330 | 333 |
if (ret == -EAGAIN) {
|
| 331 | 334 |
qemu_set_fd_handler2(s->fd, NULL, NULL, migrate_fd_put_notify, s); |
| 332 |
} else if (ret < 0) {
|
|
| 333 |
s->state = MIG_STATE_ERROR; |
|
| 334 |
notifier_list_notify(&migration_state_notifiers, NULL); |
|
| 335 | 335 |
} |
| 336 | 336 |
|
| 337 | 337 |
return ret; |
Also available in: Unified diff