sockin_user.c revision 1.1.10.2
1 1.1.10.2 tls /* $NetBSD: sockin_user.c,v 1.1.10.2 2014/08/20 00:04:43 tls Exp $ */ 2 1.1.10.2 tls 3 1.1.10.2 tls /* 4 1.1.10.2 tls * Copyright (c) 2008 Antti Kantee. All Rights Reserved. 5 1.1.10.2 tls * 6 1.1.10.2 tls * Redistribution and use in source and binary forms, with or without 7 1.1.10.2 tls * modification, are permitted provided that the following conditions 8 1.1.10.2 tls * are met: 9 1.1.10.2 tls * 1. Redistributions of source code must retain the above copyright 10 1.1.10.2 tls * notice, this list of conditions and the following disclaimer. 11 1.1.10.2 tls * 2. Redistributions in binary form must reproduce the above copyright 12 1.1.10.2 tls * notice, this list of conditions and the following disclaimer in the 13 1.1.10.2 tls * documentation and/or other materials provided with the distribution. 14 1.1.10.2 tls * 15 1.1.10.2 tls * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS 16 1.1.10.2 tls * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 1.1.10.2 tls * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 1.1.10.2 tls * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 19 1.1.10.2 tls * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 20 1.1.10.2 tls * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 21 1.1.10.2 tls * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 22 1.1.10.2 tls * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 23 1.1.10.2 tls * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 24 1.1.10.2 tls * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 25 1.1.10.2 tls * SUCH DAMAGE. 26 1.1.10.2 tls */ 27 1.1.10.2 tls 28 1.1.10.2 tls /* for struct msghdr content visibility */ 29 1.1.10.2 tls #define _XOPEN_SOURCE 4 30 1.1.10.2 tls #define _XOPEN_SOURCE_EXTENDED 1 31 1.1.10.2 tls 32 1.1.10.2 tls #ifndef _KERNEL 33 1.1.10.2 tls #include <sys/types.h> 34 1.1.10.2 tls #include <sys/socket.h> 35 1.1.10.2 tls 36 1.1.10.2 tls #include <errno.h> 37 1.1.10.2 tls #include <poll.h> 38 1.1.10.2 tls #include <stdlib.h> 39 1.1.10.2 tls #include <string.h> 40 1.1.10.2 tls #include <stdint.h> 41 1.1.10.2 tls 42 1.1.10.2 tls #include <rump/rumpuser_component.h> 43 1.1.10.2 tls #include <rump/rumpdefs.h> 44 1.1.10.2 tls 45 1.1.10.2 tls #include "sockin_user.h" 46 1.1.10.2 tls 47 1.1.10.2 tls #define seterror(_v_) if ((_v_) == -1) rv = errno; else rv = 0; 48 1.1.10.2 tls 49 1.1.10.2 tls #ifndef __arraycount 50 1.1.10.2 tls #define __arraycount(a) (sizeof(a) / sizeof(*a)) 51 1.1.10.2 tls #endif 52 1.1.10.2 tls 53 1.1.10.2 tls #ifndef __UNCONST 54 1.1.10.2 tls #define __UNCONST(a) ((void*)(const void*)a) 55 1.1.10.2 tls #endif 56 1.1.10.2 tls 57 1.1.10.2 tls #include <netinet/in.h> 58 1.1.10.2 tls #include <netinet/tcp.h> 59 1.1.10.2 tls #include <netinet/udp.h> 60 1.1.10.2 tls 61 1.1.10.2 tls 62 1.1.10.2 tls static int translate_so_sockopt(int); 63 1.1.10.2 tls static int translate_ip_sockopt(int); 64 1.1.10.2 tls static int translate_tcp_sockopt(int); 65 1.1.10.2 tls static int translate_domain(int); 66 1.1.10.2 tls 67 1.1.10.2 tls #define translate(_a_) case RUMP_##_a_: return _a_ 68 1.1.10.2 tls static int 69 1.1.10.2 tls translate_so_sockopt(int lopt) 70 1.1.10.2 tls { 71 1.1.10.2 tls 72 1.1.10.2 tls switch (lopt) { 73 1.1.10.2 tls translate(SO_DEBUG); 74 1.1.10.2 tls #ifndef SO_REUSEPORT 75 1.1.10.2 tls case RUMP_SO_REUSEPORT: return SO_REUSEADDR; 76 1.1.10.2 tls #else 77 1.1.10.2 tls translate(SO_REUSEPORT); 78 1.1.10.2 tls #endif 79 1.1.10.2 tls translate(SO_TYPE); 80 1.1.10.2 tls translate(SO_ERROR); 81 1.1.10.2 tls translate(SO_DONTROUTE); 82 1.1.10.2 tls translate(SO_BROADCAST); 83 1.1.10.2 tls translate(SO_SNDBUF); 84 1.1.10.2 tls translate(SO_RCVBUF); 85 1.1.10.2 tls translate(SO_KEEPALIVE); 86 1.1.10.2 tls translate(SO_OOBINLINE); 87 1.1.10.2 tls translate(SO_LINGER); 88 1.1.10.2 tls default: return -1; 89 1.1.10.2 tls } 90 1.1.10.2 tls } 91 1.1.10.2 tls 92 1.1.10.2 tls static int 93 1.1.10.2 tls translate_ip_sockopt(int lopt) 94 1.1.10.2 tls { 95 1.1.10.2 tls 96 1.1.10.2 tls switch (lopt) { 97 1.1.10.2 tls translate(IP_TOS); 98 1.1.10.2 tls translate(IP_TTL); 99 1.1.10.2 tls translate(IP_HDRINCL); 100 1.1.10.2 tls translate(IP_MULTICAST_TTL); 101 1.1.10.2 tls translate(IP_MULTICAST_LOOP); 102 1.1.10.2 tls translate(IP_MULTICAST_IF); 103 1.1.10.2 tls translate(IP_ADD_MEMBERSHIP); 104 1.1.10.2 tls translate(IP_DROP_MEMBERSHIP); 105 1.1.10.2 tls default: return -1; 106 1.1.10.2 tls } 107 1.1.10.2 tls } 108 1.1.10.2 tls 109 1.1.10.2 tls static int 110 1.1.10.2 tls translate_tcp_sockopt(int lopt) 111 1.1.10.2 tls { 112 1.1.10.2 tls 113 1.1.10.2 tls switch (lopt) { 114 1.1.10.2 tls translate(TCP_NODELAY); 115 1.1.10.2 tls translate(TCP_MAXSEG); 116 1.1.10.2 tls default: return -1; 117 1.1.10.2 tls } 118 1.1.10.2 tls } 119 1.1.10.2 tls 120 1.1.10.2 tls static int 121 1.1.10.2 tls translate_domain(int domain) 122 1.1.10.2 tls { 123 1.1.10.2 tls 124 1.1.10.2 tls switch (domain) { 125 1.1.10.2 tls translate(AF_INET); 126 1.1.10.2 tls translate(AF_INET6); 127 1.1.10.2 tls default: return AF_UNSPEC; 128 1.1.10.2 tls } 129 1.1.10.2 tls } 130 1.1.10.2 tls 131 1.1.10.2 tls #undef translate 132 1.1.10.2 tls 133 1.1.10.2 tls static void 134 1.1.10.2 tls translate_sockopt(int *levelp, int *namep) 135 1.1.10.2 tls { 136 1.1.10.2 tls int level, name; 137 1.1.10.2 tls 138 1.1.10.2 tls level = *levelp; 139 1.1.10.2 tls name = *namep; 140 1.1.10.2 tls 141 1.1.10.2 tls switch (level) { 142 1.1.10.2 tls case RUMP_SOL_SOCKET: 143 1.1.10.2 tls level = SOL_SOCKET; 144 1.1.10.2 tls name = translate_so_sockopt(name); 145 1.1.10.2 tls break; 146 1.1.10.2 tls case RUMP_IPPROTO_IP: 147 1.1.10.2 tls #ifdef SOL_IP 148 1.1.10.2 tls level = SOL_IP; 149 1.1.10.2 tls #else 150 1.1.10.2 tls level = IPPROTO_IP; 151 1.1.10.2 tls #endif 152 1.1.10.2 tls name = translate_ip_sockopt(name); 153 1.1.10.2 tls break; 154 1.1.10.2 tls case RUMP_IPPROTO_TCP: 155 1.1.10.2 tls #ifdef SOL_TCP 156 1.1.10.2 tls level = SOL_TCP; 157 1.1.10.2 tls #else 158 1.1.10.2 tls level = IPPROTO_TCP; 159 1.1.10.2 tls #endif 160 1.1.10.2 tls name = translate_tcp_sockopt(name); 161 1.1.10.2 tls break; 162 1.1.10.2 tls case RUMP_IPPROTO_UDP: 163 1.1.10.2 tls #ifdef SOL_UDP 164 1.1.10.2 tls level = SOL_UDP; 165 1.1.10.2 tls #else 166 1.1.10.2 tls level = IPPROTO_UDP; 167 1.1.10.2 tls #endif 168 1.1.10.2 tls name = -1; 169 1.1.10.2 tls break; 170 1.1.10.2 tls default: 171 1.1.10.2 tls level = -1; 172 1.1.10.2 tls } 173 1.1.10.2 tls *levelp = level; 174 1.1.10.2 tls *namep = name; 175 1.1.10.2 tls } 176 1.1.10.2 tls 177 1.1.10.2 tls #ifndef __NetBSD__ 178 1.1.10.2 tls static const struct { 179 1.1.10.2 tls int bfl; 180 1.1.10.2 tls int lfl; 181 1.1.10.2 tls } bsd_to_native_msg_flags_[] = { 182 1.1.10.2 tls {RUMP_MSG_OOB, MSG_OOB}, 183 1.1.10.2 tls {RUMP_MSG_PEEK, MSG_PEEK}, 184 1.1.10.2 tls {RUMP_MSG_DONTROUTE, MSG_DONTROUTE}, 185 1.1.10.2 tls {RUMP_MSG_EOR, MSG_EOR}, 186 1.1.10.2 tls {RUMP_MSG_TRUNC, MSG_TRUNC}, 187 1.1.10.2 tls {RUMP_MSG_CTRUNC, MSG_CTRUNC}, 188 1.1.10.2 tls {RUMP_MSG_WAITALL, MSG_WAITALL}, 189 1.1.10.2 tls {RUMP_MSG_DONTWAIT, MSG_DONTWAIT}, 190 1.1.10.2 tls 191 1.1.10.2 tls /* might be better to always set NOSIGNAL ... */ 192 1.1.10.2 tls #ifdef MSG_NOSIGNAL 193 1.1.10.2 tls {RUMP_MSG_NOSIGNAL, MSG_NOSIGNAL}, 194 1.1.10.2 tls #endif 195 1.1.10.2 tls }; 196 1.1.10.2 tls 197 1.1.10.2 tls static int native_to_bsd_msg_flags(int); 198 1.1.10.2 tls 199 1.1.10.2 tls static int 200 1.1.10.2 tls native_to_bsd_msg_flags(int lflag) 201 1.1.10.2 tls { 202 1.1.10.2 tls unsigned int i; 203 1.1.10.2 tls int bfl, lfl; 204 1.1.10.2 tls int bflag = 0; 205 1.1.10.2 tls 206 1.1.10.2 tls if (lflag == 0) 207 1.1.10.2 tls return (0); 208 1.1.10.2 tls 209 1.1.10.2 tls for(i = 0; i < __arraycount(bsd_to_native_msg_flags_); i++) { 210 1.1.10.2 tls bfl = bsd_to_native_msg_flags_[i].bfl; 211 1.1.10.2 tls lfl = bsd_to_native_msg_flags_[i].lfl; 212 1.1.10.2 tls 213 1.1.10.2 tls if (lflag & lfl) { 214 1.1.10.2 tls lflag ^= lfl; 215 1.1.10.2 tls bflag |= bfl; 216 1.1.10.2 tls } 217 1.1.10.2 tls } 218 1.1.10.2 tls if (lflag != 0) 219 1.1.10.2 tls return (-1); 220 1.1.10.2 tls 221 1.1.10.2 tls return (bflag); 222 1.1.10.2 tls } 223 1.1.10.2 tls 224 1.1.10.2 tls static int 225 1.1.10.2 tls bsd_to_native_msg_flags(int bflag) 226 1.1.10.2 tls { 227 1.1.10.2 tls unsigned int i; 228 1.1.10.2 tls int lflag = 0; 229 1.1.10.2 tls 230 1.1.10.2 tls if (bflag == 0) 231 1.1.10.2 tls return (0); 232 1.1.10.2 tls 233 1.1.10.2 tls for(i = 0; i < __arraycount(bsd_to_native_msg_flags_); i++) { 234 1.1.10.2 tls if (bflag & bsd_to_native_msg_flags_[i].bfl) 235 1.1.10.2 tls lflag |= bsd_to_native_msg_flags_[i].lfl; 236 1.1.10.2 tls } 237 1.1.10.2 tls 238 1.1.10.2 tls return (lflag); 239 1.1.10.2 tls } 240 1.1.10.2 tls #endif 241 1.1.10.2 tls 242 1.1.10.2 tls struct rump_sockaddr { 243 1.1.10.2 tls uint8_t sa_len; /* total length */ 244 1.1.10.2 tls uint8_t sa_family; /* address family */ 245 1.1.10.2 tls char sa_data[14]; /* actually longer; address value */ 246 1.1.10.2 tls }; 247 1.1.10.2 tls 248 1.1.10.2 tls struct rump_msghdr { 249 1.1.10.2 tls void *msg_name; /* optional address */ 250 1.1.10.2 tls uint32_t msg_namelen; /* size of address */ 251 1.1.10.2 tls struct iovec *msg_iov; /* scatter/gather array */ 252 1.1.10.2 tls int msg_iovlen; /* # elements in msg_iov */ 253 1.1.10.2 tls void *msg_control; /* ancillary data, see below */ 254 1.1.10.2 tls uint32_t msg_controllen; /* ancillary data buffer len */ 255 1.1.10.2 tls int msg_flags; /* flags on received message */ 256 1.1.10.2 tls }; 257 1.1.10.2 tls 258 1.1.10.2 tls static struct sockaddr *translate_sockaddr(const struct sockaddr *, 259 1.1.10.2 tls uint32_t); 260 1.1.10.2 tls static void translate_sockaddr_back(const struct sockaddr *, 261 1.1.10.2 tls struct rump_sockaddr *, uint32_t len); 262 1.1.10.2 tls static struct msghdr *translate_msghdr(const struct rump_msghdr *, int *); 263 1.1.10.2 tls static void translate_msghdr_back(const struct msghdr *, struct rump_msghdr *); 264 1.1.10.2 tls 265 1.1.10.2 tls #if defined(__NetBSD__) 266 1.1.10.2 tls static struct sockaddr * 267 1.1.10.2 tls translate_sockaddr(const struct sockaddr *addr, uint32_t len) 268 1.1.10.2 tls { 269 1.1.10.2 tls 270 1.1.10.2 tls return (struct sockaddr *)__UNCONST(addr); 271 1.1.10.2 tls } 272 1.1.10.2 tls 273 1.1.10.2 tls static void 274 1.1.10.2 tls translate_sockaddr_back(const struct sockaddr *laddr, 275 1.1.10.2 tls struct rump_sockaddr *baddr, uint32_t len) 276 1.1.10.2 tls { 277 1.1.10.2 tls 278 1.1.10.2 tls return; 279 1.1.10.2 tls } 280 1.1.10.2 tls 281 1.1.10.2 tls static struct msghdr * 282 1.1.10.2 tls translate_msghdr(const struct rump_msghdr *bmsg, int *flags) 283 1.1.10.2 tls { 284 1.1.10.2 tls 285 1.1.10.2 tls return (struct msghdr *)__UNCONST(bmsg); 286 1.1.10.2 tls } 287 1.1.10.2 tls 288 1.1.10.2 tls static void 289 1.1.10.2 tls translate_msghdr_back(const struct msghdr *lmsg, struct rump_msghdr *bmsg) 290 1.1.10.2 tls { 291 1.1.10.2 tls 292 1.1.10.2 tls return; 293 1.1.10.2 tls } 294 1.1.10.2 tls 295 1.1.10.2 tls #else 296 1.1.10.2 tls static struct sockaddr * 297 1.1.10.2 tls translate_sockaddr(const struct sockaddr *addr, uint32_t len) 298 1.1.10.2 tls { 299 1.1.10.2 tls struct sockaddr *laddr; 300 1.1.10.2 tls const struct rump_sockaddr *baddr; 301 1.1.10.2 tls 302 1.1.10.2 tls baddr = (const struct rump_sockaddr *)addr; 303 1.1.10.2 tls laddr = malloc(len); 304 1.1.10.2 tls if (laddr == NULL) 305 1.1.10.2 tls return NULL; 306 1.1.10.2 tls memcpy(laddr, baddr, len); 307 1.1.10.2 tls laddr->sa_family = translate_domain(baddr->sa_family); 308 1.1.10.2 tls /* No sa_len for Linux and SunOS */ 309 1.1.10.2 tls #if defined(__DragonFly__) || defined(__FreeBSD__) || defined(__OpenBSD__) 310 1.1.10.2 tls laddr->sa_len = len; 311 1.1.10.2 tls #endif 312 1.1.10.2 tls return laddr; 313 1.1.10.2 tls } 314 1.1.10.2 tls 315 1.1.10.2 tls #define translate_back(_a_) case _a_: return RUMP_##_a_ 316 1.1.10.2 tls static int translate_domain_back(int); 317 1.1.10.2 tls static int 318 1.1.10.2 tls translate_domain_back(int domain) 319 1.1.10.2 tls { 320 1.1.10.2 tls 321 1.1.10.2 tls switch (domain) { 322 1.1.10.2 tls translate_back(AF_INET); 323 1.1.10.2 tls translate_back(AF_INET6); 324 1.1.10.2 tls default: return RUMP_AF_UNSPEC; 325 1.1.10.2 tls } 326 1.1.10.2 tls } 327 1.1.10.2 tls #undef translate_back 328 1.1.10.2 tls 329 1.1.10.2 tls static void 330 1.1.10.2 tls translate_sockaddr_back(const struct sockaddr *laddr, 331 1.1.10.2 tls struct rump_sockaddr *baddr, 332 1.1.10.2 tls uint32_t len) 333 1.1.10.2 tls { 334 1.1.10.2 tls 335 1.1.10.2 tls if (baddr != NULL) { 336 1.1.10.2 tls memcpy(baddr, laddr, len); 337 1.1.10.2 tls baddr->sa_family = translate_domain_back(laddr->sa_family); 338 1.1.10.2 tls baddr->sa_len = len; 339 1.1.10.2 tls } 340 1.1.10.2 tls free(__UNCONST(laddr)); 341 1.1.10.2 tls } 342 1.1.10.2 tls 343 1.1.10.2 tls static struct msghdr * 344 1.1.10.2 tls translate_msghdr(const struct rump_msghdr *bmsg, int *flags) 345 1.1.10.2 tls { 346 1.1.10.2 tls struct msghdr *rv; 347 1.1.10.2 tls 348 1.1.10.2 tls *flags = bsd_to_native_msg_flags(*flags); 349 1.1.10.2 tls if (*flags < 0) 350 1.1.10.2 tls *flags = 0; 351 1.1.10.2 tls 352 1.1.10.2 tls rv = malloc(sizeof(*rv)); 353 1.1.10.2 tls rv->msg_namelen = bmsg->msg_namelen; 354 1.1.10.2 tls rv->msg_iov = bmsg->msg_iov; 355 1.1.10.2 tls rv->msg_iovlen = bmsg->msg_iovlen; 356 1.1.10.2 tls rv->msg_control = bmsg->msg_control; 357 1.1.10.2 tls rv->msg_controllen = bmsg->msg_controllen; 358 1.1.10.2 tls rv->msg_flags = 0; 359 1.1.10.2 tls 360 1.1.10.2 tls if (bmsg->msg_name != NULL) { 361 1.1.10.2 tls rv->msg_name = translate_sockaddr(bmsg->msg_name, 362 1.1.10.2 tls bmsg->msg_namelen); 363 1.1.10.2 tls if (rv->msg_name == NULL) { 364 1.1.10.2 tls free(rv); 365 1.1.10.2 tls return NULL; 366 1.1.10.2 tls } 367 1.1.10.2 tls } else 368 1.1.10.2 tls rv->msg_name = NULL; 369 1.1.10.2 tls return rv; 370 1.1.10.2 tls } 371 1.1.10.2 tls 372 1.1.10.2 tls static void 373 1.1.10.2 tls translate_msghdr_back(const struct msghdr *lmsg, struct rump_msghdr *bmsg) 374 1.1.10.2 tls { 375 1.1.10.2 tls 376 1.1.10.2 tls if (bmsg == NULL) { 377 1.1.10.2 tls if (lmsg->msg_name != NULL) 378 1.1.10.2 tls free(lmsg->msg_name); 379 1.1.10.2 tls free(__UNCONST(lmsg)); 380 1.1.10.2 tls return; 381 1.1.10.2 tls } 382 1.1.10.2 tls bmsg->msg_namelen = lmsg->msg_namelen; 383 1.1.10.2 tls bmsg->msg_iov = lmsg->msg_iov; 384 1.1.10.2 tls bmsg->msg_iovlen = lmsg->msg_iovlen; 385 1.1.10.2 tls bmsg->msg_control = lmsg->msg_control; 386 1.1.10.2 tls bmsg->msg_controllen = lmsg->msg_controllen; 387 1.1.10.2 tls bmsg->msg_flags = native_to_bsd_msg_flags(lmsg->msg_flags); 388 1.1.10.2 tls 389 1.1.10.2 tls if (lmsg->msg_name != NULL) 390 1.1.10.2 tls translate_sockaddr_back(lmsg->msg_name, bmsg->msg_name, 391 1.1.10.2 tls bmsg->msg_namelen); 392 1.1.10.2 tls else 393 1.1.10.2 tls bmsg->msg_name = NULL; 394 1.1.10.2 tls 395 1.1.10.2 tls free(__UNCONST(lmsg)); 396 1.1.10.2 tls } 397 1.1.10.2 tls #endif 398 1.1.10.2 tls 399 1.1.10.2 tls int 400 1.1.10.2 tls rumpcomp_sockin_socket(int domain, int type, int proto, int *s) 401 1.1.10.2 tls { 402 1.1.10.2 tls void *cookie; 403 1.1.10.2 tls int rv; 404 1.1.10.2 tls 405 1.1.10.2 tls domain = translate_domain(domain); 406 1.1.10.2 tls 407 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 408 1.1.10.2 tls *s = socket(domain, type, proto); 409 1.1.10.2 tls seterror(*s); 410 1.1.10.2 tls rumpuser_component_schedule(cookie); 411 1.1.10.2 tls 412 1.1.10.2 tls return rumpuser_component_errtrans(rv); 413 1.1.10.2 tls } 414 1.1.10.2 tls 415 1.1.10.2 tls int 416 1.1.10.2 tls rumpcomp_sockin_sendmsg(int s, const struct msghdr *msg, int flags, size_t *snd) 417 1.1.10.2 tls { 418 1.1.10.2 tls void *cookie; 419 1.1.10.2 tls ssize_t nn; 420 1.1.10.2 tls int rv; 421 1.1.10.2 tls 422 1.1.10.2 tls msg = translate_msghdr((struct rump_msghdr *)msg, &flags); 423 1.1.10.2 tls 424 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 425 1.1.10.2 tls nn = sendmsg(s, msg, flags); 426 1.1.10.2 tls seterror(nn); 427 1.1.10.2 tls *snd = (size_t)nn; 428 1.1.10.2 tls rumpuser_component_schedule(cookie); 429 1.1.10.2 tls 430 1.1.10.2 tls translate_msghdr_back(msg, NULL); 431 1.1.10.2 tls 432 1.1.10.2 tls return rumpuser_component_errtrans(rv); 433 1.1.10.2 tls } 434 1.1.10.2 tls 435 1.1.10.2 tls int 436 1.1.10.2 tls rumpcomp_sockin_recvmsg(int s, struct msghdr *msg, int flags, size_t *rcv) 437 1.1.10.2 tls { 438 1.1.10.2 tls void *cookie; 439 1.1.10.2 tls ssize_t nn; 440 1.1.10.2 tls int rv; 441 1.1.10.2 tls struct rump_msghdr *saveptr; 442 1.1.10.2 tls 443 1.1.10.2 tls saveptr = (struct rump_msghdr *)msg; 444 1.1.10.2 tls msg = translate_msghdr(saveptr, &flags); 445 1.1.10.2 tls 446 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 447 1.1.10.2 tls nn = recvmsg(s, msg, flags); 448 1.1.10.2 tls seterror(nn); 449 1.1.10.2 tls *rcv = (size_t)nn; 450 1.1.10.2 tls rumpuser_component_schedule(cookie); 451 1.1.10.2 tls 452 1.1.10.2 tls translate_msghdr_back(msg, saveptr); 453 1.1.10.2 tls 454 1.1.10.2 tls return rumpuser_component_errtrans(rv); 455 1.1.10.2 tls } 456 1.1.10.2 tls 457 1.1.10.2 tls int 458 1.1.10.2 tls rumpcomp_sockin_connect(int s, const struct sockaddr *name, int len) 459 1.1.10.2 tls { 460 1.1.10.2 tls void *cookie; 461 1.1.10.2 tls int rv; 462 1.1.10.2 tls 463 1.1.10.2 tls name = translate_sockaddr(name, len); 464 1.1.10.2 tls 465 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 466 1.1.10.2 tls rv = connect(s, name, (socklen_t)len); 467 1.1.10.2 tls seterror(rv); 468 1.1.10.2 tls rumpuser_component_schedule(cookie); 469 1.1.10.2 tls 470 1.1.10.2 tls translate_sockaddr_back(name, NULL, len); 471 1.1.10.2 tls 472 1.1.10.2 tls return rumpuser_component_errtrans(rv); 473 1.1.10.2 tls } 474 1.1.10.2 tls 475 1.1.10.2 tls int 476 1.1.10.2 tls rumpcomp_sockin_bind(int s, const struct sockaddr *name, int len) 477 1.1.10.2 tls { 478 1.1.10.2 tls void *cookie; 479 1.1.10.2 tls int rv; 480 1.1.10.2 tls 481 1.1.10.2 tls name = translate_sockaddr(name, len); 482 1.1.10.2 tls 483 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 484 1.1.10.2 tls rv = bind(s, name, (socklen_t)len); 485 1.1.10.2 tls seterror(rv); 486 1.1.10.2 tls rumpuser_component_schedule(cookie); 487 1.1.10.2 tls 488 1.1.10.2 tls translate_sockaddr_back(name, NULL, len); 489 1.1.10.2 tls 490 1.1.10.2 tls return rumpuser_component_errtrans(rv); 491 1.1.10.2 tls } 492 1.1.10.2 tls 493 1.1.10.2 tls int 494 1.1.10.2 tls rumpcomp_sockin_accept(int s, struct sockaddr *name, int *lenp, int *s2) 495 1.1.10.2 tls { 496 1.1.10.2 tls void *cookie; 497 1.1.10.2 tls int rv; 498 1.1.10.2 tls struct rump_sockaddr *saveptr; 499 1.1.10.2 tls 500 1.1.10.2 tls saveptr = (struct rump_sockaddr *)name; 501 1.1.10.2 tls name = translate_sockaddr(name, *lenp); 502 1.1.10.2 tls 503 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 504 1.1.10.2 tls *s2 = accept(s, name, (socklen_t *)lenp); 505 1.1.10.2 tls seterror(*s2); 506 1.1.10.2 tls rumpuser_component_schedule(cookie); 507 1.1.10.2 tls 508 1.1.10.2 tls translate_sockaddr_back(name, saveptr, *lenp); 509 1.1.10.2 tls 510 1.1.10.2 tls return rumpuser_component_errtrans(rv); 511 1.1.10.2 tls } 512 1.1.10.2 tls 513 1.1.10.2 tls int 514 1.1.10.2 tls rumpcomp_sockin_listen(int s, int backlog) 515 1.1.10.2 tls { 516 1.1.10.2 tls void *cookie; 517 1.1.10.2 tls int rv; 518 1.1.10.2 tls 519 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 520 1.1.10.2 tls rv = listen(s, backlog); 521 1.1.10.2 tls seterror(rv); 522 1.1.10.2 tls rumpuser_component_schedule(cookie); 523 1.1.10.2 tls 524 1.1.10.2 tls return rumpuser_component_errtrans(rv); 525 1.1.10.2 tls } 526 1.1.10.2 tls 527 1.1.10.2 tls int 528 1.1.10.2 tls rumpcomp_sockin_getname(int s, struct sockaddr *so, int *lenp, 529 1.1.10.2 tls enum rumpcomp_sockin_getnametype which) 530 1.1.10.2 tls { 531 1.1.10.2 tls socklen_t slen = *lenp; 532 1.1.10.2 tls int rv; 533 1.1.10.2 tls struct rump_sockaddr *saveptr; 534 1.1.10.2 tls 535 1.1.10.2 tls saveptr = (struct rump_sockaddr *)so; 536 1.1.10.2 tls so = translate_sockaddr(so, *lenp); 537 1.1.10.2 tls 538 1.1.10.2 tls if (which == RUMPCOMP_SOCKIN_SOCKNAME) 539 1.1.10.2 tls rv = getsockname(s, so, &slen); 540 1.1.10.2 tls else 541 1.1.10.2 tls rv = getpeername(s, so, &slen); 542 1.1.10.2 tls 543 1.1.10.2 tls seterror(rv); 544 1.1.10.2 tls translate_sockaddr_back(so, saveptr, *lenp); 545 1.1.10.2 tls 546 1.1.10.2 tls *lenp = slen; 547 1.1.10.2 tls 548 1.1.10.2 tls return rumpuser_component_errtrans(rv); 549 1.1.10.2 tls } 550 1.1.10.2 tls 551 1.1.10.2 tls int 552 1.1.10.2 tls rumpcomp_sockin_setsockopt(int s, int level, int name, 553 1.1.10.2 tls const void *data, int dlen) 554 1.1.10.2 tls { 555 1.1.10.2 tls socklen_t slen = dlen; 556 1.1.10.2 tls int rv; 557 1.1.10.2 tls 558 1.1.10.2 tls translate_sockopt(&level, &name); 559 1.1.10.2 tls if (level == -1 || name == -1) { 560 1.1.10.2 tls #ifdef SETSOCKOPT_STRICT 561 1.1.10.2 tls errno = EINVAL; 562 1.1.10.2 tls rv = -1; 563 1.1.10.2 tls #else 564 1.1.10.2 tls rv = 0; 565 1.1.10.2 tls #endif 566 1.1.10.2 tls } else 567 1.1.10.2 tls rv = setsockopt(s, level, name, data, slen); 568 1.1.10.2 tls 569 1.1.10.2 tls seterror(rv); 570 1.1.10.2 tls 571 1.1.10.2 tls return rumpuser_component_errtrans(rv); 572 1.1.10.2 tls } 573 1.1.10.2 tls 574 1.1.10.2 tls int 575 1.1.10.2 tls rumpcomp_sockin_poll(struct pollfd *fds, int nfds, int timeout, int *nready) 576 1.1.10.2 tls { 577 1.1.10.2 tls void *cookie; 578 1.1.10.2 tls int rv; 579 1.1.10.2 tls 580 1.1.10.2 tls cookie = rumpuser_component_unschedule(); 581 1.1.10.2 tls *nready = poll(fds, (nfds_t)nfds, timeout); 582 1.1.10.2 tls seterror(*nready); 583 1.1.10.2 tls rumpuser_component_schedule(cookie); 584 1.1.10.2 tls 585 1.1.10.2 tls return rumpuser_component_errtrans(rv); 586 1.1.10.2 tls } 587 1.1.10.2 tls #endif 588
Indexes created Tue Sep 30 11:09:46 GMT 2025