mirrors/qemu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

io: fix setting of QIO_CHANNEL_FEATURE_FD_PASS on server connections

Browse Source 
The QIO_CHANNEL_FEATURE_FD_PASS feature flag is set in the
qio_channel_socket_set_fd() method, however, this only deals
with client side connections.

To ensure server side connections also have the feature flag
set, we must set it in qio_channel_socket_accept() too. This
also highlighted a typo fix where the code updated the
sockaddr struct in the wrong object instance.

Reviewed-by: Eric Blake <eblake@redhat.com>
Signed-off-by: Daniel P. Berrange <berrange@redhat.com>
This commit is contained in:
Daniel P. Berrange 2015-12-21 12:04:21 +00:00
parent e4d2edc9d0
commit bead59946a
2 changed files with 33 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
io/channel-socket.c
View File

@ -352,13 +352,19 @@ qio_channel_socket_accept(QIOChannelSocket *ioc,
goto error; goto error;
} }
if (getsockname(cioc->fd, (struct sockaddr *)&ioc->localAddr, if (getsockname(cioc->fd, (struct sockaddr *)&cioc->localAddr,
&ioc->localAddrLen) < 0) { &cioc->localAddrLen) < 0) {
error_setg_errno(errp, socket_error(), error_setg_errno(errp, socket_error(),
"Unable to query local socket address"); "Unable to query local socket address");
goto error; goto error;
} }
#ifndef WIN32
if (cioc->localAddr.ss_family == AF_UNIX) {
QIO_CHANNEL(cioc)->features |= (1 << QIO_CHANNEL_FEATURE_FD_PASS);
}
#endif /* WIN32 */
trace_qio_channel_socket_accept_complete(ioc, cioc, cioc->fd); trace_qio_channel_socket_accept_complete(ioc, cioc, cioc->fd);
return cioc; return cioc;

29
tests/test-io-channel-socket.c
View File

@ -210,13 +210,19 @@ static void test_io_channel_setup_async(SocketAddress *listen_addr,
static void test_io_channel(bool async, static void test_io_channel(bool async,
SocketAddress *listen_addr, SocketAddress *listen_addr,
SocketAddress *connect_addr) SocketAddress *connect_addr,
bool passFD)
{ {
QIOChannel *src, *dst; QIOChannel *src, *dst;
QIOChannelTest *test; QIOChannelTest *test;
if (async) { if (async) {
test_io_channel_setup_async(listen_addr, connect_addr, &src, &dst); test_io_channel_setup_async(listen_addr, connect_addr, &src, &dst);
g_assert(!passFD ||
qio_channel_has_feature(src, QIO_CHANNEL_FEATURE_FD_PASS));
g_assert(!passFD ||
qio_channel_has_feature(dst, QIO_CHANNEL_FEATURE_FD_PASS));
test = qio_channel_test_new(); test = qio_channel_test_new();
qio_channel_test_run_threads(test, true, src, dst); qio_channel_test_run_threads(test, true, src, dst);
qio_channel_test_validate(test); qio_channel_test_validate(test);
@ -226,6 +232,11 @@ static void test_io_channel(bool async,
test_io_channel_setup_async(listen_addr, connect_addr, &src, &dst); test_io_channel_setup_async(listen_addr, connect_addr, &src, &dst);
g_assert(!passFD ||
qio_channel_has_feature(src, QIO_CHANNEL_FEATURE_FD_PASS));
g_assert(!passFD ||
qio_channel_has_feature(dst, QIO_CHANNEL_FEATURE_FD_PASS));
test = qio_channel_test_new(); test = qio_channel_test_new();
qio_channel_test_run_threads(test, false, src, dst); qio_channel_test_run_threads(test, false, src, dst);
qio_channel_test_validate(test); qio_channel_test_validate(test);
@ -235,6 +246,11 @@ static void test_io_channel(bool async,
} else { } else {
test_io_channel_setup_sync(listen_addr, connect_addr, &src, &dst); test_io_channel_setup_sync(listen_addr, connect_addr, &src, &dst);
g_assert(!passFD ||
qio_channel_has_feature(src, QIO_CHANNEL_FEATURE_FD_PASS));
g_assert(!passFD ||
qio_channel_has_feature(dst, QIO_CHANNEL_FEATURE_FD_PASS));
test = qio_channel_test_new(); test = qio_channel_test_new();
qio_channel_test_run_threads(test, true, src, dst); qio_channel_test_run_threads(test, true, src, dst);
qio_channel_test_validate(test); qio_channel_test_validate(test);
@ -244,6 +260,11 @@ static void test_io_channel(bool async,
test_io_channel_setup_sync(listen_addr, connect_addr, &src, &dst); test_io_channel_setup_sync(listen_addr, connect_addr, &src, &dst);
g_assert(!passFD ||
qio_channel_has_feature(src, QIO_CHANNEL_FEATURE_FD_PASS));
g_assert(!passFD ||
qio_channel_has_feature(dst, QIO_CHANNEL_FEATURE_FD_PASS));
test = qio_channel_test_new(); test = qio_channel_test_new();
qio_channel_test_run_threads(test, false, src, dst); qio_channel_test_run_threads(test, false, src, dst);
qio_channel_test_validate(test); qio_channel_test_validate(test);
@ -269,7 +290,7 @@ static void test_io_channel_ipv4(bool async)
connect_addr->u.inet->host = g_strdup("127.0.0.1"); connect_addr->u.inet->host = g_strdup("127.0.0.1");
connect_addr->u.inet->port = NULL; /* Filled in later */ connect_addr->u.inet->port = NULL; /* Filled in later */
test_io_channel(async, listen_addr, connect_addr); test_io_channel(async, listen_addr, connect_addr, false);
qapi_free_SocketAddress(listen_addr); qapi_free_SocketAddress(listen_addr);
qapi_free_SocketAddress(connect_addr); qapi_free_SocketAddress(connect_addr);
@ -303,7 +324,7 @@ static void test_io_channel_ipv6(bool async)
connect_addr->u.inet->host = g_strdup("::1"); connect_addr->u.inet->host = g_strdup("::1");
connect_addr->u.inet->port = NULL; /* Filled in later */ connect_addr->u.inet->port = NULL; /* Filled in later */
test_io_channel(async, listen_addr, connect_addr); test_io_channel(async, listen_addr, connect_addr, false);
qapi_free_SocketAddress(listen_addr); qapi_free_SocketAddress(listen_addr);
qapi_free_SocketAddress(connect_addr); qapi_free_SocketAddress(connect_addr);
@ -337,7 +358,7 @@ static void test_io_channel_unix(bool async)
connect_addr->u.q_unix = g_new0(UnixSocketAddress, 1); connect_addr->u.q_unix = g_new0(UnixSocketAddress, 1);
connect_addr->u.q_unix->path = g_strdup(TEST_SOCKET); connect_addr->u.q_unix->path = g_strdup(TEST_SOCKET);
test_io_channel(async, listen_addr, connect_addr); test_io_channel(async, listen_addr, connect_addr, true);
qapi_free_SocketAddress(listen_addr); qapi_free_SocketAddress(listen_addr);
qapi_free_SocketAddress(connect_addr); qapi_free_SocketAddress(connect_addr);