Git Repo - qemu.git/blame_incremental

... / ...

Commit	Line	Data
	1	/*
	2	* QEMU live migration channel operations
	3	*
	4	* Copyright Red Hat, Inc. 2016
	5	*
	6	* Authors:
	7	* Daniel P. Berrange <[email protected]>
	8	*
	9	* Contributions after 2012-01-13 are licensed under the terms of the
	10	* GNU GPL, version 2 or (at your option) any later version.
	11	*/
	12
	13	#include "qemu/osdep.h"
	14	#include "channel.h"
	15	#include "tls.h"
	16	#include "migration.h"
	17	#include "qemu-file-channel.h"
	18	#include "trace.h"
	19	#include "qapi/error.h"
	20	#include "io/channel-tls.h"
	21
	22	/**
	23	* @migration_channel_process_incoming - Create new incoming migration channel
	24	*
	25	* Notice that TLS is special. For it we listen in a listener socket,
	26	* and then create a new client socket from the TLS library.
	27	*
	28	* @ioc: Channel to which we are connecting
	29	*/
	30	void migration_channel_process_incoming(QIOChannel *ioc)
	31	{
	32	MigrationState *s = migrate_get_current();
	33
	34	trace_migration_set_incoming_channel(
	35	ioc, object_get_typename(OBJECT(ioc)));
	36
	37	if (s->parameters.tls_creds &&
	38	*s->parameters.tls_creds &&
	39	!object_dynamic_cast(OBJECT(ioc),
	40	TYPE_QIO_CHANNEL_TLS)) {
	41	Error *local_err = NULL;
	42	migration_tls_channel_process_incoming(s, ioc, &local_err);
	43	if (local_err) {
	44	error_report_err(local_err);
	45	}
	46	} else {
	47	migration_ioc_process_incoming(ioc);
	48	}
	49	}
	50
	51
	52	/**
	53	* @migration_channel_connect - Create new outgoing migration channel
	54	*
	55	* @s: Current migration state
	56	* @ioc: Channel to which we are connecting
	57	* @hostname: Where we want to connect
	58	* @error: Error indicating failure to connect, free'd here
	59	*/
	60	void migration_channel_connect(MigrationState *s,
	61	QIOChannel *ioc,
	62	const char *hostname,
	63	Error *error)
	64	{
	65	trace_migration_set_outgoing_channel(
	66	ioc, object_get_typename(OBJECT(ioc)), hostname, error);
	67
	68	if (!error) {
	69	if (s->parameters.tls_creds &&
	70	*s->parameters.tls_creds &&
	71	!object_dynamic_cast(OBJECT(ioc),
	72	TYPE_QIO_CHANNEL_TLS)) {
	73	migration_tls_channel_connect(s, ioc, hostname, &error);
	74
	75	if (!error) {
	76	/* tls_channel_connect will call back to this
	77	* function after the TLS handshake,
	78	* so we mustn't call migrate_fd_connect until then
	79	*/
	80
	81	return;
	82	}
	83	} else {
	84	QEMUFile *f = qemu_fopen_channel_output(ioc);
	85
	86	qemu_mutex_lock(&s->qemu_file_lock);
	87	s->to_dst_file = f;
	88	qemu_mutex_unlock(&s->qemu_file_lock);
	89	}
	90	}
	91	migrate_fd_connect(s, error);
	92	error_free(error);
	93	}