david.venhoff/QEMU-Nyx-fork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sockets: Convert to new qapi union layout

Browse Source 
We have two issues with our qapi union layout:
1) Even though the QMP wire format spells the tag 'type', the
C code spells it 'kind', requiring some hacks in the generator.
2) The C struct uses an anonymous union, which places all tag
values in the same namespace as all non-variant members. This
leads to spurious collisions if a tag value matches a non-variant
member's name.

Make the conversion to the new layout for socket-related code.

Signed-off-by: Eric Blake <eblake@redhat.com>
Message-Id: <1445898903-12082-17-git-send-email-eblake@redhat.com>
[Commit message tweaked slightly]
Signed-off-by: Markus Armbruster <armbru@redhat.com>
This commit is contained in:
Eric Blake 2015-10-26 16:34:55 -06:00 committed by Markus Armbruster
parent 6a8f9661dc
commit 2d32addae7
3 changed files with 61 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
qemu-nbd.c
View File

@ -362,17 +362,17 @@ static SocketAddress *nbd_build_socket_address(const char *sockpath,
saddr = g_new0(SocketAddress, 1); saddr = g_new0(SocketAddress, 1);
if (sockpath) { if (sockpath) {
saddr->kind = SOCKET_ADDRESS_KIND_UNIX; saddr->type = SOCKET_ADDRESS_KIND_UNIX;
saddr->q_unix = g_new0(UnixSocketAddress, 1); saddr->u.q_unix = g_new0(UnixSocketAddress, 1);
saddr->q_unix->path = g_strdup(sockpath); saddr->u.q_unix->path = g_strdup(sockpath);
} else { } else {
saddr->kind = SOCKET_ADDRESS_KIND_INET; saddr->type = SOCKET_ADDRESS_KIND_INET;
saddr->inet = g_new0(InetSocketAddress, 1); saddr->u.inet = g_new0(InetSocketAddress, 1);
saddr->inet->host = g_strdup(bindto); saddr->u.inet->host = g_strdup(bindto);
if (port) { if (port) {
saddr->inet->port = g_strdup(port); saddr->u.inet->port = g_strdup(port);
} else { } else {
saddr->inet->port = g_strdup_printf("%d", NBD_DEFAULT_PORT); saddr->u.inet->port = g_strdup_printf("%d", NBD_DEFAULT_PORT);
} }
} }

44
ui/vnc.c
View File

@ -3524,9 +3524,9 @@ void vnc_display_open(const char *id, Error **errp)
} }
if (strncmp(vnc, "unix:", 5) == 0) { if (strncmp(vnc, "unix:", 5) == 0) {
saddr->kind = SOCKET_ADDRESS_KIND_UNIX; saddr->type = SOCKET_ADDRESS_KIND_UNIX;
saddr->q_unix = g_new0(UnixSocketAddress, 1); saddr->u.q_unix = g_new0(UnixSocketAddress, 1);
saddr->q_unix->path = g_strdup(vnc + 5); saddr->u.q_unix->path = g_strdup(vnc + 5);
if (vs->ws_enabled) { if (vs->ws_enabled) {
error_setg(errp, "UNIX sockets not supported with websock"); error_setg(errp, "UNIX sockets not supported with websock");
@ -3534,12 +3534,12 @@ void vnc_display_open(const char *id, Error **errp)
} }
} else { } else {
unsigned long long baseport; unsigned long long baseport;
saddr->kind = SOCKET_ADDRESS_KIND_INET; saddr->type = SOCKET_ADDRESS_KIND_INET;
saddr->inet = g_new0(InetSocketAddress, 1); saddr->u.inet = g_new0(InetSocketAddress, 1);
if (vnc[0] == '[' && vnc[hlen - 1] == ']') { if (vnc[0] == '[' && vnc[hlen - 1] == ']') {
saddr->inet->host = g_strndup(vnc + 1, hlen - 2); saddr->u.inet->host = g_strndup(vnc + 1, hlen - 2);
} else { } else {
saddr->inet->host = g_strndup(vnc, hlen); saddr->u.inet->host = g_strndup(vnc, hlen);
} }
if (parse_uint_full(h + 1, &baseport, 10) < 0) { if (parse_uint_full(h + 1, &baseport, 10) < 0) {
error_setg(errp, "can't convert to a number: %s", h + 1); error_setg(errp, "can't convert to a number: %s", h + 1);
@ -3550,28 +3550,28 @@ void vnc_display_open(const char *id, Error **errp)
error_setg(errp, "port %s out of range", h + 1); error_setg(errp, "port %s out of range", h + 1);
goto fail; goto fail;
} }
saddr->inet->port = g_strdup_printf( saddr->u.inet->port = g_strdup_printf(
"%d", (int)baseport + 5900); "%d", (int)baseport + 5900);
if (to) { if (to) {
saddr->inet->has_to = true; saddr->u.inet->has_to = true;
saddr->inet->to = to; saddr->u.inet->to = to;
} }
saddr->inet->ipv4 = saddr->inet->has_ipv4 = has_ipv4; saddr->u.inet->ipv4 = saddr->u.inet->has_ipv4 = has_ipv4;
saddr->inet->ipv6 = saddr->inet->has_ipv6 = has_ipv6; saddr->u.inet->ipv6 = saddr->u.inet->has_ipv6 = has_ipv6;
if (vs->ws_enabled) { if (vs->ws_enabled) {
wsaddr->kind = SOCKET_ADDRESS_KIND_INET; wsaddr->type = SOCKET_ADDRESS_KIND_INET;
wsaddr->inet = g_new0(InetSocketAddress, 1); wsaddr->u.inet = g_new0(InetSocketAddress, 1);
wsaddr->inet->host = g_strdup(saddr->inet->host); wsaddr->u.inet->host = g_strdup(saddr->u.inet->host);
wsaddr->inet->port = g_strdup(websocket); wsaddr->u.inet->port = g_strdup(websocket);
if (to) { if (to) {
wsaddr->inet->has_to = true; wsaddr->u.inet->has_to = true;
wsaddr->inet->to = to; wsaddr->u.inet->to = to;
} }
wsaddr->inet->ipv4 = wsaddr->inet->has_ipv4 = has_ipv4; wsaddr->u.inet->ipv4 = wsaddr->u.inet->has_ipv4 = has_ipv4;
wsaddr->inet->ipv6 = wsaddr->inet->has_ipv6 = has_ipv6; wsaddr->u.inet->ipv6 = wsaddr->u.inet->has_ipv6 = has_ipv6;
} }
} }
} else { } else {
@ -3770,7 +3770,7 @@ void vnc_display_open(const char *id, Error **errp)
if (csock < 0) { if (csock < 0) {
goto fail; goto fail;
} }
vs->is_unix = saddr->kind == SOCKET_ADDRESS_KIND_UNIX; vs->is_unix = saddr->type == SOCKET_ADDRESS_KIND_UNIX;
vnc_connect(vs, csock, false, false); vnc_connect(vs, csock, false, false);
} else { } else {
/* listen for connects */ /* listen for connects */
@ -3778,7 +3778,7 @@ void vnc_display_open(const char *id, Error **errp)
if (vs->lsock < 0) { if (vs->lsock < 0) {
goto fail; goto fail;
} }
vs->is_unix = saddr->kind == SOCKET_ADDRESS_KIND_UNIX; vs->is_unix = saddr->type == SOCKET_ADDRESS_KIND_UNIX;
if (vs->ws_enabled) { if (vs->ws_enabled) {
vs->lwebsock = socket_listen(wsaddr, errp); vs->lwebsock = socket_listen(wsaddr, errp);
if (vs->lwebsock < 0) { if (vs->lwebsock < 0) {

60
util/qemu-sockets.c
View File

@ -918,23 +918,23 @@ SocketAddress *socket_parse(const char *str, Error **errp)
error_setg(errp, "invalid Unix socket address"); error_setg(errp, "invalid Unix socket address");
goto fail; goto fail;
} else { } else {
addr->kind = SOCKET_ADDRESS_KIND_UNIX; addr->type = SOCKET_ADDRESS_KIND_UNIX;
addr->q_unix = g_new(UnixSocketAddress, 1); addr->u.q_unix = g_new(UnixSocketAddress, 1);
addr->q_unix->path = g_strdup(str + 5); addr->u.q_unix->path = g_strdup(str + 5);
} }
} else if (strstart(str, "fd:", NULL)) { } else if (strstart(str, "fd:", NULL)) {
if (str[3] == '\0') { if (str[3] == '\0') {
error_setg(errp, "invalid file descriptor address"); error_setg(errp, "invalid file descriptor address");
goto fail; goto fail;
} else { } else {
addr->kind = SOCKET_ADDRESS_KIND_FD; addr->type = SOCKET_ADDRESS_KIND_FD;
addr->fd = g_new(String, 1); addr->u.fd = g_new(String, 1);
addr->fd->str = g_strdup(str + 3); addr->u.fd->str = g_strdup(str + 3);
} }
} else { } else {
addr->kind = SOCKET_ADDRESS_KIND_INET; addr->type = SOCKET_ADDRESS_KIND_INET;
addr->inet = inet_parse(str, errp); addr->u.inet = inet_parse(str, errp);
if (addr->inet == NULL) { if (addr->u.inet == NULL) {
goto fail; goto fail;
} }
} }
@ -952,19 +952,19 @@ int socket_connect(SocketAddress *addr, Error **errp,
int fd; int fd;
opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort); opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
switch (addr->kind) { switch (addr->type) {
case SOCKET_ADDRESS_KIND_INET: case SOCKET_ADDRESS_KIND_INET:
inet_addr_to_opts(opts, addr->inet); inet_addr_to_opts(opts, addr->u.inet);
fd = inet_connect_opts(opts, errp, callback, opaque); fd = inet_connect_opts(opts, errp, callback, opaque);
break; break;
case SOCKET_ADDRESS_KIND_UNIX: case SOCKET_ADDRESS_KIND_UNIX:
qemu_opt_set(opts, "path", addr->q_unix->path, &error_abort); qemu_opt_set(opts, "path", addr->u.q_unix->path, &error_abort);
fd = unix_connect_opts(opts, errp, callback, opaque); fd = unix_connect_opts(opts, errp, callback, opaque);
break; break;
case SOCKET_ADDRESS_KIND_FD: case SOCKET_ADDRESS_KIND_FD:
fd = monitor_get_fd(cur_mon, addr->fd->str, errp); fd = monitor_get_fd(cur_mon, addr->u.fd->str, errp);
if (fd >= 0 && callback) { if (fd >= 0 && callback) {
qemu_set_nonblock(fd); qemu_set_nonblock(fd);
callback(fd, NULL, opaque); callback(fd, NULL, opaque);
@ -984,19 +984,19 @@ int socket_listen(SocketAddress *addr, Error **errp)
int fd; int fd;
opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort); opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
switch (addr->kind) { switch (addr->type) {
case SOCKET_ADDRESS_KIND_INET: case SOCKET_ADDRESS_KIND_INET:
inet_addr_to_opts(opts, addr->inet); inet_addr_to_opts(opts, addr->u.inet);
fd = inet_listen_opts(opts, 0, errp); fd = inet_listen_opts(opts, 0, errp);
break; break;
case SOCKET_ADDRESS_KIND_UNIX: case SOCKET_ADDRESS_KIND_UNIX:
qemu_opt_set(opts, "path", addr->q_unix->path, &error_abort); qemu_opt_set(opts, "path", addr->u.q_unix->path, &error_abort);
fd = unix_listen_opts(opts, errp); fd = unix_listen_opts(opts, errp);
break; break;
case SOCKET_ADDRESS_KIND_FD: case SOCKET_ADDRESS_KIND_FD:
fd = monitor_get_fd(cur_mon, addr->fd->str, errp); fd = monitor_get_fd(cur_mon, addr->u.fd->str, errp);
break; break;
default: default:
@ -1012,12 +1012,12 @@ int socket_dgram(SocketAddress *remote, SocketAddress *local, Error **errp)
int fd; int fd;
opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort); opts = qemu_opts_create(&socket_optslist, NULL, 0, &error_abort);
switch (remote->kind) { switch (remote->type) {
case SOCKET_ADDRESS_KIND_INET: case SOCKET_ADDRESS_KIND_INET:
inet_addr_to_opts(opts, remote->inet); inet_addr_to_opts(opts, remote->u.inet);
if (local) { if (local) {
qemu_opt_set(opts, "localaddr", local->inet->host, &error_abort); qemu_opt_set(opts, "localaddr", local->u.inet->host, &error_abort);
qemu_opt_set(opts, "localport", local->inet->port, &error_abort); qemu_opt_set(opts, "localport", local->u.inet->port, &error_abort);
} }
fd = inet_dgram_opts(opts, errp); fd = inet_dgram_opts(opts, errp);
break; break;
@ -1052,14 +1052,14 @@ socket_sockaddr_to_address_inet(struct sockaddr_storage *sa,
} }
addr = g_new0(SocketAddress, 1); addr = g_new0(SocketAddress, 1);
addr->kind = SOCKET_ADDRESS_KIND_INET; addr->type = SOCKET_ADDRESS_KIND_INET;
addr->inet = g_new0(InetSocketAddress, 1); addr->u.inet = g_new0(InetSocketAddress, 1);
addr->inet->host = g_strdup(host); addr->u.inet->host = g_strdup(host);
addr->inet->port = g_strdup(serv); addr->u.inet->port = g_strdup(serv);
if (sa->ss_family == AF_INET) { if (sa->ss_family == AF_INET) {
addr->inet->has_ipv4 = addr->inet->ipv4 = true; addr->u.inet->has_ipv4 = addr->u.inet->ipv4 = true;
} else { } else {
addr->inet->has_ipv6 = addr->inet->ipv6 = true; addr->u.inet->has_ipv6 = addr->u.inet->ipv6 = true;
} }
return addr; return addr;
@ -1076,10 +1076,10 @@ socket_sockaddr_to_address_unix(struct sockaddr_storage *sa,
struct sockaddr_un *su = (struct sockaddr_un *)sa; struct sockaddr_un *su = (struct sockaddr_un *)sa;
addr = g_new0(SocketAddress, 1); addr = g_new0(SocketAddress, 1);
addr->kind = SOCKET_ADDRESS_KIND_UNIX; addr->type = SOCKET_ADDRESS_KIND_UNIX;
addr->q_unix = g_new0(UnixSocketAddress, 1); addr->u.q_unix = g_new0(UnixSocketAddress, 1);
if (su->sun_path[0]) { if (su->sun_path[0]) {
addr->q_unix->path = g_strndup(su->sun_path, addr->u.q_unix->path = g_strndup(su->sun_path,
sizeof(su->sun_path)); sizeof(su->sun_path));
} }