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