io/channel-socket.c

   1 /*
   2  * QEMU I/O channels sockets driver
   3  *
   4  * Copyright (c) 2015 Red Hat, Inc.
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, see <http://www.gnu.org/licenses/>.
  18  *
  19  */
  20
  21 #include "qemu/osdep.h"
  22 #include "qapi/error.h"
  23 #include "qapi/qapi-visit-sockets.h"
  24 #include "io/channel-socket.h"
  25 #include "io/channel-watch.h"
  26 #include "trace.h"
  27 #include "qapi/clone-visitor.h"
  28
  29 #define SOCKET_MAX_FDS 16
  30
  31 SocketAddress *
  32 qio_channel_socket_get_local_address(QIOChannelSocket *ioc,
  33                                      Error **errp)
  34 {
  35     return socket_sockaddr_to_address(&ioc->localAddr,
  36                                       ioc->localAddrLen,
  37                                       errp);
  38 }
  39
  40 SocketAddress *
  41 qio_channel_socket_get_remote_address(QIOChannelSocket *ioc,
  42                                       Error **errp)
  43 {
  44     return socket_sockaddr_to_address(&ioc->remoteAddr,
  45                                       ioc->remoteAddrLen,
  46                                       errp);
  47 }
  48
  49 QIOChannelSocket *
  50 qio_channel_socket_new(void)
  51 {
  52     QIOChannelSocket *sioc;
  53     QIOChannel *ioc;
  54
  55     sioc = QIO_CHANNEL_SOCKET(object_new(TYPE_QIO_CHANNEL_SOCKET));
  56     sioc->fd = -1;
  57
  58     ioc = QIO_CHANNEL(sioc);
  59     qio_channel_set_feature(ioc, QIO_CHANNEL_FEATURE_SHUTDOWN);
  60
  61 #ifdef WIN32
  62     ioc->event = CreateEvent(NULL, FALSE, FALSE, NULL);
  63 #endif
  64
  65     trace_qio_channel_socket_new(sioc);
  66
  67     return sioc;
  68 }
  69
  70
  71 static int
  72 qio_channel_socket_set_fd(QIOChannelSocket *sioc,
  73                           int fd,
  74                           Error **errp)
  75 {
  76     if (sioc->fd != -1) {
  77         error_setg(errp, "Socket is already open");
  78         return -1;
  79     }
  80
  81     sioc->fd = fd;
  82     sioc->remoteAddrLen = sizeof(sioc->remoteAddr);
  83     sioc->localAddrLen = sizeof(sioc->localAddr);
  84
  85
  86     if (getpeername(fd, (struct sockaddr *)&sioc->remoteAddr,
  87                     &sioc->remoteAddrLen) < 0) {
  88         if (errno == ENOTCONN) {
  89             memset(&sioc->remoteAddr, 0, sizeof(sioc->remoteAddr));
  90             sioc->remoteAddrLen = sizeof(sioc->remoteAddr);
  91         } else {
  92             error_setg_errno(errp, errno,
  93                              "Unable to query remote socket address");
  94             goto error;
  95         }
  96     }
  97
  98     if (getsockname(fd, (struct sockaddr *)&sioc->localAddr,
  99                     &sioc->localAddrLen) < 0) {
 100         error_setg_errno(errp, errno,
 101                          "Unable to query local socket address");
 102         goto error;
 103     }
 104
 105 #ifndef WIN32
 106     if (sioc->localAddr.ss_family == AF_UNIX) {
 107         QIOChannel *ioc = QIO_CHANNEL(sioc);
 108         qio_channel_set_feature(ioc, QIO_CHANNEL_FEATURE_FD_PASS);
 109     }
 110 #endif /* WIN32 */
 111
 112     return 0;
 113
 114  error:
 115     sioc->fd = -1; /* Let the caller close FD on failure */
 116     return -1;
 117 }
 118
 119 QIOChannelSocket *
 120 qio_channel_socket_new_fd(int fd,
 121                           Error **errp)
 122 {
 123     QIOChannelSocket *ioc;
 124
 125     ioc = qio_channel_socket_new();
 126     if (qio_channel_socket_set_fd(ioc, fd, errp) < 0) {
 127         object_unref(OBJECT(ioc));
 128         return NULL;
 129     }
 130
 131     trace_qio_channel_socket_new_fd(ioc, fd);
 132
 133     return ioc;
 134 }
 135
 136
 137 int qio_channel_socket_connect_sync(QIOChannelSocket *ioc,
 138                                     SocketAddress *addr,
 139                                     Error **errp)
 140 {
 141     int fd;
 142
 143     trace_qio_channel_socket_connect_sync(ioc, addr);
 144     fd = socket_connect(addr, errp);
 145     if (fd < 0) {
 146         trace_qio_channel_socket_connect_fail(ioc);
 147         return -1;
 148     }
 149
 150     trace_qio_channel_socket_connect_complete(ioc, fd);
 151     if (qio_channel_socket_set_fd(ioc, fd, errp) < 0) {
 152         close(fd);
 153         return -1;
 154     }
 155
 156     return 0;
 157 }
 158
 159
 160 static void qio_channel_socket_connect_worker(QIOTask *task,
 161                                               gpointer opaque)
 162 {
 163     QIOChannelSocket *ioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
 164     SocketAddress *addr = opaque;
 165     Error *err = NULL;
 166
 167     qio_channel_socket_connect_sync(ioc, addr, &err);
 168
 169     qio_task_set_error(task, err);
 170 }
 171
 172
 173 void qio_channel_socket_connect_async(QIOChannelSocket *ioc,
 174                                       SocketAddress *addr,
 175                                       QIOTaskFunc callback,
 176                                       gpointer opaque,
 177                                       GDestroyNotify destroy,
 178                                       GMainContext *context)
 179 {
 180     QIOTask *task = qio_task_new(
 181         OBJECT(ioc), callback, opaque, destroy);
 182     SocketAddress *addrCopy;
 183
 184     addrCopy = QAPI_CLONE(SocketAddress, addr);
 185
 186     /* socket_connect() does a non-blocking connect(), but it
 187      * still blocks in DNS lookups, so we must use a thread */
 188     trace_qio_channel_socket_connect_async(ioc, addr);
 189     qio_task_run_in_thread(task,
 190                            qio_channel_socket_connect_worker,
 191                            addrCopy,
 192                            (GDestroyNotify)qapi_free_SocketAddress,
 193                            context);
 194 }
 195
 196
 197 int qio_channel_socket_listen_sync(QIOChannelSocket *ioc,
 198                                    SocketAddress *addr,
 199                                    Error **errp)
 200 {
 201     int fd;
 202
 203     trace_qio_channel_socket_listen_sync(ioc, addr);
 204     fd = socket_listen(addr, errp);
 205     if (fd < 0) {
 206         trace_qio_channel_socket_listen_fail(ioc);
 207         return -1;
 208     }
 209
 210     trace_qio_channel_socket_listen_complete(ioc, fd);
 211     if (qio_channel_socket_set_fd(ioc, fd, errp) < 0) {
 212         close(fd);
 213         return -1;
 214     }
 215     qio_channel_set_feature(QIO_CHANNEL(ioc), QIO_CHANNEL_FEATURE_LISTEN);
 216
 217     return 0;
 218 }
 219
 220
 221 static void qio_channel_socket_listen_worker(QIOTask *task,
 222                                              gpointer opaque)
 223 {
 224     QIOChannelSocket *ioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
 225     SocketAddress *addr = opaque;
 226     Error *err = NULL;
 227
 228     qio_channel_socket_listen_sync(ioc, addr, &err);
 229
 230     qio_task_set_error(task, err);
 231 }
 232
 233
 234 void qio_channel_socket_listen_async(QIOChannelSocket *ioc,
 235                                      SocketAddress *addr,
 236                                      QIOTaskFunc callback,
 237                                      gpointer opaque,
 238                                      GDestroyNotify destroy,
 239                                      GMainContext *context)
 240 {
 241     QIOTask *task = qio_task_new(
 242         OBJECT(ioc), callback, opaque, destroy);
 243     SocketAddress *addrCopy;
 244
 245     addrCopy = QAPI_CLONE(SocketAddress, addr);
 246
 247     /* socket_listen() blocks in DNS lookups, so we must use a thread */
 248     trace_qio_channel_socket_listen_async(ioc, addr);
 249     qio_task_run_in_thread(task,
 250                            qio_channel_socket_listen_worker,
 251                            addrCopy,
 252                            (GDestroyNotify)qapi_free_SocketAddress,
 253                            context);
 254 }
 255
 256
 257 int qio_channel_socket_dgram_sync(QIOChannelSocket *ioc,
 258                                   SocketAddress *localAddr,
 259                                   SocketAddress *remoteAddr,
 260                                   Error **errp)
 261 {
 262     int fd;
 263
 264     trace_qio_channel_socket_dgram_sync(ioc, localAddr, remoteAddr);
 265     fd = socket_dgram(remoteAddr, localAddr, errp);
 266     if (fd < 0) {
 267         trace_qio_channel_socket_dgram_fail(ioc);
 268         return -1;
 269     }
 270
 271     trace_qio_channel_socket_dgram_complete(ioc, fd);
 272     if (qio_channel_socket_set_fd(ioc, fd, errp) < 0) {
 273         close(fd);
 274         return -1;
 275     }
 276
 277     return 0;
 278 }
 279
 280
 281 struct QIOChannelSocketDGramWorkerData {
 282     SocketAddress *localAddr;
 283     SocketAddress *remoteAddr;
 284 };
 285
 286
 287 static void qio_channel_socket_dgram_worker_free(gpointer opaque)
 288 {
 289     struct QIOChannelSocketDGramWorkerData *data = opaque;
 290     qapi_free_SocketAddress(data->localAddr);
 291     qapi_free_SocketAddress(data->remoteAddr);
 292     g_free(data);
 293 }
 294
 295 static void qio_channel_socket_dgram_worker(QIOTask *task,
 296                                             gpointer opaque)
 297 {
 298     QIOChannelSocket *ioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
 299     struct QIOChannelSocketDGramWorkerData *data = opaque;
 300     Error *err = NULL;
 301
 302     /* socket_dgram() blocks in DNS lookups, so we must use a thread */
 303     qio_channel_socket_dgram_sync(ioc, data->localAddr,
 304                                   data->remoteAddr, &err);
 305
 306     qio_task_set_error(task, err);
 307 }
 308
 309
 310 void qio_channel_socket_dgram_async(QIOChannelSocket *ioc,
 311                                     SocketAddress *localAddr,
 312                                     SocketAddress *remoteAddr,
 313                                     QIOTaskFunc callback,
 314                                     gpointer opaque,
 315                                     GDestroyNotify destroy,
 316                                     GMainContext *context)
 317 {
 318     QIOTask *task = qio_task_new(
 319         OBJECT(ioc), callback, opaque, destroy);
 320     struct QIOChannelSocketDGramWorkerData *data = g_new0(
 321         struct QIOChannelSocketDGramWorkerData, 1);
 322
 323     data->localAddr = QAPI_CLONE(SocketAddress, localAddr);
 324     data->remoteAddr = QAPI_CLONE(SocketAddress, remoteAddr);
 325
 326     trace_qio_channel_socket_dgram_async(ioc, localAddr, remoteAddr);
 327     qio_task_run_in_thread(task,
 328                            qio_channel_socket_dgram_worker,
 329                            data,
 330                            qio_channel_socket_dgram_worker_free,
 331                            context);
 332 }
 333
 334
 335 QIOChannelSocket *
 336 qio_channel_socket_accept(QIOChannelSocket *ioc,
 337                           Error **errp)
 338 {
 339     QIOChannelSocket *cioc;
 340
 341     cioc = qio_channel_socket_new();
 342     cioc->remoteAddrLen = sizeof(ioc->remoteAddr);
 343     cioc->localAddrLen = sizeof(ioc->localAddr);
 344
 345  retry:
 346     trace_qio_channel_socket_accept(ioc);
 347     cioc->fd = qemu_accept(ioc->fd, (struct sockaddr *)&cioc->remoteAddr,
 348                            &cioc->remoteAddrLen);
 349     if (cioc->fd < 0) {
 350         if (errno == EINTR) {
 351             goto retry;
 352         }
 353         error_setg_errno(errp, errno, "Unable to accept connection");
 354         trace_qio_channel_socket_accept_fail(ioc);
 355         goto error;
 356     }
 357
 358     if (getsockname(cioc->fd, (struct sockaddr *)&cioc->localAddr,
 359                     &cioc->localAddrLen) < 0) {
 360         error_setg_errno(errp, errno,
 361                          "Unable to query local socket address");
 362         goto error;
 363     }
 364
 365 #ifndef WIN32
 366     if (cioc->localAddr.ss_family == AF_UNIX) {
 367         QIOChannel *ioc_local = QIO_CHANNEL(cioc);
 368         qio_channel_set_feature(ioc_local, QIO_CHANNEL_FEATURE_FD_PASS);
 369     }
 370 #endif /* WIN32 */
 371
 372     trace_qio_channel_socket_accept_complete(ioc, cioc, cioc->fd);
 373     return cioc;
 374
 375  error:
 376     object_unref(OBJECT(cioc));
 377     return NULL;
 378 }
 379
 380 static void qio_channel_socket_init(Object *obj)
 381 {
 382     QIOChannelSocket *ioc = QIO_CHANNEL_SOCKET(obj);
 383     ioc->fd = -1;
 384 }
 385
 386 static void qio_channel_socket_finalize(Object *obj)
 387 {
 388     QIOChannelSocket *ioc = QIO_CHANNEL_SOCKET(obj);
 389
 390     if (ioc->fd != -1) {
 391         QIOChannel *ioc_local = QIO_CHANNEL(ioc);
 392         if (qio_channel_has_feature(ioc_local, QIO_CHANNEL_FEATURE_LISTEN)) {
 393             Error *err = NULL;
 394
 395             socket_listen_cleanup(ioc->fd, &err);
 396             if (err) {
 397                 error_report_err(err);
 398                 err = NULL;
 399             }
 400         }
 401 #ifdef WIN32
 402         WSAEventSelect(ioc->fd, NULL, 0);
 403 #endif
 404         closesocket(ioc->fd);
 405         ioc->fd = -1;
 406     }
 407 }
 408
 409
 410 #ifndef WIN32
 411 static void qio_channel_socket_copy_fds(struct msghdr *msg,
 412                                         int **fds, size_t *nfds)
 413 {
 414     struct cmsghdr *cmsg;
 415
 416     *nfds = 0;
 417     *fds = NULL;
 418
 419     for (cmsg = CMSG_FIRSTHDR(msg); cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) {
 420         int fd_size, i;
 421         int gotfds;
 422
 423         if (cmsg->cmsg_len < CMSG_LEN(sizeof(int)) ||
 424             cmsg->cmsg_level != SOL_SOCKET ||
 425             cmsg->cmsg_type != SCM_RIGHTS) {
 426             continue;
 427         }
 428
 429         fd_size = cmsg->cmsg_len - CMSG_LEN(0);
 430
 431         if (!fd_size) {
 432             continue;
 433         }
 434
 435         gotfds = fd_size / sizeof(int);
 436         *fds = g_renew(int, *fds, *nfds + gotfds);
 437         memcpy(*fds + *nfds, CMSG_DATA(cmsg), fd_size);
 438
 439         for (i = 0; i < gotfds; i++) {
 440             int fd = (*fds)[*nfds + i];
 441             if (fd < 0) {
 442                 continue;
 443             }
 444
 445             /* O_NONBLOCK is preserved across SCM_RIGHTS so reset it */
 446             qemu_set_block(fd);
 447
 448 #ifndef MSG_CMSG_CLOEXEC
 449             qemu_set_cloexec(fd);
 450 #endif
 451         }
 452         *nfds += gotfds;
 453     }
 454 }
 455
 456
 457 static ssize_t qio_channel_socket_readv(QIOChannel *ioc,
 458                                         const struct iovec *iov,
 459                                         size_t niov,
 460                                         int **fds,
 461                                         size_t *nfds,
 462                                         Error **errp)
 463 {
 464     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 465     ssize_t ret;
 466     struct msghdr msg = { NULL, };
 467     char control[CMSG_SPACE(sizeof(int) * SOCKET_MAX_FDS)];
 468     int sflags = 0;
 469
 470     memset(control, 0, CMSG_SPACE(sizeof(int) * SOCKET_MAX_FDS));
 471
 472 #ifdef MSG_CMSG_CLOEXEC
 473     sflags |= MSG_CMSG_CLOEXEC;
 474 #endif
 475
 476     msg.msg_iov = (struct iovec *)iov;
 477     msg.msg_iovlen = niov;
 478     if (fds && nfds) {
 479         msg.msg_control = control;
 480         msg.msg_controllen = sizeof(control);
 481     }
 482
 483  retry:
 484     ret = recvmsg(sioc->fd, &msg, sflags);
 485     if (ret < 0) {
 486         if (errno == EAGAIN) {
 487             return QIO_CHANNEL_ERR_BLOCK;
 488         }
 489         if (errno == EINTR) {
 490             goto retry;
 491         }
 492
 493         error_setg_errno(errp, errno,
 494                          "Unable to read from socket");
 495         return -1;
 496     }
 497
 498     if (fds && nfds) {
 499         qio_channel_socket_copy_fds(&msg, fds, nfds);
 500     }
 501
 502     return ret;
 503 }
 504
 505 static ssize_t qio_channel_socket_writev(QIOChannel *ioc,
 506                                          const struct iovec *iov,
 507                                          size_t niov,
 508                                          int *fds,
 509                                          size_t nfds,
 510                                          Error **errp)
 511 {
 512     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 513     ssize_t ret;
 514     struct msghdr msg = { NULL, };
 515     char control[CMSG_SPACE(sizeof(int) * SOCKET_MAX_FDS)];
 516     size_t fdsize = sizeof(int) * nfds;
 517     struct cmsghdr *cmsg;
 518
 519     memset(control, 0, CMSG_SPACE(sizeof(int) * SOCKET_MAX_FDS));
 520
 521     msg.msg_iov = (struct iovec *)iov;
 522     msg.msg_iovlen = niov;
 523
 524     if (nfds) {
 525         if (nfds > SOCKET_MAX_FDS) {
 526             error_setg_errno(errp, EINVAL,
 527                              "Only %d FDs can be sent, got %zu",
 528                              SOCKET_MAX_FDS, nfds);
 529             return -1;
 530         }
 531
 532         msg.msg_control = control;
 533         msg.msg_controllen = CMSG_SPACE(sizeof(int) * nfds);
 534
 535         cmsg = CMSG_FIRSTHDR(&msg);
 536         cmsg->cmsg_len = CMSG_LEN(fdsize);
 537         cmsg->cmsg_level = SOL_SOCKET;
 538         cmsg->cmsg_type = SCM_RIGHTS;
 539         memcpy(CMSG_DATA(cmsg), fds, fdsize);
 540     }
 541
 542  retry:
 543     ret = sendmsg(sioc->fd, &msg, 0);
 544     if (ret <= 0) {
 545         if (errno == EAGAIN) {
 546             return QIO_CHANNEL_ERR_BLOCK;
 547         }
 548         if (errno == EINTR) {
 549             goto retry;
 550         }
 551         error_setg_errno(errp, errno,
 552                          "Unable to write to socket");
 553         return -1;
 554     }
 555     return ret;
 556 }
 557 #else /* WIN32 */
 558 static ssize_t qio_channel_socket_readv(QIOChannel *ioc,
 559                                         const struct iovec *iov,
 560                                         size_t niov,
 561                                         int **fds,
 562                                         size_t *nfds,
 563                                         Error **errp)
 564 {
 565     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 566     ssize_t done = 0;
 567     ssize_t i;
 568
 569     for (i = 0; i < niov; i++) {
 570         ssize_t ret;
 571     retry:
 572         ret = recv(sioc->fd,
 573                    iov[i].iov_base,
 574                    iov[i].iov_len,
 575                    0);
 576         if (ret < 0) {
 577             if (errno == EAGAIN) {
 578                 if (done) {
 579                     return done;
 580                 } else {
 581                     return QIO_CHANNEL_ERR_BLOCK;
 582                 }
 583             } else if (errno == EINTR) {
 584                 goto retry;
 585             } else {
 586                 error_setg_errno(errp, errno,
 587                                  "Unable to read from socket");
 588                 return -1;
 589             }
 590         }
 591         done += ret;
 592         if (ret < iov[i].iov_len) {
 593             return done;
 594         }
 595     }
 596
 597     return done;
 598 }
 599
 600 static ssize_t qio_channel_socket_writev(QIOChannel *ioc,
 601                                          const struct iovec *iov,
 602                                          size_t niov,
 603                                          int *fds,
 604                                          size_t nfds,
 605                                          Error **errp)
 606 {
 607     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 608     ssize_t done = 0;
 609     ssize_t i;
 610
 611     for (i = 0; i < niov; i++) {
 612         ssize_t ret;
 613     retry:
 614         ret = send(sioc->fd,
 615                    iov[i].iov_base,
 616                    iov[i].iov_len,
 617                    0);
 618         if (ret < 0) {
 619             if (errno == EAGAIN) {
 620                 if (done) {
 621                     return done;
 622                 } else {
 623                     return QIO_CHANNEL_ERR_BLOCK;
 624                 }
 625             } else if (errno == EINTR) {
 626                 goto retry;
 627             } else {
 628                 error_setg_errno(errp, errno,
 629                                  "Unable to write to socket");
 630                 return -1;
 631             }
 632         }
 633         done += ret;
 634         if (ret < iov[i].iov_len) {
 635             return done;
 636         }
 637     }
 638
 639     return done;
 640 }
 641 #endif /* WIN32 */
 642
 643 static int
 644 qio_channel_socket_set_blocking(QIOChannel *ioc,
 645                                 bool enabled,
 646                                 Error **errp)
 647 {
 648     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 649
 650     if (enabled) {
 651         qemu_set_block(sioc->fd);
 652     } else {
 653         qemu_set_nonblock(sioc->fd);
 654     }
 655     return 0;
 656 }
 657
 658
 659 static void
 660 qio_channel_socket_set_delay(QIOChannel *ioc,
 661                              bool enabled)
 662 {
 663     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 664     int v = enabled ? 0 : 1;
 665
 666     qemu_setsockopt(sioc->fd,
 667                     IPPROTO_TCP, TCP_NODELAY,
 668                     &v, sizeof(v));
 669 }
 670
 671
 672 static void
 673 qio_channel_socket_set_cork(QIOChannel *ioc,
 674                             bool enabled)
 675 {
 676     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 677     int v = enabled ? 1 : 0;
 678
 679     socket_set_cork(sioc->fd, v);
 680 }
 681
 682
 683 static int
 684 qio_channel_socket_close(QIOChannel *ioc,
 685                          Error **errp)
 686 {
 687     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 688     int rc = 0;
 689
 690     if (sioc->fd != -1) {
 691 #ifdef WIN32
 692         WSAEventSelect(sioc->fd, NULL, 0);
 693 #endif
 694         if (qio_channel_has_feature(ioc, QIO_CHANNEL_FEATURE_LISTEN)) {
 695             socket_listen_cleanup(sioc->fd, errp);
 696         }
 697
 698         if (closesocket(sioc->fd) < 0) {
 699             sioc->fd = -1;
 700             error_setg_errno(errp, errno,
 701                              "Unable to close socket");
 702             return -1;
 703         }
 704         sioc->fd = -1;
 705     }
 706     return rc;
 707 }
 708
 709 static int
 710 qio_channel_socket_shutdown(QIOChannel *ioc,
 711                             QIOChannelShutdown how,
 712                             Error **errp)
 713 {
 714     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 715     int sockhow;
 716
 717     switch (how) {
 718     case QIO_CHANNEL_SHUTDOWN_READ:
 719         sockhow = SHUT_RD;
 720         break;
 721     case QIO_CHANNEL_SHUTDOWN_WRITE:
 722         sockhow = SHUT_WR;
 723         break;
 724     case QIO_CHANNEL_SHUTDOWN_BOTH:
 725     default:
 726         sockhow = SHUT_RDWR;
 727         break;
 728     }
 729
 730     if (shutdown(sioc->fd, sockhow) < 0) {
 731         error_setg_errno(errp, errno,
 732                          "Unable to shutdown socket");
 733         return -1;
 734     }
 735     return 0;
 736 }
 737
 738 static void qio_channel_socket_set_aio_fd_handler(QIOChannel *ioc,
 739                                                   AioContext *ctx,
 740                                                   IOHandler *io_read,
 741                                                   IOHandler *io_write,
 742                                                   void *opaque)
 743 {
 744     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 745     aio_set_fd_handler(ctx, sioc->fd, false, io_read, io_write, NULL, opaque);
 746 }
 747
 748 static GSource *qio_channel_socket_create_watch(QIOChannel *ioc,
 749                                                 GIOCondition condition)
 750 {
 751     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(ioc);
 752     return qio_channel_create_socket_watch(ioc,
 753                                            sioc->fd,
 754                                            condition);
 755 }
 756
 757 static void qio_channel_socket_class_init(ObjectClass *klass,
 758                                           void *class_data G_GNUC_UNUSED)
 759 {
 760     QIOChannelClass *ioc_klass = QIO_CHANNEL_CLASS(klass);
 761
 762     ioc_klass->io_writev = qio_channel_socket_writev;
 763     ioc_klass->io_readv = qio_channel_socket_readv;
 764     ioc_klass->io_set_blocking = qio_channel_socket_set_blocking;
 765     ioc_klass->io_close = qio_channel_socket_close;
 766     ioc_klass->io_shutdown = qio_channel_socket_shutdown;
 767     ioc_klass->io_set_cork = qio_channel_socket_set_cork;
 768     ioc_klass->io_set_delay = qio_channel_socket_set_delay;
 769     ioc_klass->io_create_watch = qio_channel_socket_create_watch;
 770     ioc_klass->io_set_aio_fd_handler = qio_channel_socket_set_aio_fd_handler;
 771 }
 772
 773 static const TypeInfo qio_channel_socket_info = {
 774     .parent = TYPE_QIO_CHANNEL,
 775     .name = TYPE_QIO_CHANNEL_SOCKET,
 776     .instance_size = sizeof(QIOChannelSocket),
 777     .instance_init = qio_channel_socket_init,
 778     .instance_finalize = qio_channel_socket_finalize,
 779     .class_init = qio_channel_socket_class_init,
 780 };
 781
 782 static void qio_channel_socket_register_types(void)
 783 {
 784     type_register_static(&qio_channel_socket_info);
 785 }
 786
 787 type_init(qio_channel_socket_register_types);