sysproxy.c revision 1.2.2.4
1 1.2.2.4 skrll /* $NetBSD: sysproxy.c,v 1.2.2.4 2016/03/19 11:30:37 skrll Exp $ */ 2 1.2.2.2 skrll 3 1.2.2.2 skrll /* 4 1.2.2.2 skrll * Copyright (c) 2010, 2011 Antti Kantee. All Rights Reserved. 5 1.2.2.2 skrll * 6 1.2.2.2 skrll * Redistribution and use in source and binary forms, with or without 7 1.2.2.2 skrll * modification, are permitted provided that the following conditions 8 1.2.2.2 skrll * are met: 9 1.2.2.2 skrll * 1. Redistributions of source code must retain the above copyright 10 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer. 11 1.2.2.2 skrll * 2. Redistributions in binary form must reproduce the above copyright 12 1.2.2.2 skrll * notice, this list of conditions and the following disclaimer in the 13 1.2.2.2 skrll * documentation and/or other materials provided with the distribution. 14 1.2.2.2 skrll * 15 1.2.2.2 skrll * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS 16 1.2.2.2 skrll * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 1.2.2.2 skrll * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 1.2.2.2 skrll * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 19 1.2.2.2 skrll * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 20 1.2.2.2 skrll * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 21 1.2.2.2 skrll * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 22 1.2.2.2 skrll * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 23 1.2.2.2 skrll * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 24 1.2.2.2 skrll * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 25 1.2.2.2 skrll * SUCH DAMAGE. 26 1.2.2.2 skrll */ 27 1.2.2.2 skrll 28 1.2.2.2 skrll #include <sys/cdefs.h> 29 1.2.2.4 skrll __KERNEL_RCSID(0, "$NetBSD: sysproxy.c,v 1.2.2.4 2016/03/19 11:30:37 skrll Exp $"); 30 1.2.2.2 skrll 31 1.2.2.2 skrll #include <sys/param.h> 32 1.2.2.2 skrll #include <sys/filedesc.h> 33 1.2.2.2 skrll #include <sys/kmem.h> 34 1.2.2.2 skrll #include <sys/syscall.h> 35 1.2.2.2 skrll #include <sys/syscallvar.h> 36 1.2.2.2 skrll #include <sys/systm.h> 37 1.2.2.2 skrll #include <sys/xcall.h> 38 1.2.2.2 skrll 39 1.2.2.2 skrll #define _RUMP_SYSPROXY 40 1.2.2.2 skrll #include <rump/rumpuser.h> 41 1.2.2.2 skrll 42 1.2.2.4 skrll #include <rump-sys/kern.h> 43 1.2.2.2 skrll 44 1.2.2.2 skrll int 45 1.2.2.2 skrll rump_init_server(const char *url) 46 1.2.2.2 skrll { 47 1.2.2.2 skrll 48 1.2.2.2 skrll return rumpuser_sp_init(url, ostype, osrelease, MACHINE); 49 1.2.2.2 skrll } 50 1.2.2.2 skrll 51 1.2.2.2 skrll static pid_t 52 1.2.2.2 skrll hyp_getpid(void) 53 1.2.2.2 skrll { 54 1.2.2.2 skrll 55 1.2.2.2 skrll return curproc->p_pid; 56 1.2.2.2 skrll } 57 1.2.2.2 skrll 58 1.2.2.2 skrll static int 59 1.2.2.2 skrll hyp_syscall(int num, void *arg, long *retval) 60 1.2.2.2 skrll { 61 1.2.2.2 skrll register_t regrv[2] = {0, 0}; 62 1.2.2.2 skrll struct lwp *l; 63 1.2.2.2 skrll struct sysent *callp; 64 1.2.2.2 skrll int rv; 65 1.2.2.2 skrll 66 1.2.2.2 skrll if (__predict_false(num >= SYS_NSYSENT)) 67 1.2.2.2 skrll return ENOSYS; 68 1.2.2.2 skrll 69 1.2.2.2 skrll /* XXX: always uses native syscall vector */ 70 1.2.2.2 skrll callp = rump_sysent + num; 71 1.2.2.2 skrll l = curlwp; 72 1.2.2.2 skrll rv = sy_invoke(callp, l, (void *)arg, regrv, num); 73 1.2.2.2 skrll retval[0] = regrv[0]; 74 1.2.2.2 skrll retval[1] = regrv[1]; 75 1.2.2.2 skrll 76 1.2.2.2 skrll return rv; 77 1.2.2.2 skrll } 78 1.2.2.2 skrll 79 1.2.2.3 skrll static struct pmap remotepmap; 80 1.2.2.3 skrll 81 1.2.2.2 skrll static int 82 1.2.2.2 skrll hyp_rfork(void *priv, int flags, const char *comm) 83 1.2.2.2 skrll { 84 1.2.2.3 skrll struct rump_spctl *spctl; 85 1.2.2.2 skrll struct vmspace *vm; 86 1.2.2.2 skrll struct proc *p; 87 1.2.2.2 skrll struct lwp *l; 88 1.2.2.2 skrll int error; 89 1.2.2.2 skrll bool initfds; 90 1.2.2.2 skrll 91 1.2.2.2 skrll /* 92 1.2.2.2 skrll * If we are forking off of pid 1, initialize file descriptors. 93 1.2.2.2 skrll */ 94 1.2.2.2 skrll l = curlwp; 95 1.2.2.2 skrll if (l->l_proc->p_pid == 1) { 96 1.2.2.2 skrll KASSERT(flags == RUMP_RFFD_CLEAR); 97 1.2.2.2 skrll initfds = true; 98 1.2.2.2 skrll } else { 99 1.2.2.2 skrll initfds = false; 100 1.2.2.2 skrll } 101 1.2.2.2 skrll 102 1.2.2.2 skrll /* 103 1.2.2.3 skrll * Since it's a proxy proc, we create a vmspace for it. 104 1.2.2.2 skrll */ 105 1.2.2.3 skrll spctl = kmem_zalloc(sizeof(*spctl), KM_SLEEP); 106 1.2.2.3 skrll vm = &spctl->spctl_vm; 107 1.2.2.3 skrll uvmspace_init(vm, &remotepmap, 0, 0, false); 108 1.2.2.3 skrll spctl->spctl = priv; 109 1.2.2.2 skrll 110 1.2.2.2 skrll if ((error = rump_lwproc_rfork_vmspace(vm, flags)) != 0) { 111 1.2.2.2 skrll kmem_free(vm, sizeof(*vm)); 112 1.2.2.2 skrll return error; 113 1.2.2.2 skrll } 114 1.2.2.2 skrll 115 1.2.2.2 skrll /* 116 1.2.2.2 skrll * We forked in this routine, so cannot use curlwp (const) 117 1.2.2.2 skrll */ 118 1.2.2.2 skrll l = rump_lwproc_curlwp(); 119 1.2.2.2 skrll p = l->l_proc; 120 1.2.2.2 skrll 121 1.2.2.2 skrll if (comm) 122 1.2.2.2 skrll strlcpy(p->p_comm, comm, sizeof(p->p_comm)); 123 1.2.2.2 skrll if (initfds) 124 1.2.2.2 skrll rump_consdev_init(); 125 1.2.2.2 skrll 126 1.2.2.2 skrll return 0; 127 1.2.2.2 skrll } 128 1.2.2.2 skrll 129 1.2.2.2 skrll /* 130 1.2.2.2 skrll * Order all lwps in a process to exit. does *not* wait for them to drain. 131 1.2.2.2 skrll */ 132 1.2.2.2 skrll static void 133 1.2.2.2 skrll hyp_lwpexit(void) 134 1.2.2.2 skrll { 135 1.2.2.2 skrll struct proc *p = curproc; 136 1.2.2.2 skrll uint64_t where; 137 1.2.2.2 skrll struct lwp *l; 138 1.2.2.2 skrll 139 1.2.2.2 skrll mutex_enter(p->p_lock); 140 1.2.2.2 skrll /* 141 1.2.2.2 skrll * First pass: mark all lwps in the process with LW_RUMP_QEXIT 142 1.2.2.2 skrll * so that they know they should exit. 143 1.2.2.2 skrll */ 144 1.2.2.2 skrll LIST_FOREACH(l, &p->p_lwps, l_sibling) { 145 1.2.2.2 skrll if (l == curlwp) 146 1.2.2.2 skrll continue; 147 1.2.2.2 skrll l->l_flag |= LW_RUMP_QEXIT; 148 1.2.2.2 skrll } 149 1.2.2.2 skrll mutex_exit(p->p_lock); 150 1.2.2.2 skrll 151 1.2.2.2 skrll /* 152 1.2.2.2 skrll * Next, make sure everyone on all CPUs sees our status 153 1.2.2.2 skrll * update. This keeps threads inside cv_wait() and makes 154 1.2.2.2 skrll * sure we don't access a stale cv pointer later when 155 1.2.2.2 skrll * we wake up the threads. 156 1.2.2.2 skrll */ 157 1.2.2.2 skrll 158 1.2.2.2 skrll where = xc_broadcast(0, (xcfunc_t)nullop, NULL, NULL); 159 1.2.2.2 skrll xc_wait(where); 160 1.2.2.2 skrll 161 1.2.2.2 skrll /* 162 1.2.2.2 skrll * Ok, all lwps are either: 163 1.2.2.2 skrll * 1) not in the cv code 164 1.2.2.2 skrll * 2) sleeping on l->l_private 165 1.2.2.2 skrll * 3) sleeping on p->p_waitcv 166 1.2.2.2 skrll * 167 1.2.2.2 skrll * Either way, l_private is stable until we set PS_RUMP_LWPEXIT 168 1.2.2.2 skrll * in p->p_sflag. 169 1.2.2.2 skrll */ 170 1.2.2.2 skrll 171 1.2.2.2 skrll mutex_enter(p->p_lock); 172 1.2.2.2 skrll LIST_FOREACH(l, &p->p_lwps, l_sibling) { 173 1.2.2.2 skrll if (l->l_private) 174 1.2.2.2 skrll cv_broadcast(l->l_private); 175 1.2.2.2 skrll } 176 1.2.2.2 skrll p->p_sflag |= PS_RUMP_LWPEXIT; 177 1.2.2.2 skrll cv_broadcast(&p->p_waitcv); 178 1.2.2.2 skrll mutex_exit(p->p_lock); 179 1.2.2.2 skrll } 180 1.2.2.2 skrll 181 1.2.2.2 skrll /* 182 1.2.2.2 skrll * Notify process that all threads have been drained and exec is complete. 183 1.2.2.2 skrll */ 184 1.2.2.2 skrll static void 185 1.2.2.2 skrll hyp_execnotify(const char *comm) 186 1.2.2.2 skrll { 187 1.2.2.2 skrll struct proc *p = curproc; 188 1.2.2.2 skrll 189 1.2.2.2 skrll fd_closeexec(); 190 1.2.2.2 skrll mutex_enter(p->p_lock); 191 1.2.2.2 skrll KASSERT(p->p_nlwps == 1 && p->p_sflag & PS_RUMP_LWPEXIT); 192 1.2.2.2 skrll p->p_sflag &= ~PS_RUMP_LWPEXIT; 193 1.2.2.2 skrll mutex_exit(p->p_lock); 194 1.2.2.2 skrll strlcpy(p->p_comm, comm, sizeof(p->p_comm)); 195 1.2.2.2 skrll } 196 1.2.2.2 skrll 197 1.2.2.2 skrll /* 198 1.2.2.2 skrll * Initialize interface pointers since component is present. 199 1.2.2.2 skrll */ 200 1.2.2.2 skrll RUMP_COMPONENT(RUMP_COMPONENT_KERN) 201 1.2.2.2 skrll { 202 1.2.2.2 skrll 203 1.2.2.2 skrll rump_sysproxy_ops.rspo_copyin = rumpuser_sp_copyin; 204 1.2.2.2 skrll rump_sysproxy_ops.rspo_copyinstr = rumpuser_sp_copyinstr; 205 1.2.2.2 skrll rump_sysproxy_ops.rspo_copyout = rumpuser_sp_copyout; 206 1.2.2.2 skrll rump_sysproxy_ops.rspo_copyoutstr = rumpuser_sp_copyoutstr; 207 1.2.2.2 skrll rump_sysproxy_ops.rspo_anonmmap = rumpuser_sp_anonmmap; 208 1.2.2.2 skrll rump_sysproxy_ops.rspo_raise = rumpuser_sp_raise; 209 1.2.2.2 skrll rump_sysproxy_ops.rspo_fini = rumpuser_sp_fini; 210 1.2.2.2 skrll 211 1.2.2.2 skrll rump_sysproxy_ops.rspo_hyp_getpid = hyp_getpid; 212 1.2.2.2 skrll rump_sysproxy_ops.rspo_hyp_syscall = hyp_syscall; 213 1.2.2.2 skrll rump_sysproxy_ops.rspo_hyp_rfork = hyp_rfork; 214 1.2.2.2 skrll rump_sysproxy_ops.rspo_hyp_lwpexit = hyp_lwpexit; 215 1.2.2.2 skrll rump_sysproxy_ops.rspo_hyp_execnotify = hyp_execnotify; 216 1.2.2.2 skrll } 217
Indexes created Mon Sep 22 10:09:38 GMT 2025