55     MigrationIncomingState *mis = migration_incoming_get_current();  in migration_incoming_in_colo_state()  local
57     return mis && (mis->state == MIGRATION_STATUS_COLO);  in migration_incoming_in_colo_state()
92     MigrationIncomingState *mis = migration_incoming_get_current();  in secondary_vm_do_failover()  local
108     migrate_set_state(&mis->state, MIGRATION_STATUS_COLO,  in secondary_vm_do_failover()
134     if (mis->from_src_file) {  in secondary_vm_do_failover()
135         qemu_file_shutdown(mis->from_src_file);  in secondary_vm_do_failover()
137     if (mis->to_src_file) {  in secondary_vm_do_failover()
138         qemu_file_shutdown(mis->to_src_file);  in secondary_vm_do_failover()
149     qemu_sem_post(&mis->colo_incoming_sem);  in secondary_vm_do_failover()
152     if (mis->colo_incoming_co) {  in secondary_vm_do_failover()
153         qemu_coroutine_enter(mis->colo_incoming_co);  in secondary_vm_do_failover()
656 static void colo_incoming_process_checkpoint(MigrationIncomingState *mis,  in colo_incoming_process_checkpoint()  argument
670     colo_send_message(mis->to_src_file, COLO_MESSAGE_CHECKPOINT_REPLY,  in colo_incoming_process_checkpoint()
677     colo_receive_check_message(mis->from_src_file,  in colo_incoming_process_checkpoint()
686     ret = qemu_loadvm_state_main(mis->from_src_file, mis);  in colo_incoming_process_checkpoint()
694     value = colo_receive_message_value(mis->from_src_file,  in colo_incoming_process_checkpoint()
710     total_size = qemu_get_buffer(mis->from_src_file, bioc->data, value);  in colo_incoming_process_checkpoint()
719     colo_send_message(mis->to_src_file, COLO_MESSAGE_VMSTATE_RECEIVED,  in colo_incoming_process_checkpoint()
772     colo_send_message(mis->to_src_file, COLO_MESSAGE_VMSTATE_LOADED,  in colo_incoming_process_checkpoint()
777 static void colo_wait_handle_message(MigrationIncomingState *mis,  in colo_wait_handle_message()  argument
783     msg = colo_receive_message(mis->from_src_file, &local_err);  in colo_wait_handle_message()
791         colo_incoming_process_checkpoint(mis, fb, bioc, errp);  in colo_wait_handle_message()
801     MigrationIncomingState *mis = NULL;  in colo_shutdown()  local
811         mis = migration_incoming_get_current();  in colo_shutdown()
812         qemu_sem_post(&mis->colo_incoming_sem);  in colo_shutdown()
821     MigrationIncomingState *mis = opaque;  in colo_process_incoming_thread()  local
827     qemu_sem_init(&mis->colo_incoming_sem, 0);  in colo_process_incoming_thread()
829     migrate_set_state(&mis->state, MIGRATION_STATUS_ACTIVE,  in colo_process_incoming_thread()
848     mis->to_src_file = qemu_file_get_return_path(mis->from_src_file);  in colo_process_incoming_thread()
849     if (!mis->to_src_file) {  in colo_process_incoming_thread()
859     qemu_file_set_blocking(mis->from_src_file, true);  in colo_process_incoming_thread()
877     colo_send_message(mis->to_src_file, COLO_MESSAGE_CHECKPOINT_READY,  in colo_process_incoming_thread()
883     while (mis->state == MIGRATION_STATUS_COLO) {  in colo_process_incoming_thread()
884         colo_wait_handle_message(mis, fb, bioc, &local_err);  in colo_process_incoming_thread()
923     qemu_sem_wait(&mis->colo_incoming_sem);  in colo_process_incoming_thread()
924     qemu_sem_destroy(&mis->colo_incoming_sem);  in colo_process_incoming_thread()
932     MigrationIncomingState *mis = migration_incoming_get_current();  in colo_incoming_co()  local
940                        mis, QEMU_THREAD_JOINABLE);  in colo_incoming_co()
942     mis->colo_incoming_co = qemu_coroutine_self();  in colo_incoming_co()
944     mis->colo_incoming_co = NULL;  in colo_incoming_co()