rumpuser_sp.c revision 1.75 1 /* $NetBSD: rumpuser_sp.c,v 1.75 2020/03/24 14:56:31 kre Exp $ */
2
3 /*
4 * Copyright (c) 2010, 2011 Antti Kantee. All Rights Reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 * 1. Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * 2. Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 *
15 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
16 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
17 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
18 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
21 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25 * SUCH DAMAGE.
26 */
27
28 /*
29 * Sysproxy routines. This provides system RPC support over host sockets.
30 * The most notable limitation is that the client and server must share
31 * the same ABI. This does not mean that they have to be the same
32 * machine or that they need to run the same version of the host OS,
33 * just that they must agree on the data structures. This even *might*
34 * work correctly from one hardware architecture to another.
35 */
36
37 #include "rumpuser_port.h"
38
39 #if !defined(lint)
40 __RCSID("$NetBSD: rumpuser_sp.c,v 1.75 2020/03/24 14:56:31 kre Exp $");
41 #endif /* !lint */
42
43 #include <sys/types.h>
44 #include <sys/mman.h>
45 #include <sys/socket.h>
46
47 #include <arpa/inet.h>
48 #include <netinet/in.h>
49 #include <netinet/tcp.h>
50
51 #include <assert.h>
52 #include <errno.h>
53 #include <fcntl.h>
54 #include <poll.h>
55 #include <pthread.h>
56 #include <stdarg.h>
57 #include <stdio.h>
58 #include <stdlib.h>
59 #include <string.h>
60 #include <unistd.h>
61
62 #include <rump/rump.h> /* XXX: for rfork flags */
63 #include <rump/rumpuser.h>
64
65 #include "rumpuser_int.h"
66
67 #include "sp_common.c"
68
69 #ifndef MAXCLI
70 #define MAXCLI 256
71 #endif
72 #ifndef MAXWORKER
73 #define MAXWORKER 128
74 #endif
75 #ifndef IDLEWORKER
76 #define IDLEWORKER 16
77 #endif
78 int rumpsp_maxworker = MAXWORKER;
79 int rumpsp_idleworker = IDLEWORKER;
80
81 static struct pollfd pfdlist[MAXCLI];
82 static struct spclient spclist[MAXCLI];
83 static unsigned int disco;
84 static volatile int spfini;
85
86 static char banner[MAXBANNER];
87
88 #define PROTOMAJOR 0
89 #define PROTOMINOR 4
90
91
92 /* either no atomic ops, or we haven't figured out how to use them */
93 #if defined(__linux__) || defined(__APPLE__) || defined(__CYGWIN__) || defined(__OpenBSD__) || defined(__GNU__) || defined(__GLIBC__)
94 static pthread_mutex_t discomtx = PTHREAD_MUTEX_INITIALIZER;
95
96 static void
97 signaldisco(void)
98 {
99
100 pthread_mutex_lock(&discomtx);
101 disco++;
102 pthread_mutex_unlock(&discomtx);
103 }
104
105 static unsigned int
106 getdisco(void)
107 {
108 unsigned int discocnt;
109
110 pthread_mutex_lock(&discomtx);
111 discocnt = disco;
112 disco = 0;
113 pthread_mutex_unlock(&discomtx);
114
115 return discocnt;
116 }
117
118 #elif defined(__FreeBSD__) || defined(__DragonFly__)
119
120 #include <machine/atomic.h>
121 #define signaldisco() atomic_add_int(&disco, 1)
122 #define getdisco() atomic_readandclear_int(&disco)
123
124 #else /* NetBSD */
125
126 #include <sys/atomic.h>
127 #define signaldisco() atomic_inc_uint(&disco)
128 #define getdisco() atomic_swap_uint(&disco, 0)
129
130 #endif
131
132
133 struct prefork {
134 uint32_t pf_auth[AUTHLEN];
135 struct lwp *pf_lwp;
136
137 LIST_ENTRY(prefork) pf_entries; /* global list */
138 LIST_ENTRY(prefork) pf_spcentries; /* linked from forking spc */
139 };
140 static LIST_HEAD(, prefork) preforks = LIST_HEAD_INITIALIZER(preforks);
141 static pthread_mutex_t pfmtx;
142
143 /*
144 * This version is for the server. It's optimized for multiple threads
145 * and is *NOT* reentrant wrt to signals.
146 */
147 static int
148 waitresp(struct spclient *spc, struct respwait *rw)
149 {
150 int spcstate;
151 int rv = 0;
152
153 pthread_mutex_lock(&spc->spc_mtx);
154 sendunlockl(spc);
155 while (!rw->rw_done && spc->spc_state != SPCSTATE_DYING) {
156 pthread_cond_wait(&rw->rw_cv, &spc->spc_mtx);
157 }
158 TAILQ_REMOVE(&spc->spc_respwait, rw, rw_entries);
159 spcstate = spc->spc_state;
160 pthread_mutex_unlock(&spc->spc_mtx);
161
162 pthread_cond_destroy(&rw->rw_cv);
163
164 if (rv)
165 return rv;
166 if (spcstate == SPCSTATE_DYING)
167 return ENOTCONN;
168 return rw->rw_error;
169 }
170
171 /*
172 * Manual wrappers, since librump does not have access to the
173 * user namespace wrapped interfaces.
174 */
175
176 static void
177 lwproc_switch(struct lwp *l)
178 {
179
180 rumpuser__hyp.hyp_schedule();
181 rumpuser__hyp.hyp_lwproc_switch(l);
182 rumpuser__hyp.hyp_unschedule();
183 }
184
185 static void
186 lwproc_release(void)
187 {
188
189 rumpuser__hyp.hyp_schedule();
190 rumpuser__hyp.hyp_lwproc_release();
191 rumpuser__hyp.hyp_unschedule();
192 }
193
194 static int
195 lwproc_rfork(struct spclient *spc, int flags, const char *comm)
196 {
197 int rv;
198
199 rumpuser__hyp.hyp_schedule();
200 rv = rumpuser__hyp.hyp_lwproc_rfork(spc, flags, comm);
201 rumpuser__hyp.hyp_unschedule();
202
203 return rv;
204 }
205
206 static int
207 lwproc_newlwp(pid_t pid)
208 {
209 int rv;
210
211 rumpuser__hyp.hyp_schedule();
212 rv = rumpuser__hyp.hyp_lwproc_newlwp(pid);
213 rumpuser__hyp.hyp_unschedule();
214
215 return rv;
216 }
217
218 static struct lwp *
219 lwproc_curlwp(void)
220 {
221 struct lwp *l;
222
223 rumpuser__hyp.hyp_schedule();
224 l = rumpuser__hyp.hyp_lwproc_curlwp();
225 rumpuser__hyp.hyp_unschedule();
226
227 return l;
228 }
229
230 static pid_t
231 lwproc_getpid(void)
232 {
233 pid_t p;
234
235 rumpuser__hyp.hyp_schedule();
236 p = rumpuser__hyp.hyp_getpid();
237 rumpuser__hyp.hyp_unschedule();
238
239 return p;
240 }
241
242 static void
243 lwproc_execnotify(const char *comm)
244 {
245
246 rumpuser__hyp.hyp_schedule();
247 rumpuser__hyp.hyp_execnotify(comm);
248 rumpuser__hyp.hyp_unschedule();
249 }
250
251 static void
252 lwproc_lwpexit(void)
253 {
254
255 rumpuser__hyp.hyp_schedule();
256 rumpuser__hyp.hyp_lwpexit();
257 rumpuser__hyp.hyp_unschedule();
258 }
259
260 static int
261 rumpsyscall(int sysnum, void *data, register_t *regrv)
262 {
263 long retval[2] = {0, 0};
264 int rv;
265
266 rumpuser__hyp.hyp_schedule();
267 rv = rumpuser__hyp.hyp_syscall(sysnum, data, retval);
268 rumpuser__hyp.hyp_unschedule();
269
270 regrv[0] = retval[0];
271 regrv[1] = retval[1];
272 return rv;
273 }
274
275 static uint64_t
276 nextreq(struct spclient *spc)
277 {
278 uint64_t nw;
279
280 pthread_mutex_lock(&spc->spc_mtx);
281 nw = spc->spc_nextreq++;
282 pthread_mutex_unlock(&spc->spc_mtx);
283
284 return nw;
285 }
286
287 /*
288 * XXX: we send responses with "blocking" I/O. This is not
289 * ok for the main thread. XXXFIXME
290 */
291
292 static void
293 send_error_resp(struct spclient *spc, uint64_t reqno, enum rumpsp_err error)
294 {
295 struct rsp_hdr rhdr;
296 struct iovec iov[1];
297
298 rhdr.rsp_len = sizeof(rhdr);
299 rhdr.rsp_reqno = reqno;
300 rhdr.rsp_class = RUMPSP_ERROR;
301 rhdr.rsp_type = 0;
302 rhdr.rsp_error = error;
303
304 IOVPUT(iov[0], rhdr);
305
306 sendlock(spc);
307 (void)SENDIOV(spc, iov);
308 sendunlock(spc);
309 }
310
311 static int
312 send_handshake_resp(struct spclient *spc, uint64_t reqno, int error)
313 {
314 struct rsp_hdr rhdr;
315 struct iovec iov[2];
316 int rv;
317
318 rhdr.rsp_len = sizeof(rhdr) + sizeof(error);
319 rhdr.rsp_reqno = reqno;
320 rhdr.rsp_class = RUMPSP_RESP;
321 rhdr.rsp_type = RUMPSP_HANDSHAKE;
322 rhdr.rsp_error = 0;
323
324 IOVPUT(iov[0], rhdr);
325 IOVPUT(iov[1], error);
326
327 sendlock(spc);
328 rv = SENDIOV(spc, iov);
329 sendunlock(spc);
330
331 return rv;
332 }
333
334 static int
335 send_syscall_resp(struct spclient *spc, uint64_t reqno, int error,
336 register_t *retval)
337 {
338 struct rsp_hdr rhdr;
339 struct rsp_sysresp sysresp;
340 struct iovec iov[2];
341 int rv;
342
343 rhdr.rsp_len = sizeof(rhdr) + sizeof(sysresp);
344 rhdr.rsp_reqno = reqno;
345 rhdr.rsp_class = RUMPSP_RESP;
346 rhdr.rsp_type = RUMPSP_SYSCALL;
347 rhdr.rsp_sysnum = 0;
348
349 sysresp.rsys_error = error;
350 memcpy(sysresp.rsys_retval, retval, sizeof(sysresp.rsys_retval));
351
352 IOVPUT(iov[0], rhdr);
353 IOVPUT(iov[1], sysresp);
354
355 sendlock(spc);
356 rv = SENDIOV(spc, iov);
357 sendunlock(spc);
358
359 return rv;
360 }
361
362 static int
363 send_prefork_resp(struct spclient *spc, uint64_t reqno, uint32_t *auth)
364 {
365 struct rsp_hdr rhdr;
366 struct iovec iov[2];
367 int rv;
368
369 rhdr.rsp_len = sizeof(rhdr) + AUTHLEN*sizeof(*auth);
370 rhdr.rsp_reqno = reqno;
371 rhdr.rsp_class = RUMPSP_RESP;
372 rhdr.rsp_type = RUMPSP_PREFORK;
373 rhdr.rsp_sysnum = 0;
374
375 IOVPUT(iov[0], rhdr);
376 IOVPUT_WITHSIZE(iov[1], auth, AUTHLEN*sizeof(*auth));
377
378 sendlock(spc);
379 rv = SENDIOV(spc, iov);
380 sendunlock(spc);
381
382 return rv;
383 }
384
385 static int
386 copyin_req(struct spclient *spc, const void *remaddr, size_t *dlen,
387 int wantstr, void **resp)
388 {
389 struct rsp_hdr rhdr;
390 struct rsp_copydata copydata;
391 struct respwait rw;
392 struct iovec iov[2];
393 int rv;
394
395 DPRINTF(("copyin_req: %zu bytes from %p\n", *dlen, remaddr));
396
397 rhdr.rsp_len = sizeof(rhdr) + sizeof(copydata);
398 rhdr.rsp_class = RUMPSP_REQ;
399 if (wantstr)
400 rhdr.rsp_type = RUMPSP_COPYINSTR;
401 else
402 rhdr.rsp_type = RUMPSP_COPYIN;
403 rhdr.rsp_sysnum = 0;
404
405 copydata.rcp_addr = __UNCONST(remaddr);
406 copydata.rcp_len = *dlen;
407
408 IOVPUT(iov[0], rhdr);
409 IOVPUT(iov[1], copydata);
410
411 putwait(spc, &rw, &rhdr);
412 rv = SENDIOV(spc, iov);
413 if (rv) {
414 unputwait(spc, &rw);
415 return rv;
416 }
417
418 rv = waitresp(spc, &rw);
419
420 DPRINTF(("copyin: response %d\n", rv));
421
422 *resp = rw.rw_data;
423 if (wantstr)
424 *dlen = rw.rw_dlen;
425
426 return rv;
427
428 }
429
430 static int
431 send_copyout_req(struct spclient *spc, const void *remaddr,
432 const void *data, size_t dlen)
433 {
434 struct rsp_hdr rhdr;
435 struct rsp_copydata copydata;
436 struct iovec iov[3];
437 int rv;
438
439 DPRINTF(("copyout_req (async): %zu bytes to %p\n", dlen, remaddr));
440
441 rhdr.rsp_len = sizeof(rhdr) + sizeof(copydata) + dlen;
442 rhdr.rsp_reqno = nextreq(spc);
443 rhdr.rsp_class = RUMPSP_REQ;
444 rhdr.rsp_type = RUMPSP_COPYOUT;
445 rhdr.rsp_sysnum = 0;
446
447 copydata.rcp_addr = __UNCONST(remaddr);
448 copydata.rcp_len = dlen;
449
450 IOVPUT(iov[0], rhdr);
451 IOVPUT(iov[1], copydata);
452 IOVPUT_WITHSIZE(iov[2], __UNCONST(data), dlen);
453
454 sendlock(spc);
455 rv = SENDIOV(spc, iov);
456 sendunlock(spc);
457
458 return rv;
459 }
460
461 static int
462 anonmmap_req(struct spclient *spc, size_t howmuch, void **resp)
463 {
464 struct rsp_hdr rhdr;
465 struct respwait rw;
466 struct iovec iov[2];
467 int rv;
468
469 DPRINTF(("anonmmap_req: %zu bytes\n", howmuch));
470
471 rhdr.rsp_len = sizeof(rhdr) + sizeof(howmuch);
472 rhdr.rsp_class = RUMPSP_REQ;
473 rhdr.rsp_type = RUMPSP_ANONMMAP;
474 rhdr.rsp_sysnum = 0;
475
476 IOVPUT(iov[0], rhdr);
477 IOVPUT(iov[1], howmuch);
478
479 putwait(spc, &rw, &rhdr);
480 rv = SENDIOV(spc, iov);
481 if (rv) {
482 unputwait(spc, &rw);
483 return rv;
484 }
485
486 rv = waitresp(spc, &rw);
487
488 *resp = rw.rw_data;
489
490 DPRINTF(("anonmmap: mapped at %p\n", **(void ***)resp));
491
492 return rv;
493 }
494
495 static int
496 send_raise_req(struct spclient *spc, int signo)
497 {
498 struct rsp_hdr rhdr;
499 struct iovec iov[1];
500 int rv;
501
502 rhdr.rsp_len = sizeof(rhdr);
503 rhdr.rsp_class = RUMPSP_REQ;
504 rhdr.rsp_type = RUMPSP_RAISE;
505 rhdr.rsp_signo = signo;
506
507 IOVPUT(iov[0], rhdr);
508
509 sendlock(spc);
510 rv = SENDIOV(spc, iov);
511 sendunlock(spc);
512
513 return rv;
514 }
515
516 static void
517 spcref(struct spclient *spc)
518 {
519
520 pthread_mutex_lock(&spc->spc_mtx);
521 spc->spc_refcnt++;
522 pthread_mutex_unlock(&spc->spc_mtx);
523 }
524
525 static void
526 spcrelease(struct spclient *spc)
527 {
528 int ref;
529
530 pthread_mutex_lock(&spc->spc_mtx);
531 ref = --spc->spc_refcnt;
532 if (__predict_false(spc->spc_inexec && ref <= 2))
533 pthread_cond_broadcast(&spc->spc_cv);
534 pthread_mutex_unlock(&spc->spc_mtx);
535
536 if (ref > 0)
537 return;
538
539 DPRINTF(("rump_sp: spcrelease: spc %p fd %d\n", spc, spc->spc_fd));
540
541 _DIAGASSERT(TAILQ_EMPTY(&spc->spc_respwait));
542 _DIAGASSERT(spc->spc_buf == NULL);
543
544 if (spc->spc_mainlwp) {
545 lwproc_switch(spc->spc_mainlwp);
546 lwproc_release();
547 }
548 spc->spc_mainlwp = NULL;
549
550 close(spc->spc_fd);
551 spc->spc_fd = -1;
552 spc->spc_state = SPCSTATE_NEW;
553
554 signaldisco();
555 }
556
557 static void
558 serv_handledisco(unsigned int idx)
559 {
560 struct spclient *spc = &spclist[idx];
561 int dolwpexit;
562
563 DPRINTF(("rump_sp: disconnecting [%u]\n", idx));
564
565 pfdlist[idx].fd = -1;
566 pfdlist[idx].revents = 0;
567 pthread_mutex_lock(&spc->spc_mtx);
568 spc->spc_state = SPCSTATE_DYING;
569 kickall(spc);
570 sendunlockl(spc);
571 /* exec uses mainlwp in another thread, but also nuked all lwps */
572 dolwpexit = !spc->spc_inexec;
573 pthread_mutex_unlock(&spc->spc_mtx);
574
575 if (dolwpexit && spc->spc_mainlwp) {
576 lwproc_switch(spc->spc_mainlwp);
577 lwproc_lwpexit();
578 lwproc_switch(NULL);
579 }
580
581 /*
582 * Nobody's going to attempt to send/receive anymore,
583 * so reinit info relevant to that.
584 */
585 /*LINTED:pointer casts may be ok*/
586 memset((char *)spc + SPC_ZEROFF, 0, sizeof(*spc) - SPC_ZEROFF);
587
588 spcrelease(spc);
589 }
590
591 static void
592 serv_shutdown(void)
593 {
594 struct spclient *spc;
595 unsigned int i;
596
597 for (i = 1; i < MAXCLI; i++) {
598 spc = &spclist[i];
599 if (spc->spc_fd == -1)
600 continue;
601
602 shutdown(spc->spc_fd, SHUT_RDWR);
603 serv_handledisco(i);
604
605 spcrelease(spc);
606 }
607 }
608
609 static unsigned
610 serv_handleconn(int fd, connecthook_fn connhook, int busy)
611 {
612 struct sockaddr_storage ss;
613 socklen_t sl = sizeof(ss);
614 int newfd, flags;
615 unsigned i;
616
617 /*LINTED: cast ok */
618 newfd = accept(fd, (struct sockaddr *)&ss, &sl);
619 if (newfd == -1)
620 return 0;
621
622 if (busy) {
623 close(newfd); /* EBUSY */
624 return 0;
625 }
626
627 flags = fcntl(newfd, F_GETFL, 0);
628 if (fcntl(newfd, F_SETFL, flags | O_NONBLOCK) == -1) {
629 close(newfd);
630 return 0;
631 }
632
633 if (connhook(newfd) != 0) {
634 close(newfd);
635 return 0;
636 }
637
638 /* write out a banner for the client */
639 if (send(newfd, banner, strlen(banner), MSG_NOSIGNAL)
640 != (ssize_t)strlen(banner)) {
641 close(newfd);
642 return 0;
643 }
644
645 /* find empty slot the simple way */
646 for (i = 0; i < MAXCLI; i++) {
647 if (pfdlist[i].fd == -1 && spclist[i].spc_state == SPCSTATE_NEW)
648 break;
649 }
650
651 /*
652 * Although not finding a slot is impossible (cf. how this routine
653 * is called), the compiler can still think that i == MAXCLI
654 * if this code is either compiled with NDEBUG or the platform
655 * does not use __dead for assert(). Therefore, add an explicit
656 * check to avoid an array-bounds error.
657 */
658 /* assert(i < MAXCLI); */
659 if (i == MAXCLI)
660 abort();
661
662 pfdlist[i].fd = newfd;
663 spclist[i].spc_fd = newfd;
664 spclist[i].spc_istatus = SPCSTATUS_BUSY; /* dedicated receiver */
665 spclist[i].spc_refcnt = 1;
666
667 TAILQ_INIT(&spclist[i].spc_respwait);
668
669 DPRINTF(("rump_sp: added new connection fd %d at idx %u\n", newfd, i));
670
671 return i;
672 }
673
674 static void
675 serv_handlesyscall(struct spclient *spc, struct rsp_hdr *rhdr, uint8_t *data)
676 {
677 register_t retval[2] = {0, 0};
678 int rv, sysnum;
679
680 sysnum = (int)rhdr->rsp_sysnum;
681 DPRINTF(("rump_sp: handling syscall %d from client %d\n",
682 sysnum, spc->spc_pid));
683
684 if (__predict_false((rv = lwproc_newlwp(spc->spc_pid)) != 0)) {
685 retval[0] = -1;
686 send_syscall_resp(spc, rhdr->rsp_reqno, rv, retval);
687 return;
688 }
689 spc->spc_syscallreq = rhdr->rsp_reqno;
690 rv = rumpsyscall(sysnum, data, retval);
691 spc->spc_syscallreq = 0;
692 lwproc_release();
693
694 DPRINTF(("rump_sp: got return value %d & %"PRIxREGISTER
695 "/%"PRIxREGISTER"\n",
696 rv, retval[0], retval[1]));
697
698 send_syscall_resp(spc, rhdr->rsp_reqno, rv, retval);
699 }
700
701 static void
702 serv_handleexec(struct spclient *spc, struct rsp_hdr *rhdr, char *comm)
703 {
704 size_t commlen = rhdr->rsp_len - HDRSZ;
705
706 pthread_mutex_lock(&spc->spc_mtx);
707 /* one for the connection and one for us */
708 while (spc->spc_refcnt > 2)
709 pthread_cond_wait(&spc->spc_cv, &spc->spc_mtx);
710 pthread_mutex_unlock(&spc->spc_mtx);
711
712 /*
713 * ok, all the threads are dead (or one is still alive and
714 * the connection is dead, in which case this doesn't matter
715 * very much). proceed with exec.
716 */
717
718 /* ensure comm is 0-terminated */
719 /* TODO: make sure it contains sensible chars? */
720 comm[commlen] = '\0';
721
722 lwproc_switch(spc->spc_mainlwp);
723 lwproc_execnotify(comm);
724 lwproc_switch(NULL);
725
726 pthread_mutex_lock(&spc->spc_mtx);
727 spc->spc_inexec = 0;
728 pthread_mutex_unlock(&spc->spc_mtx);
729 send_handshake_resp(spc, rhdr->rsp_reqno, 0);
730 }
731
732 enum sbatype { SBA_SYSCALL, SBA_EXEC };
733
734 struct servbouncearg {
735 struct spclient *sba_spc;
736 struct rsp_hdr sba_hdr;
737 enum sbatype sba_type;
738 uint8_t *sba_data;
739
740 TAILQ_ENTRY(servbouncearg) sba_entries;
741 };
742 static pthread_mutex_t sbamtx;
743 static pthread_cond_t sbacv;
744 static int nworker, idleworker, nwork;
745 static TAILQ_HEAD(, servbouncearg) wrklist = TAILQ_HEAD_INITIALIZER(wrklist);
746
747 /*ARGSUSED*/
748 static void *
749 serv_workbouncer(void *arg)
750 {
751 struct servbouncearg *sba;
752
753 for (;;) {
754 pthread_mutex_lock(&sbamtx);
755 if (__predict_false(idleworker - nwork >= rumpsp_idleworker)) {
756 nworker--;
757 pthread_mutex_unlock(&sbamtx);
758 break;
759 }
760 idleworker++;
761 while (TAILQ_EMPTY(&wrklist)) {
762 _DIAGASSERT(nwork == 0);
763 pthread_cond_wait(&sbacv, &sbamtx);
764 }
765 idleworker--;
766
767 sba = TAILQ_FIRST(&wrklist);
768 TAILQ_REMOVE(&wrklist, sba, sba_entries);
769 nwork--;
770 pthread_mutex_unlock(&sbamtx);
771
772 if (__predict_true(sba->sba_type == SBA_SYSCALL)) {
773 serv_handlesyscall(sba->sba_spc,
774 &sba->sba_hdr, sba->sba_data);
775 } else {
776 _DIAGASSERT(sba->sba_type == SBA_EXEC);
777 serv_handleexec(sba->sba_spc, &sba->sba_hdr,
778 (char *)sba->sba_data);
779 }
780 spcrelease(sba->sba_spc);
781 free(sba->sba_data);
782 free(sba);
783 }
784
785 return NULL;
786 }
787
788 static int
789 sp_copyin(void *arg, const void *raddr, void *laddr, size_t *len, int wantstr)
790 {
791 struct spclient *spc = arg;
792 void *rdata = NULL; /* XXXuninit */
793 int rv, nlocks;
794
795 rumpkern_unsched(&nlocks, NULL);
796
797 rv = copyin_req(spc, raddr, len, wantstr, &rdata);
798 if (rv)
799 goto out;
800
801 memcpy(laddr, rdata, *len);
802 free(rdata);
803
804 out:
805 rumpkern_sched(nlocks, NULL);
806 if (rv)
807 rv = EFAULT;
808 ET(rv);
809 }
810
811 int
812 rumpuser_sp_copyin(void *arg, const void *raddr, void *laddr, size_t len)
813 {
814 int rv;
815
816 rv = sp_copyin(arg, raddr, laddr, &len, 0);
817 ET(rv);
818 }
819
820 int
821 rumpuser_sp_copyinstr(void *arg, const void *raddr, void *laddr, size_t *len)
822 {
823 int rv;
824
825 rv = sp_copyin(arg, raddr, laddr, len, 1);
826 ET(rv);
827 }
828
829 static int
830 sp_copyout(void *arg, const void *laddr, void *raddr, size_t dlen)
831 {
832 struct spclient *spc = arg;
833 int nlocks, rv;
834
835 rumpkern_unsched(&nlocks, NULL);
836 rv = send_copyout_req(spc, raddr, laddr, dlen);
837 rumpkern_sched(nlocks, NULL);
838
839 if (rv)
840 rv = EFAULT;
841 ET(rv);
842 }
843
844 int
845 rumpuser_sp_copyout(void *arg, const void *laddr, void *raddr, size_t dlen)
846 {
847 int rv;
848
849 rv = sp_copyout(arg, laddr, raddr, dlen);
850 ET(rv);
851 }
852
853 int
854 rumpuser_sp_copyoutstr(void *arg, const void *laddr, void *raddr, size_t *dlen)
855 {
856 int rv;
857
858 rv = sp_copyout(arg, laddr, raddr, *dlen);
859 ET(rv);
860 }
861
862 int
863 rumpuser_sp_anonmmap(void *arg, size_t howmuch, void **addr)
864 {
865 struct spclient *spc = arg;
866 void *resp, *rdata = NULL; /* XXXuninit */
867 int nlocks, rv;
868
869 rumpkern_unsched(&nlocks, NULL);
870
871 rv = anonmmap_req(spc, howmuch, &rdata);
872 if (rv) {
873 rv = EFAULT;
874 goto out;
875 }
876
877 resp = *(void **)rdata;
878 free(rdata);
879
880 if (resp == NULL) {
881 rv = ENOMEM;
882 }
883
884 *addr = resp;
885
886 out:
887 rumpkern_sched(nlocks, NULL);
888 ET(rv);
889 }
890
891 int
892 rumpuser_sp_raise(void *arg, int signo)
893 {
894 struct spclient *spc = arg;
895 int rv, nlocks;
896
897 rumpkern_unsched(&nlocks, NULL);
898 rv = send_raise_req(spc, signo);
899 rumpkern_sched(nlocks, NULL);
900
901 return rv;
902 }
903
904 static pthread_attr_t pattr_detached;
905 static void
906 schedulework(struct spclient *spc, enum sbatype sba_type)
907 {
908 struct servbouncearg *sba;
909 pthread_t pt;
910 uint64_t reqno;
911 int retries = 0;
912
913 reqno = spc->spc_hdr.rsp_reqno;
914 while ((sba = malloc(sizeof(*sba))) == NULL) {
915 if (nworker == 0 || retries++ > 10) {
916 send_error_resp(spc, reqno, RUMPSP_ERR_TRYAGAIN);
917 spcfreebuf(spc);
918 return;
919 }
920 /* slim chance of more memory? */
921 usleep(10000);
922 }
923
924 sba->sba_spc = spc;
925 sba->sba_type = sba_type;
926 sba->sba_hdr = spc->spc_hdr;
927 sba->sba_data = spc->spc_buf;
928 spcresetbuf(spc);
929
930 spcref(spc);
931
932 pthread_mutex_lock(&sbamtx);
933 TAILQ_INSERT_TAIL(&wrklist, sba, sba_entries);
934 nwork++;
935 if (nwork <= idleworker) {
936 /* do we have a daemon's tool (i.e. idle threads)? */
937 pthread_cond_signal(&sbacv);
938 } else if (nworker < rumpsp_maxworker) {
939 /*
940 * Else, need to create one
941 * (if we can, otherwise just expect another
942 * worker to pick up the syscall)
943 */
944 if (pthread_create(&pt, &pattr_detached,
945 serv_workbouncer, NULL) == 0) {
946 nworker++;
947 }
948 }
949 pthread_mutex_unlock(&sbamtx);
950 }
951
952 /*
953 *
954 * Startup routines and mainloop for server.
955 *
956 */
957
958 struct spservarg {
959 int sps_sock;
960 connecthook_fn sps_connhook;
961 };
962
963 static void
964 handlereq(struct spclient *spc)
965 {
966 uint64_t reqno;
967 int error;
968
969 reqno = spc->spc_hdr.rsp_reqno;
970 if (__predict_false(spc->spc_state == SPCSTATE_NEW)) {
971 if (spc->spc_hdr.rsp_type != RUMPSP_HANDSHAKE) {
972 send_error_resp(spc, reqno, RUMPSP_ERR_AUTH);
973 shutdown(spc->spc_fd, SHUT_RDWR);
974 spcfreebuf(spc);
975 return;
976 }
977
978 if (spc->spc_hdr.rsp_handshake == HANDSHAKE_GUEST) {
979 char *comm = (char *)spc->spc_buf;
980 size_t commlen = spc->spc_hdr.rsp_len - HDRSZ;
981
982 /* ensure it's 0-terminated */
983 /* XXX make sure it contains sensible chars? */
984 comm[commlen] = '\0';
985
986 /* make sure we fork off of proc1 */
987 _DIAGASSERT(lwproc_curlwp() == NULL);
988
989 if ((error = lwproc_rfork(spc,
990 RUMP_RFFD_CLEAR, comm)) != 0) {
991 shutdown(spc->spc_fd, SHUT_RDWR);
992 }
993
994 spcfreebuf(spc);
995 if (error)
996 return;
997
998 spc->spc_mainlwp = lwproc_curlwp();
999
1000 send_handshake_resp(spc, reqno, 0);
1001 } else if (spc->spc_hdr.rsp_handshake == HANDSHAKE_FORK) {
1002 struct lwp *tmpmain;
1003 struct prefork *pf;
1004 struct handshake_fork *rfp;
1005 int cancel;
1006
1007 if (spc->spc_off-HDRSZ != sizeof(*rfp)) {
1008 send_error_resp(spc, reqno,
1009 RUMPSP_ERR_MALFORMED_REQUEST);
1010 shutdown(spc->spc_fd, SHUT_RDWR);
1011 spcfreebuf(spc);
1012 return;
1013 }
1014
1015 /*LINTED*/
1016 rfp = (void *)spc->spc_buf;
1017 cancel = rfp->rf_cancel;
1018
1019 pthread_mutex_lock(&pfmtx);
1020 LIST_FOREACH(pf, &preforks, pf_entries) {
1021 if (memcmp(rfp->rf_auth, pf->pf_auth,
1022 sizeof(rfp->rf_auth)) == 0) {
1023 LIST_REMOVE(pf, pf_entries);
1024 LIST_REMOVE(pf, pf_spcentries);
1025 break;
1026 }
1027 }
1028 pthread_mutex_unlock(&pfmtx);
1029 spcfreebuf(spc);
1030
1031 if (!pf) {
1032 send_error_resp(spc, reqno,
1033 RUMPSP_ERR_INVALID_PREFORK);
1034 shutdown(spc->spc_fd, SHUT_RDWR);
1035 return;
1036 }
1037
1038 tmpmain = pf->pf_lwp;
1039 free(pf);
1040 lwproc_switch(tmpmain);
1041 if (cancel) {
1042 lwproc_release();
1043 shutdown(spc->spc_fd, SHUT_RDWR);
1044 return;
1045 }
1046
1047 /*
1048 * So, we forked already during "prefork" to save
1049 * the file descriptors from a parent exit
1050 * race condition. But now we need to fork
1051 * a second time since the initial fork has
1052 * the wrong spc pointer. (yea, optimize
1053 * interfaces some day if anyone cares)
1054 */
1055 if ((error = lwproc_rfork(spc,
1056 RUMP_RFFD_SHARE, NULL)) != 0) {
1057 send_error_resp(spc, reqno,
1058 RUMPSP_ERR_RFORK_FAILED);
1059 shutdown(spc->spc_fd, SHUT_RDWR);
1060 lwproc_release();
1061 return;
1062 }
1063 spc->spc_mainlwp = lwproc_curlwp();
1064 lwproc_switch(tmpmain);
1065 lwproc_release();
1066 lwproc_switch(spc->spc_mainlwp);
1067
1068 send_handshake_resp(spc, reqno, 0);
1069 } else {
1070 send_error_resp(spc, reqno, RUMPSP_ERR_AUTH);
1071 shutdown(spc->spc_fd, SHUT_RDWR);
1072 spcfreebuf(spc);
1073 return;
1074 }
1075
1076 spc->spc_pid = lwproc_getpid();
1077
1078 DPRINTF(("rump_sp: handshake for client %p complete, pid %d\n",
1079 spc, spc->spc_pid));
1080
1081 lwproc_switch(NULL);
1082 spc->spc_state = SPCSTATE_RUNNING;
1083 return;
1084 }
1085
1086 if (__predict_false(spc->spc_hdr.rsp_type == RUMPSP_PREFORK)) {
1087 struct prefork *pf;
1088 uint32_t auth[AUTHLEN];
1089 size_t randlen;
1090 int inexec;
1091
1092 DPRINTF(("rump_sp: prefork handler executing for %p\n", spc));
1093 spcfreebuf(spc);
1094
1095 pthread_mutex_lock(&spc->spc_mtx);
1096 inexec = spc->spc_inexec;
1097 pthread_mutex_unlock(&spc->spc_mtx);
1098 if (inexec) {
1099 send_error_resp(spc, reqno, RUMPSP_ERR_INEXEC);
1100 shutdown(spc->spc_fd, SHUT_RDWR);
1101 return;
1102 }
1103
1104 pf = malloc(sizeof(*pf));
1105 if (pf == NULL) {
1106 send_error_resp(spc, reqno, RUMPSP_ERR_NOMEM);
1107 return;
1108 }
1109
1110 /*
1111 * Use client main lwp to fork. this is never used by
1112 * worker threads (except in exec, but we checked for that
1113 * above) so we can safely use it here.
1114 */
1115 lwproc_switch(spc->spc_mainlwp);
1116 if ((error = lwproc_rfork(spc, RUMP_RFFD_COPY, NULL)) != 0) {
1117 DPRINTF(("rump_sp: fork failed: %d (%p)\n",error, spc));
1118 send_error_resp(spc, reqno, RUMPSP_ERR_RFORK_FAILED);
1119 lwproc_switch(NULL);
1120 free(pf);
1121 return;
1122 }
1123
1124 /* Ok, we have a new process context and a new curlwp */
1125 rumpuser_getrandom(auth, sizeof(auth), 0, &randlen);
1126 memcpy(pf->pf_auth, auth, sizeof(pf->pf_auth));
1127 pf->pf_lwp = lwproc_curlwp();
1128 lwproc_switch(NULL);
1129
1130 pthread_mutex_lock(&pfmtx);
1131 LIST_INSERT_HEAD(&preforks, pf, pf_entries);
1132 LIST_INSERT_HEAD(&spc->spc_pflist, pf, pf_spcentries);
1133 pthread_mutex_unlock(&pfmtx);
1134
1135 DPRINTF(("rump_sp: prefork handler success %p\n", spc));
1136
1137 send_prefork_resp(spc, reqno, auth);
1138 return;
1139 }
1140
1141 if (__predict_false(spc->spc_hdr.rsp_type == RUMPSP_HANDSHAKE)) {
1142 int inexec;
1143
1144 if (spc->spc_hdr.rsp_handshake != HANDSHAKE_EXEC) {
1145 send_error_resp(spc, reqno,
1146 RUMPSP_ERR_MALFORMED_REQUEST);
1147 shutdown(spc->spc_fd, SHUT_RDWR);
1148 spcfreebuf(spc);
1149 return;
1150 }
1151
1152 pthread_mutex_lock(&spc->spc_mtx);
1153 inexec = spc->spc_inexec;
1154 pthread_mutex_unlock(&spc->spc_mtx);
1155 if (inexec) {
1156 send_error_resp(spc, reqno, RUMPSP_ERR_INEXEC);
1157 shutdown(spc->spc_fd, SHUT_RDWR);
1158 spcfreebuf(spc);
1159 return;
1160 }
1161
1162 pthread_mutex_lock(&spc->spc_mtx);
1163 spc->spc_inexec = 1;
1164 pthread_mutex_unlock(&spc->spc_mtx);
1165
1166 /*
1167 * start to drain lwps. we will wait for it to finish
1168 * in another thread
1169 */
1170 lwproc_switch(spc->spc_mainlwp);
1171 lwproc_lwpexit();
1172 lwproc_switch(NULL);
1173
1174 /*
1175 * exec has to wait for lwps to drain, so finish it off
1176 * in another thread
1177 */
1178 schedulework(spc, SBA_EXEC);
1179 return;
1180 }
1181
1182 if (__predict_false(spc->spc_hdr.rsp_type != RUMPSP_SYSCALL)) {
1183 send_error_resp(spc, reqno, RUMPSP_ERR_MALFORMED_REQUEST);
1184 spcfreebuf(spc);
1185 return;
1186 }
1187
1188 schedulework(spc, SBA_SYSCALL);
1189 }
1190
1191 static void *
1192 spserver(void *arg)
1193 {
1194 struct spservarg *sarg = arg;
1195 struct spclient *spc;
1196 unsigned idx;
1197 int seen;
1198 int rv;
1199 unsigned int nfds, maxidx;
1200
1201 for (idx = 0; idx < MAXCLI; idx++) {
1202 pfdlist[idx].fd = -1;
1203 pfdlist[idx].events = POLLIN;
1204
1205 spc = &spclist[idx];
1206 pthread_mutex_init(&spc->spc_mtx, NULL);
1207 pthread_cond_init(&spc->spc_cv, NULL);
1208 spc->spc_fd = -1;
1209 }
1210 pfdlist[0].fd = spclist[0].spc_fd = sarg->sps_sock;
1211 pfdlist[0].events = POLLIN;
1212 nfds = 1;
1213 maxidx = 0;
1214
1215 pthread_attr_init(&pattr_detached);
1216 pthread_attr_setdetachstate(&pattr_detached, PTHREAD_CREATE_DETACHED);
1217 #if NOTYET
1218 pthread_attr_setstacksize(&pattr_detached, 32*1024);
1219 #endif
1220
1221 pthread_mutex_init(&sbamtx, NULL);
1222 pthread_cond_init(&sbacv, NULL);
1223
1224 DPRINTF(("rump_sp: server mainloop\n"));
1225
1226 for (;;) {
1227 int discoed;
1228
1229 /* g/c hangarounds (eventually) */
1230 discoed = getdisco();
1231 while (discoed--) {
1232 nfds--;
1233 idx = maxidx;
1234 while (idx) {
1235 if (pfdlist[idx].fd != -1) {
1236 maxidx = idx;
1237 break;
1238 }
1239 idx--;
1240 }
1241 DPRINTF(("rump_sp: set maxidx to [%u]\n",
1242 maxidx));
1243 }
1244
1245 DPRINTF(("rump_sp: loop nfd %d\n", maxidx+1));
1246 seen = 0;
1247 rv = poll(pfdlist, maxidx+1, INFTIM);
1248 assert(maxidx+1 <= MAXCLI);
1249 assert(rv != 0);
1250 if (rv == -1) {
1251 if (errno == EINTR)
1252 continue;
1253 fprintf(stderr, "rump_spserver: poll returned %d\n",
1254 errno);
1255 break;
1256 }
1257
1258 for (idx = 0; seen < rv && idx < MAXCLI; idx++) {
1259 if ((pfdlist[idx].revents & POLLIN) == 0)
1260 continue;
1261
1262 seen++;
1263 DPRINTF(("rump_sp: activity at [%u] %d/%d\n",
1264 idx, seen, rv));
1265 if (idx > 0) {
1266 spc = &spclist[idx];
1267 DPRINTF(("rump_sp: mainloop read [%u]\n", idx));
1268 switch (readframe(spc)) {
1269 case 0:
1270 break;
1271 case -1:
1272 serv_handledisco(idx);
1273 break;
1274 default:
1275 switch (spc->spc_hdr.rsp_class) {
1276 case RUMPSP_RESP:
1277 kickwaiter(spc);
1278 break;
1279 case RUMPSP_REQ:
1280 handlereq(spc);
1281 break;
1282 default:
1283 send_error_resp(spc,
1284 spc->spc_hdr.rsp_reqno,
1285 RUMPSP_ERR_MALFORMED_REQUEST);
1286 spcfreebuf(spc);
1287 break;
1288 }
1289 break;
1290 }
1291
1292 } else {
1293 DPRINTF(("rump_sp: mainloop new connection\n"));
1294
1295 if (__predict_false(spfini)) {
1296 close(spclist[0].spc_fd);
1297 serv_shutdown();
1298 goto out;
1299 }
1300
1301 idx = serv_handleconn(pfdlist[0].fd,
1302 sarg->sps_connhook, nfds == MAXCLI);
1303 if (idx)
1304 nfds++;
1305 if (idx > maxidx)
1306 maxidx = idx;
1307 DPRINTF(("rump_sp: maxid now %d\n", maxidx));
1308 }
1309 }
1310 }
1311
1312 out:
1313 return NULL;
1314 }
1315
1316 static unsigned cleanupidx;
1317 static struct sockaddr *cleanupsa;
1318 int
1319 rumpuser_sp_init(const char *url,
1320 const char *ostype, const char *osrelease, const char *machine)
1321 {
1322 pthread_t pt;
1323 struct spservarg *sarg;
1324 struct sockaddr *sap;
1325 char *p;
1326 unsigned idx = 0; /* XXXgcc */
1327 int error, s;
1328
1329 p = strdup(url);
1330 if (p == NULL) {
1331 error = ENOMEM;
1332 goto out;
1333 }
1334 error = parseurl(p, &sap, &idx, 1);
1335 free(p);
1336 if (error)
1337 goto out;
1338
1339 snprintf(banner, sizeof(banner), "RUMPSP-%d.%d-%s-%s/%s\n",
1340 PROTOMAJOR, PROTOMINOR, ostype, osrelease, machine);
1341
1342 s = socket(parsetab[idx].domain, SOCK_STREAM, 0);
1343 if (s == -1) {
1344 error = errno;
1345 goto out;
1346 }
1347
1348 sarg = malloc(sizeof(*sarg));
1349 if (sarg == NULL) {
1350 close(s);
1351 error = ENOMEM;
1352 goto out;
1353 }
1354
1355 sarg->sps_sock = s;
1356 sarg->sps_connhook = parsetab[idx].connhook;
1357
1358 cleanupidx = idx;
1359 cleanupsa = sap;
1360
1361 /* sloppy error recovery */
1362
1363 /*LINTED*/
1364 if (bind(s, sap, parsetab[idx].slen) == -1) {
1365 error = errno;
1366 fprintf(stderr, "rump_sp: failed to bind to URL %s\n", url);
1367 goto out;
1368 }
1369 if (listen(s, MAXCLI) == -1) {
1370 error = errno;
1371 fprintf(stderr, "rump_sp: server listen failed\n");
1372 goto out;
1373 }
1374
1375 if ((error = pthread_create(&pt, NULL, spserver, sarg)) != 0) {
1376 fprintf(stderr, "rump_sp: cannot create wrkr thread\n");
1377 goto out;
1378 }
1379 pthread_detach(pt);
1380
1381 out:
1382 ET(error);
1383 }
1384
1385 void
1386 rumpuser_sp_fini(void *arg)
1387 {
1388 struct spclient *spc = arg;
1389 register_t retval[2] = {0, 0};
1390
1391 if (spclist[0].spc_fd) {
1392 parsetab[cleanupidx].cleanup(cleanupsa);
1393 }
1394
1395 /*
1396 * stuff response into the socket, since the rump kernel container
1397 * is just about to exit
1398 */
1399 if (spc && spc->spc_syscallreq)
1400 send_syscall_resp(spc, spc->spc_syscallreq, 0, retval);
1401
1402 if (spclist[0].spc_fd) {
1403 shutdown(spclist[0].spc_fd, SHUT_RDWR);
1404 spfini = 1;
1405 }
1406
1407 /*
1408 * could release thread, but don't bother, since the container
1409 * will be stone dead in a moment.
1410 */
1411 }
1412