rumpuser_pth_dummy.c revision 1.9
1 /* $NetBSD: rumpuser_pth_dummy.c,v 1.9 2013/04/27 14:59:08 pooka Exp $ */ 2 3 /* 4 * Copyright (c) 2009 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 #include "rumpuser_port.h" 29 30 #include <sys/cdefs.h> 31 #if !defined(lint) 32 __RCSID("$NetBSD: rumpuser_pth_dummy.c,v 1.9 2013/04/27 14:59:08 pooka Exp $"); 33 #endif /* !lint */ 34 35 #include <sys/time.h> 36 37 #include <assert.h> 38 #include <errno.h> 39 #include <stdlib.h> 40 #include <stdio.h> 41 #include <string.h> 42 #include <stdint.h> 43 44 #include <rump/rumpuser.h> 45 46 #include "rumpuser_int.h" 47 48 static struct lwp *curlwp; 49 50 struct rumpuser_cv {}; 51 52 struct rumpuser_mtx { 53 int v; 54 struct lwp *o; 55 }; 56 57 struct rumpuser_rw { 58 int v; 59 }; 60 61 struct rumpuser_mtx rumpuser_aio_mtx; 62 struct rumpuser_cv rumpuser_aio_cv; 63 int rumpuser_aio_head, rumpuser_aio_tail; 64 struct rumpuser_aio rumpuser_aios[N_AIOS]; 65 66 void 67 rumpuser__thrinit(void) 68 { 69 70 return; 71 } 72 73 /*ARGSUSED*/ 74 void 75 rumpuser_biothread(void *arg) 76 { 77 78 fprintf(stderr, "rumpuser: threads not available\n"); 79 abort(); 80 } 81 82 /*ARGSUSED*/ 83 int 84 rumpuser_thread_create(void *(*f)(void *), void *arg, const char *thrname, 85 int joinable, void **tptr) 86 { 87 88 fprintf(stderr, "rumpuser: threads not available\n"); 89 abort(); 90 return 0; 91 } 92 93 void 94 rumpuser_thread_exit(void) 95 { 96 97 fprintf(stderr, "rumpuser: threads not available\n"); 98 abort(); 99 } 100 101 void 102 rumpuser_mutex_init(struct rumpuser_mtx **mtx) 103 { 104 105 *mtx = calloc(1, sizeof(struct rumpuser_mtx)); 106 } 107 108 void 109 rumpuser_mutex_init_kmutex(struct rumpuser_mtx **mtx, int isspin) 110 { 111 112 *mtx = calloc(1, sizeof(struct rumpuser_mtx)); 113 } 114 115 void 116 rumpuser_mutex_enter(struct rumpuser_mtx *mtx) 117 { 118 119 mtx->v++; 120 mtx->o = curlwp; 121 } 122 123 void 124 rumpuser_mutex_enter_nowrap(struct rumpuser_mtx *mtx) 125 { 126 127 rumpuser_mutex_enter(mtx); 128 } 129 130 int 131 rumpuser_mutex_tryenter(struct rumpuser_mtx *mtx) 132 { 133 134 mtx->v++; 135 return 1; 136 } 137 138 void 139 rumpuser_mutex_exit(struct rumpuser_mtx *mtx) 140 { 141 142 assert(mtx->v > 0); 143 if (--mtx->v == 0) 144 mtx->o = NULL; 145 } 146 147 void 148 rumpuser_mutex_destroy(struct rumpuser_mtx *mtx) 149 { 150 151 free(mtx); 152 } 153 154 struct lwp * 155 rumpuser_mutex_owner(struct rumpuser_mtx *mtx) 156 { 157 158 return mtx->o; 159 } 160 161 void 162 rumpuser_rw_init(struct rumpuser_rw **rw) 163 { 164 165 *rw = calloc(1, sizeof(struct rumpuser_rw)); 166 } 167 168 void 169 rumpuser_rw_enter(struct rumpuser_rw *rw, int write) 170 { 171 172 if (write) { 173 rw->v++; 174 assert(rw->v == 1); 175 } else { 176 assert(rw->v <= 0); 177 rw->v--; 178 } 179 } 180 181 int 182 rumpuser_rw_tryenter(struct rumpuser_rw *rw, int write) 183 { 184 185 rumpuser_rw_enter(rw, write); 186 return 1; 187 } 188 189 void 190 rumpuser_rw_exit(struct rumpuser_rw *rw) 191 { 192 193 if (rw->v > 0) { 194 assert(rw->v == 1); 195 rw->v--; 196 } else { 197 rw->v++; 198 } 199 } 200 201 void 202 rumpuser_rw_destroy(struct rumpuser_rw *rw) 203 { 204 205 free(rw); 206 } 207 208 int 209 rumpuser_rw_held(struct rumpuser_rw *rw) 210 { 211 212 return rw->v != 0; 213 } 214 215 int 216 rumpuser_rw_rdheld(struct rumpuser_rw *rw) 217 { 218 219 return rw->v < 0; 220 } 221 222 int 223 rumpuser_rw_wrheld(struct rumpuser_rw *rw) 224 { 225 226 return rw->v > 0; 227 } 228 229 /*ARGSUSED*/ 230 void 231 rumpuser_cv_init(struct rumpuser_cv **cv) 232 { 233 234 } 235 236 /*ARGSUSED*/ 237 void 238 rumpuser_cv_destroy(struct rumpuser_cv *cv) 239 { 240 241 } 242 243 /*ARGSUSED*/ 244 void 245 rumpuser_cv_wait(struct rumpuser_cv *cv, struct rumpuser_mtx *mtx) 246 { 247 248 } 249 250 /*ARGSUSED*/ 251 int 252 rumpuser_cv_timedwait(struct rumpuser_cv *cv, struct rumpuser_mtx *mtx, 253 int64_t sec, int64_t nsec) 254 { 255 struct timespec ts; 256 257 /*LINTED*/ 258 ts.tv_sec = sec; 259 /*LINTED*/ 260 ts.tv_nsec = nsec; 261 262 nanosleep(&ts, NULL); 263 return 0; 264 } 265 266 /*ARGSUSED*/ 267 void 268 rumpuser_cv_signal(struct rumpuser_cv *cv) 269 { 270 271 } 272 273 /*ARGSUSED*/ 274 void 275 rumpuser_cv_broadcast(struct rumpuser_cv *cv) 276 { 277 278 } 279 280 /*ARGSUSED*/ 281 int 282 rumpuser_cv_has_waiters(struct rumpuser_cv *cv) 283 { 284 285 return 0; 286 } 287 288 /* 289 * curlwp 290 */ 291 292 void 293 rumpuser_set_curlwp(struct lwp *l) 294 { 295 296 curlwp = l; 297 } 298 299 struct lwp * 300 rumpuser_get_curlwp(void) 301 { 302 303 return curlwp; 304 } 305
Indexes created Wed Oct 01 07:09:59 GMT 2025