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