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