| 1 | /* |
| 2 | * CDDL HEADER START |
| 3 | * |
| 4 | * The contents of this file are subject to the terms of the |
| 5 | * Common Development and Distribution License (the "License"). |
| 6 | * You may not use this file except in compliance with the License. |
| 7 | * |
| 8 | * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE |
| 9 | * or http://www.opensolaris.org/os/licensing. |
| 10 | * See the License for the specific language governing permissions |
| 11 | * and limitations under the License. |
| 12 | * |
| 13 | * When distributing Covered Code, include this CDDL HEADER in each |
| 14 | * file and include the License file at usr/src/OPENSOLARIS.LICENSE. |
| 15 | * If applicable, add the following below this CDDL HEADER, with the |
| 16 | * fields enclosed by brackets "[]" replaced with your own identifying |
| 17 | * information: Portions Copyright [yyyy] [name of copyright owner] |
| 18 | * |
| 19 | * CDDL HEADER END |
| 20 | */ |
| 21 | /* |
| 22 | * Copyright (c) 2005, 2010, Oracle and/or its affiliates. All rights reserved. |
| 23 | * Copyright (c) 2012, 2015 by Delphix. All rights reserved. |
| 24 | * Copyright (c) 2012, Joyent, Inc. All rights reserved. |
| 25 | */ |
| 26 | /* |
| 27 | * Copyright 2011 Nexenta Systems, Inc. All rights reserved. |
| 28 | */ |
| 29 | |
| 30 | #ifndef _SYS_ZFS_CONTEXT_H |
| 31 | #define _SYS_ZFS_CONTEXT_H |
| 32 | |
| 33 | #ifdef __cplusplus |
| 34 | extern "C" { |
| 35 | #endif |
| 36 | |
| 37 | #define _SYS_MUTEX_H |
| 38 | #define _SYS_RWLOCK_H |
| 39 | #define _SYS_CONDVAR_H |
| 40 | #define _SYS_SYSTM_H |
| 41 | #define _SYS_T_LOCK_H |
| 42 | #define _SYS_VNODE_H |
| 43 | #define _SYS_VFS_H |
| 44 | #define _SYS_SUNDDI_H |
| 45 | #define _SYS_CALLB_H |
| 46 | #ifndef __NetBSD__ |
| 47 | #define _SYS_SCHED_H_ |
| 48 | #else |
| 49 | #define _SYS_CONDVAR_H_ |
| 50 | #define _SYS_MUTEX_H_ |
| 51 | #define _SYS_RWLOCK_H_ |
| 52 | #endif |
| 53 | |
| 54 | #include <solaris.h> |
| 55 | #include <stdio.h> |
| 56 | #include <stdlib.h> |
| 57 | #include <stddef.h> |
| 58 | #include <stdarg.h> |
| 59 | #include <fcntl.h> |
| 60 | #include <unistd.h> |
| 61 | #include <errno.h> |
| 62 | #include <string.h> |
| 63 | #include <strings.h> |
| 64 | #include <thread.h> |
| 65 | #include <assert.h> |
| 66 | #include <limits.h> |
| 67 | #include <dirent.h> |
| 68 | #include <time.h> |
| 69 | #include <math.h> |
| 70 | #include <umem.h> |
| 71 | #include <inttypes.h> |
| 72 | #include <fsshare.h> |
| 73 | #include <pthread.h> |
| 74 | #include <sched.h> |
| 75 | #include <sys/debug.h> |
| 76 | #include <sys/note.h> |
| 77 | #include <sys/types.h> |
| 78 | #include <sys/cred.h> |
| 79 | #include <sys/atomic.h> |
| 80 | #include <sys/sysmacros.h> |
| 81 | #include <sys/bitmap.h> |
| 82 | #include <sys/resource.h> |
| 83 | #include <sys/byteorder.h> |
| 84 | #include <sys/list.h> |
| 85 | #include <sys/time.h> |
| 86 | #include <sys/uio.h> |
| 87 | #include <sys/mntent.h> |
| 88 | #include <sys/mnttab.h> |
| 89 | #include <sys/zfs_debug.h> |
| 90 | #include <sys/sdt.h> |
| 91 | #include <sys/kstat.h> |
| 92 | #include <sys/u8_textprep.h> |
| 93 | #include <sys/kernel.h> |
| 94 | #include <sys/disk.h> |
| 95 | #include <sys/sysevent.h> |
| 96 | #include <sys/sysevent/eventdefs.h> |
| 97 | #include <sys/sysevent/dev.h> |
| 98 | #ifndef __NetBSD__ |
| 99 | #include <machine/atomic.h> |
| 100 | #else |
| 101 | #include <sys/atomic.h> |
| 102 | #endif |
| 103 | #include <sys/debug.h> |
| 104 | #ifdef illumos |
| 105 | #include "zfs.h" |
| 106 | #endif |
| 107 | |
| 108 | #define ZFS_EXPORTS_PATH "/etc/zfs/exports" |
| 109 | |
| 110 | /* |
| 111 | * Debugging |
| 112 | */ |
| 113 | |
| 114 | /* |
| 115 | * Note that we are not using the debugging levels. |
| 116 | */ |
| 117 | |
| 118 | #define CE_CONT 0 /* continuation */ |
| 119 | #define CE_NOTE 1 /* notice */ |
| 120 | #define CE_WARN 2 /* warning */ |
| 121 | #define CE_PANIC 3 /* panic */ |
| 122 | #define CE_IGNORE 4 /* print nothing */ |
| 123 | |
| 124 | /* |
| 125 | * ZFS debugging |
| 126 | */ |
| 127 | |
| 128 | #define ZFS_LOG(...) do { } while (0) |
| 129 | |
| 130 | typedef u_longlong_t rlim64_t; |
| 131 | #define RLIM64_INFINITY ((rlim64_t)-3) |
| 132 | |
| 133 | #ifdef ZFS_DEBUG |
| 134 | extern void dprintf_setup(int *argc, char **argv); |
| 135 | #endif /* ZFS_DEBUG */ |
| 136 | |
| 137 | extern void cmn_err(int, const char *, ...); |
| 138 | extern void vcmn_err(int, const char *, __va_list); |
| 139 | extern void panic(const char *, ...); |
| 140 | extern void vpanic(const char *, __va_list); |
| 141 | |
| 142 | #define fm_panic panic |
| 143 | |
| 144 | extern int aok; |
| 145 | |
| 146 | /* |
| 147 | * DTrace SDT probes have different signatures in userland than they do in |
| 148 | * the kernel. If they're being used in kernel code, re-define them out of |
| 149 | * existence for their counterparts in libzpool. |
| 150 | * |
| 151 | * Here's an example of how to use the set-error probes in userland: |
| 152 | * zfs$target:::set-error /arg0 == EBUSY/ {stack();} |
| 153 | * |
| 154 | * Here's an example of how to use DTRACE_PROBE probes in userland: |
| 155 | * If there is a probe declared as follows: |
| 156 | * DTRACE_PROBE2(zfs__probe_name, uint64_t, blkid, dnode_t *, dn); |
| 157 | * Then you can use it as follows: |
| 158 | * zfs$target:::probe2 /copyinstr(arg0) == "zfs__probe_name"/ |
| 159 | * {printf("%u %p\n", arg1, arg2);} |
| 160 | */ |
| 161 | |
| 162 | #ifdef DTRACE_PROBE |
| 163 | #undef DTRACE_PROBE |
| 164 | #endif /* DTRACE_PROBE */ |
| 165 | #ifdef illumos |
| 166 | #define DTRACE_PROBE(a) \ |
| 167 | ZFS_PROBE0(#a) |
| 168 | #endif |
| 169 | |
| 170 | #ifdef DTRACE_PROBE1 |
| 171 | #undef DTRACE_PROBE1 |
| 172 | #endif /* DTRACE_PROBE1 */ |
| 173 | #ifdef illumos |
| 174 | #define DTRACE_PROBE1(a, b, c) \ |
| 175 | ZFS_PROBE1(#a, (unsigned long)c) |
| 176 | #endif |
| 177 | |
| 178 | #ifdef DTRACE_PROBE2 |
| 179 | #undef DTRACE_PROBE2 |
| 180 | #endif /* DTRACE_PROBE2 */ |
| 181 | #ifdef illumos |
| 182 | #define DTRACE_PROBE2(a, b, c, d, e) \ |
| 183 | ZFS_PROBE2(#a, (unsigned long)c, (unsigned long)e) |
| 184 | #endif |
| 185 | |
| 186 | #ifdef DTRACE_PROBE3 |
| 187 | #undef DTRACE_PROBE3 |
| 188 | #endif /* DTRACE_PROBE3 */ |
| 189 | #ifdef illumos |
| 190 | #define DTRACE_PROBE3(a, b, c, d, e, f, g) \ |
| 191 | ZFS_PROBE3(#a, (unsigned long)c, (unsigned long)e, (unsigned long)g) |
| 192 | #endif |
| 193 | |
| 194 | #ifdef DTRACE_PROBE4 |
| 195 | #undef DTRACE_PROBE4 |
| 196 | #endif /* DTRACE_PROBE4 */ |
| 197 | #ifdef illumos |
| 198 | #define DTRACE_PROBE4(a, b, c, d, e, f, g, h, i) \ |
| 199 | ZFS_PROBE4(#a, (unsigned long)c, (unsigned long)e, (unsigned long)g, \ |
| 200 | (unsigned long)i) |
| 201 | #endif |
| 202 | |
| 203 | #ifdef illumos |
| 204 | /* |
| 205 | * We use the comma operator so that this macro can be used without much |
| 206 | * additional code. For example, "return (EINVAL);" becomes |
| 207 | * "return (SET_ERROR(EINVAL));". Note that the argument will be evaluated |
| 208 | * twice, so it should not have side effects (e.g. something like: |
| 209 | * "return (SET_ERROR(log_error(EINVAL, info)));" would log the error twice). |
| 210 | */ |
| 211 | #define SET_ERROR(err) (ZFS_SET_ERROR(err), err) |
| 212 | #else /* !illumos */ |
| 213 | |
| 214 | #define DTRACE_PROBE(a) ((void)0) |
| 215 | #define DTRACE_PROBE1(a, b, c) ((void)0) |
| 216 | #define DTRACE_PROBE2(a, b, c, d, e) ((void)0) |
| 217 | #define DTRACE_PROBE3(a, b, c, d, e, f, g) ((void)0) |
| 218 | #define DTRACE_PROBE4(a, b, c, d, e, f, g, h, i) ((void)0) |
| 219 | |
| 220 | #define SET_ERROR(err) (err) |
| 221 | #endif /* !illumos */ |
| 222 | |
| 223 | /* |
| 224 | * Threads |
| 225 | */ |
| 226 | #define curthread ((void *)(uintptr_t)thr_self()) |
| 227 | |
| 228 | #define kpreempt(x) sched_yield() |
| 229 | |
| 230 | typedef struct kthread kthread_t; |
| 231 | |
| 232 | #define thread_create(stk, stksize, func, arg, len, pp, state, pri) \ |
| 233 | zk_thread_create(func, arg) |
| 234 | #define thread_exit() thr_exit(NULL) |
| 235 | #define thread_join(t) panic("libzpool cannot join threads") |
| 236 | |
| 237 | #define newproc(f, a, cid, pri, ctp, pid) (ENOSYS) |
| 238 | |
| 239 | /* in libzpool, p0 exists only to have its address taken */ |
| 240 | struct proc { |
| 241 | uintptr_t this_is_never_used_dont_dereference_it; |
| 242 | }; |
| 243 | |
| 244 | extern struct proc p0; |
| 245 | #define curproc (&p0) |
| 246 | |
| 247 | #define PS_NONE -1 |
| 248 | |
| 249 | extern kthread_t *zk_thread_create(void (*func)(), void *arg); |
| 250 | |
| 251 | #define issig(why) (FALSE) |
| 252 | #define ISSIG(thr, why) (FALSE) |
| 253 | |
| 254 | /* |
| 255 | * Mutexes |
| 256 | */ |
| 257 | typedef struct kmutex { |
| 258 | void *m_owner; |
| 259 | boolean_t initialized; |
| 260 | mutex_t m_lock; |
| 261 | } kmutex_t; |
| 262 | |
| 263 | #define MUTEX_DEFAULT USYNC_THREAD |
| 264 | #undef MUTEX_HELD |
| 265 | #undef MUTEX_NOT_HELD |
| 266 | #define MUTEX_HELD(m) ((m)->m_owner == curthread) |
| 267 | #define MUTEX_NOT_HELD(m) (!MUTEX_HELD(m)) |
| 268 | #define _mutex_held(m) pthread_mutex_isowned_np(m) |
| 269 | |
| 270 | /* |
| 271 | * Argh -- we have to get cheesy here because the kernel and userland |
| 272 | * have different signatures for the same routine. |
| 273 | */ |
| 274 | //extern int _mutex_init(mutex_t *mp, int type, void *arg); |
| 275 | //extern int _mutex_destroy(mutex_t *mp); |
| 276 | //extern int _mutex_owned(mutex_t *mp); |
| 277 | |
| 278 | #define mutex_init(mp, b, c, d) zmutex_init((kmutex_t *)(mp)) |
| 279 | #define mutex_destroy(mp) zmutex_destroy((kmutex_t *)(mp)) |
| 280 | #define mutex_owned(mp) zmutex_owned((kmutex_t *)(mp)) |
| 281 | |
| 282 | extern void zmutex_init(kmutex_t *mp); |
| 283 | extern void zmutex_destroy(kmutex_t *mp); |
| 284 | extern int zmutex_owned(kmutex_t *mp); |
| 285 | extern void mutex_enter(kmutex_t *mp); |
| 286 | extern void mutex_exit(kmutex_t *mp); |
| 287 | extern int mutex_tryenter(kmutex_t *mp); |
| 288 | extern void *mutex_owner(kmutex_t *mp); |
| 289 | |
| 290 | /* |
| 291 | * RW locks |
| 292 | */ |
| 293 | typedef struct krwlock { |
| 294 | int rw_count; |
| 295 | void *rw_owner; |
| 296 | boolean_t initialized; |
| 297 | rwlock_t rw_lock; |
| 298 | } krwlock_t; |
| 299 | |
| 300 | typedef int krw_t; |
| 301 | |
| 302 | #define RW_READER 0 |
| 303 | #define RW_WRITER 1 |
| 304 | #define RW_DEFAULT USYNC_THREAD |
| 305 | |
| 306 | #undef RW_READ_HELD |
| 307 | #define RW_READ_HELD(x) ((x)->rw_owner == NULL && (x)->rw_count > 0) |
| 308 | |
| 309 | #undef RW_WRITE_HELD |
| 310 | #define RW_WRITE_HELD(x) ((x)->rw_owner == curthread) |
| 311 | #define RW_LOCK_HELD(x) rw_lock_held(x) |
| 312 | |
| 313 | #undef RW_LOCK_HELD |
| 314 | #define RW_LOCK_HELD(x) (RW_READ_HELD(x) || RW_WRITE_HELD(x)) |
| 315 | |
| 316 | extern void rw_init(krwlock_t *rwlp, char *name, int type, void *arg); |
| 317 | extern void rw_destroy(krwlock_t *rwlp); |
| 318 | extern void rw_enter(krwlock_t *rwlp, krw_t rw); |
| 319 | extern int rw_tryenter(krwlock_t *rwlp, krw_t rw); |
| 320 | extern int rw_tryupgrade(krwlock_t *rwlp); |
| 321 | extern void rw_exit(krwlock_t *rwlp); |
| 322 | extern int rw_lock_held(krwlock_t *rwlp); |
| 323 | #define rw_downgrade(rwlp) do { } while (0) |
| 324 | |
| 325 | extern uid_t crgetuid(cred_t *cr); |
| 326 | extern uid_t crgetruid(cred_t *cr); |
| 327 | extern gid_t crgetgid(cred_t *cr); |
| 328 | extern int crgetngroups(cred_t *cr); |
| 329 | extern gid_t *crgetgroups(cred_t *cr); |
| 330 | |
| 331 | /* |
| 332 | * Condition variables |
| 333 | */ |
| 334 | typedef cond_t kcondvar_t; |
| 335 | |
| 336 | #define CV_DEFAULT USYNC_THREAD |
| 337 | #define CALLOUT_FLAG_ABSOLUTE 0x2 |
| 338 | |
| 339 | extern void cv_init(kcondvar_t *cv, char *name, int type, void *arg); |
| 340 | extern void cv_destroy(kcondvar_t *cv); |
| 341 | extern void cv_wait(kcondvar_t *cv, kmutex_t *mp); |
| 342 | extern clock_t cv_timedwait(kcondvar_t *cv, kmutex_t *mp, clock_t abstime); |
| 343 | extern clock_t cv_timedwait_hires(kcondvar_t *cvp, kmutex_t *mp, hrtime_t tim, |
| 344 | hrtime_t res, int flag); |
| 345 | extern void cv_signal(kcondvar_t *cv); |
| 346 | extern void cv_broadcast(kcondvar_t *cv); |
| 347 | |
| 348 | /* |
| 349 | * Thread-specific data |
| 350 | */ |
| 351 | #define tsd_get(k) pthread_getspecific(k) |
| 352 | #define tsd_set(k, v) pthread_setspecific(k, v) |
| 353 | #define tsd_create(kp, d) pthread_key_create(kp, d) |
| 354 | #define tsd_destroy(kp) /* nothing */ |
| 355 | |
| 356 | /* |
| 357 | * Kernel memory |
| 358 | */ |
| 359 | #define KM_SLEEP UMEM_NOFAIL |
| 360 | #define KM_PUSHPAGE KM_SLEEP |
| 361 | #define KM_NOSLEEP UMEM_DEFAULT |
| 362 | #define KMC_NODEBUG UMC_NODEBUG |
| 363 | #define KMC_NOTOUCH 0 /* not needed for userland caches */ |
| 364 | #define KM_NODEBUG 0 |
| 365 | #define kmem_alloc(_s, _f) umem_alloc(_s, _f) |
| 366 | #define kmem_zalloc(_s, _f) umem_zalloc(_s, _f) |
| 367 | #define kmem_free(_b, _s) umem_free(_b, _s) |
| 368 | #define kmem_size() (physmem * PAGESIZE) |
| 369 | #define kmem_cache_create(_a, _b, _c, _d, _e, _f, _g, _h, _i) \ |
| 370 | umem_cache_create(_a, _b, _c, _d, _e, _f, _g, _h, _i) |
| 371 | #define kmem_cache_destroy(_c) umem_cache_destroy(_c) |
| 372 | #define kmem_cache_alloc(_c, _f) umem_cache_alloc(_c, _f) |
| 373 | #define kmem_cache_free(_c, _b) umem_cache_free(_c, _b) |
| 374 | #define kmem_debugging() 0 |
| 375 | #define kmem_cache_reap_now(_c) /* nothing */ |
| 376 | #define kmem_cache_set_move(_c, _cb) /* nothing */ |
| 377 | #define POINTER_INVALIDATE(_pp) /* nothing */ |
| 378 | #define POINTER_IS_VALID(_p) 0 |
| 379 | |
| 380 | typedef umem_cache_t kmem_cache_t; |
| 381 | |
| 382 | typedef enum kmem_cbrc { |
| 383 | KMEM_CBRC_YES, |
| 384 | KMEM_CBRC_NO, |
| 385 | KMEM_CBRC_LATER, |
| 386 | KMEM_CBRC_DONT_NEED, |
| 387 | KMEM_CBRC_DONT_KNOW |
| 388 | } kmem_cbrc_t; |
| 389 | |
| 390 | /* |
| 391 | * Task queues |
| 392 | */ |
| 393 | typedef struct taskq taskq_t; |
| 394 | typedef uintptr_t taskqid_t; |
| 395 | typedef void (task_func_t)(void *); |
| 396 | |
| 397 | typedef struct taskq_ent { |
| 398 | struct taskq_ent *tqent_next; |
| 399 | struct taskq_ent *tqent_prev; |
| 400 | task_func_t *tqent_func; |
| 401 | void *tqent_arg; |
| 402 | uintptr_t tqent_flags; |
| 403 | } taskq_ent_t; |
| 404 | |
| 405 | #define TQENT_FLAG_PREALLOC 0x1 /* taskq_dispatch_ent used */ |
| 406 | |
| 407 | #define TASKQ_PREPOPULATE 0x0001 |
| 408 | #define TASKQ_CPR_SAFE 0x0002 /* Use CPR safe protocol */ |
| 409 | #define TASKQ_DYNAMIC 0x0004 /* Use dynamic thread scheduling */ |
| 410 | #define TASKQ_THREADS_CPU_PCT 0x0008 /* Scale # threads by # cpus */ |
| 411 | #define TASKQ_DC_BATCH 0x0010 /* Mark threads as batch */ |
| 412 | |
| 413 | #define TQ_SLEEP KM_SLEEP /* Can block for memory */ |
| 414 | #define TQ_NOSLEEP KM_NOSLEEP /* cannot block for memory; may fail */ |
| 415 | #define TQ_NOQUEUE 0x02 /* Do not enqueue if can't dispatch */ |
| 416 | #define TQ_FRONT 0x08 /* Queue in front */ |
| 417 | |
| 418 | |
| 419 | extern taskq_t *system_taskq; |
| 420 | |
| 421 | extern taskq_t *taskq_create(const char *, int, pri_t, int, int, uint_t); |
| 422 | #define taskq_create_proc(a, b, c, d, e, p, f) \ |
| 423 | (taskq_create(a, b, c, d, e, f)) |
| 424 | #define taskq_create_sysdc(a, b, d, e, p, dc, f) \ |
| 425 | (taskq_create(a, b, maxclsyspri, d, e, f)) |
| 426 | extern taskqid_t taskq_dispatch(taskq_t *, task_func_t, void *, uint_t); |
| 427 | extern void taskq_dispatch_ent(taskq_t *, task_func_t, void *, uint_t, |
| 428 | taskq_ent_t *); |
| 429 | extern void taskq_destroy(taskq_t *); |
| 430 | extern void taskq_wait(taskq_t *); |
| 431 | extern int taskq_member(taskq_t *, void *); |
| 432 | extern void system_taskq_init(void); |
| 433 | extern void system_taskq_fini(void); |
| 434 | |
| 435 | #define taskq_dispatch_safe(tq, func, arg, flags, task) \ |
| 436 | taskq_dispatch((tq), (func), (arg), (flags)) |
| 437 | |
| 438 | #define XVA_MAPSIZE 3 |
| 439 | #define XVA_MAGIC 0x78766174 |
| 440 | |
| 441 | /* |
| 442 | * vnodes |
| 443 | */ |
| 444 | typedef struct vnode { |
| 445 | uint64_t v_size; |
| 446 | int v_fd; |
| 447 | char *v_path; |
| 448 | int v_dump_fd; |
| 449 | } vnode_t; |
| 450 | |
| 451 | extern char *vn_dumpdir; |
| 452 | #define AV_SCANSTAMP_SZ 32 /* length of anti-virus scanstamp */ |
| 453 | |
| 454 | typedef struct xoptattr { |
| 455 | timestruc_t xoa_createtime; /* Create time of file */ |
| 456 | uint8_t xoa_archive; |
| 457 | uint8_t xoa_system; |
| 458 | uint8_t xoa_readonly; |
| 459 | uint8_t xoa_hidden; |
| 460 | uint8_t xoa_nounlink; |
| 461 | uint8_t xoa_immutable; |
| 462 | uint8_t xoa_appendonly; |
| 463 | uint8_t xoa_nodump; |
| 464 | uint8_t xoa_settable; |
| 465 | uint8_t xoa_opaque; |
| 466 | uint8_t xoa_av_quarantined; |
| 467 | uint8_t xoa_av_modified; |
| 468 | uint8_t xoa_av_scanstamp[AV_SCANSTAMP_SZ]; |
| 469 | uint8_t xoa_reparse; |
| 470 | uint8_t xoa_offline; |
| 471 | uint8_t xoa_sparse; |
| 472 | } xoptattr_t; |
| 473 | |
| 474 | typedef struct vattr { |
| 475 | uint_t va_mask; /* bit-mask of attributes */ |
| 476 | u_offset_t va_size; /* file size in bytes */ |
| 477 | } vattr_t; |
| 478 | |
| 479 | |
| 480 | typedef struct xvattr { |
| 481 | vattr_t xva_vattr; /* Embedded vattr structure */ |
| 482 | uint32_t xva_magic; /* Magic Number */ |
| 483 | uint32_t xva_mapsize; /* Size of attr bitmap (32-bit words) */ |
| 484 | uint32_t *xva_rtnattrmapp; /* Ptr to xva_rtnattrmap[] */ |
| 485 | uint32_t xva_reqattrmap[XVA_MAPSIZE]; /* Requested attrs */ |
| 486 | uint32_t xva_rtnattrmap[XVA_MAPSIZE]; /* Returned attrs */ |
| 487 | xoptattr_t xva_xoptattrs; /* Optional attributes */ |
| 488 | } xvattr_t; |
| 489 | |
| 490 | typedef struct vsecattr { |
| 491 | uint_t vsa_mask; /* See below */ |
| 492 | int vsa_aclcnt; /* ACL entry count */ |
| 493 | void *vsa_aclentp; /* pointer to ACL entries */ |
| 494 | int vsa_dfaclcnt; /* default ACL entry count */ |
| 495 | void *vsa_dfaclentp; /* pointer to default ACL entries */ |
| 496 | size_t vsa_aclentsz; /* ACE size in bytes of vsa_aclentp */ |
| 497 | } vsecattr_t; |
| 498 | |
| 499 | #define AT_TYPE 0x00001 |
| 500 | #define AT_MODE 0x00002 |
| 501 | #define AT_UID 0x00004 |
| 502 | #define AT_GID 0x00008 |
| 503 | #define AT_FSID 0x00010 |
| 504 | #define AT_NODEID 0x00020 |
| 505 | #define AT_NLINK 0x00040 |
| 506 | #define AT_SIZE 0x00080 |
| 507 | #define AT_ATIME 0x00100 |
| 508 | #define AT_MTIME 0x00200 |
| 509 | #define AT_CTIME 0x00400 |
| 510 | #define AT_RDEV 0x00800 |
| 511 | #define AT_BLKSIZE 0x01000 |
| 512 | #define AT_NBLOCKS 0x02000 |
| 513 | #define AT_SEQ 0x08000 |
| 514 | #define AT_XVATTR 0x10000 |
| 515 | |
| 516 | #define CRCREAT 0 |
| 517 | |
| 518 | extern int fop_getattr(vnode_t *vp, vattr_t *vap); |
| 519 | |
| 520 | #define VOP_CLOSE(vp, f, c, o, cr, ct) 0 |
| 521 | #define VOP_PUTPAGE(vp, of, sz, fl, cr, ct) 0 |
| 522 | #ifndef __NetBSD__ |
| 523 | #define VOP_GETATTR(vp, vap, cr) fop_getattr((vp), (vap)); |
| 524 | #else |
| 525 | #define VOP_GETATTR(vp, vap, fl, cr, ct) fop_getattr((vp), (vap)); |
| 526 | #endif |
| 527 | |
| 528 | #define VOP_FSYNC(vp, f, cr, ct) fsync((vp)->v_fd) |
| 529 | |
| 530 | #define VN_RELE(vp) vn_close(vp, 0, NULL, NULL) |
| 531 | #define VN_RELE_ASYNC(vp, taskq) vn_close(vp, 0, NULL, NULL) |
| 532 | |
| 533 | #define vn_lock(vp, type) |
| 534 | #define VOP_UNLOCK(vp, type) |
| 535 | |
| 536 | extern int vn_open(char *path, int x1, int oflags, int mode, vnode_t **vpp, |
| 537 | int x2, int x3); |
| 538 | extern int vn_openat(char *path, int x1, int oflags, int mode, vnode_t **vpp, |
| 539 | int x2, int x3, vnode_t *vp, int fd); |
| 540 | extern int vn_rdwr(int uio, vnode_t *vp, void *addr, ssize_t len, |
| 541 | offset_t offset, int x1, int x2, rlim64_t x3, void *x4, ssize_t *residp); |
| 542 | extern void vn_close(vnode_t *vp, int openflag, cred_t *cr, kthread_t *td); |
| 543 | |
| 544 | #define vn_remove(path, x1, x2) remove(path) |
| 545 | #define vn_rename(from, to, seg) rename((from), (to)) |
| 546 | #define vn_is_readonly(vp) B_FALSE |
| 547 | |
| 548 | extern vnode_t *rootdir; |
| 549 | |
| 550 | #include <sys/file.h> /* for FREAD, FWRITE, etc */ |
| 551 | #define FTRUNC O_TRUNC |
| 552 | |
| 553 | /* |
| 554 | * Random stuff |
| 555 | */ |
| 556 | #define ddi_get_lbolt() (gethrtime() >> 23) |
| 557 | #define ddi_get_lbolt64() (gethrtime() >> 23) |
| 558 | #define hz 119 /* frequency when using gethrtime() >> 23 for lbolt */ |
| 559 | |
| 560 | extern void delay(clock_t ticks); |
| 561 | |
| 562 | #define SEC_TO_TICK(sec) ((sec) * hz) |
| 563 | #define NSEC_TO_TICK(nsec) ((nsec) / (NANOSEC / hz)) |
| 564 | |
| 565 | #define gethrestime_sec() time(NULL) |
| 566 | #define gethrestime(t) \ |
| 567 | do {\ |
| 568 | (t)->tv_sec = gethrestime_sec();\ |
| 569 | (t)->tv_nsec = 0;\ |
| 570 | } while (0); |
| 571 | |
| 572 | #define max_ncpus 64 |
| 573 | |
| 574 | #define minclsyspri 60 |
| 575 | #define maxclsyspri 99 |
| 576 | |
| 577 | #define CPU_SEQID (thr_self() & (max_ncpus - 1)) |
| 578 | |
| 579 | #define kcred NULL |
| 580 | #define CRED() NULL |
| 581 | |
| 582 | #ifndef ptob |
| 583 | #define ptob(x) ((x) * PAGESIZE) |
| 584 | #endif |
| 585 | |
| 586 | extern uint64_t physmem; |
| 587 | |
| 588 | #ifndef __NetBSD__ |
| 589 | extern int highbit64(uint64_t i); |
| 590 | #endif |
| 591 | extern int random_get_bytes(uint8_t *ptr, size_t len); |
| 592 | extern int random_get_pseudo_bytes(uint8_t *ptr, size_t len); |
| 593 | |
| 594 | extern void kernel_init(int); |
| 595 | extern void kernel_fini(void); |
| 596 | |
| 597 | struct spa; |
| 598 | extern void nicenum(uint64_t num, char *buf); |
| 599 | extern void show_pool_stats(struct spa *); |
| 600 | |
| 601 | typedef struct callb_cpr { |
| 602 | kmutex_t *cc_lockp; |
| 603 | } callb_cpr_t; |
| 604 | |
| 605 | #define CALLB_CPR_INIT(cp, lockp, func, name) { \ |
| 606 | (cp)->cc_lockp = lockp; \ |
| 607 | } |
| 608 | |
| 609 | #define CALLB_CPR_SAFE_BEGIN(cp) { \ |
| 610 | ASSERT(MUTEX_HELD((cp)->cc_lockp)); \ |
| 611 | } |
| 612 | |
| 613 | #define CALLB_CPR_SAFE_END(cp, lockp) { \ |
| 614 | ASSERT(MUTEX_HELD((cp)->cc_lockp)); \ |
| 615 | } |
| 616 | |
| 617 | #define CALLB_CPR_EXIT(cp) { \ |
| 618 | ASSERT(MUTEX_HELD((cp)->cc_lockp)); \ |
| 619 | mutex_exit((cp)->cc_lockp); \ |
| 620 | } |
| 621 | |
| 622 | #define zone_dataset_visible(x, y) (1) |
| 623 | #define INGLOBALZONE(z) (1) |
| 624 | |
| 625 | extern char *kmem_asprintf(const char *fmt, ...); |
| 626 | #define strfree(str) kmem_free((str), strlen(str) + 1) |
| 627 | |
| 628 | /* |
| 629 | * Hostname information |
| 630 | */ |
| 631 | extern struct utsname utsname; |
| 632 | extern char hw_serial[]; /* for userland-emulated hostid access */ |
| 633 | extern int ddi_strtoul(const char *str, char **nptr, int base, |
| 634 | unsigned long *result); |
| 635 | |
| 636 | extern int ddi_strtoull(const char *str, char **nptr, int base, |
| 637 | u_longlong_t *result); |
| 638 | |
| 639 | /* ZFS Boot Related stuff. */ |
| 640 | |
| 641 | struct _buf { |
| 642 | intptr_t _fd; |
| 643 | }; |
| 644 | |
| 645 | struct bootstat { |
| 646 | uint64_t st_size; |
| 647 | }; |
| 648 | |
| 649 | typedef struct ace_object { |
| 650 | uid_t a_who; |
| 651 | uint32_t a_access_mask; |
| 652 | uint16_t a_flags; |
| 653 | uint16_t a_type; |
| 654 | uint8_t a_obj_type[16]; |
| 655 | uint8_t a_inherit_obj_type[16]; |
| 656 | } ace_object_t; |
| 657 | |
| 658 | |
| 659 | #define ACE_ACCESS_ALLOWED_OBJECT_ACE_TYPE 0x05 |
| 660 | #define ACE_ACCESS_DENIED_OBJECT_ACE_TYPE 0x06 |
| 661 | #define ACE_SYSTEM_AUDIT_OBJECT_ACE_TYPE 0x07 |
| 662 | #define ACE_SYSTEM_ALARM_OBJECT_ACE_TYPE 0x08 |
| 663 | |
| 664 | extern struct _buf *kobj_open_file(char *name); |
| 665 | extern int kobj_read_file(struct _buf *file, char *buf, unsigned size, |
| 666 | unsigned off); |
| 667 | extern void kobj_close_file(struct _buf *file); |
| 668 | extern int kobj_get_filesize(struct _buf *file, uint64_t *size); |
| 669 | extern int zfs_secpolicy_snapshot_perms(const char *name, cred_t *cr); |
| 670 | extern int zfs_secpolicy_rename_perms(const char *from, const char *to, |
| 671 | cred_t *cr); |
| 672 | extern int zfs_secpolicy_destroy_perms(const char *name, cred_t *cr); |
| 673 | #ifndef __NetBSD__ |
| 674 | extern zoneid_t getzoneid(void); |
| 675 | #endif |
| 676 | /* Random compatibility stuff. */ |
| 677 | #define pwrite64(d, p, n, o) pwrite(d, p, n, o) |
| 678 | #define readdir64(d) readdir(d) |
| 679 | #define SIGPENDING(td) (0) |
| 680 | #define root_mount_wait() do { } while (0) |
| 681 | #define root_mounted() (1) |
| 682 | |
| 683 | struct file { |
| 684 | void *dummy; |
| 685 | }; |
| 686 | |
| 687 | #define FCREAT O_CREAT |
| 688 | #define FOFFMAX 0x0 |
| 689 | |
| 690 | /* SID stuff */ |
| 691 | typedef struct ksiddomain { |
| 692 | uint_t kd_ref; |
| 693 | uint_t kd_len; |
| 694 | char *kd_name; |
| 695 | } ksiddomain_t; |
| 696 | |
| 697 | ksiddomain_t *ksid_lookupdomain(const char *); |
| 698 | void ksiddomain_rele(ksiddomain_t *); |
| 699 | |
| 700 | typedef uint32_t idmap_rid_t; |
| 701 | |
| 702 | #define DDI_SLEEP KM_SLEEP |
| 703 | #define ddi_log_sysevent(_a, _b, _c, _d, _e, _f, _g) (0) |
| 704 | |
| 705 | #define SX_SYSINIT(name, lock, desc) |
| 706 | |
| 707 | #define SYSCTL_HANDLER_ARGS struct sysctl_oid *oidp, void *arg1, \ |
| 708 | intptr_t arg2, struct sysctl_req *req |
| 709 | |
| 710 | /* |
| 711 | * This describes the access space for a sysctl request. This is needed |
| 712 | * so that we can use the interface from the kernel or from user-space. |
| 713 | */ |
| 714 | struct sysctl_req { |
| 715 | struct thread *td; /* used for access checking */ |
| 716 | int lock; /* wiring state */ |
| 717 | void *oldptr; |
| 718 | size_t oldlen; |
| 719 | size_t oldidx; |
| 720 | int (*oldfunc)(struct sysctl_req *, const void *, size_t); |
| 721 | void *newptr; |
| 722 | size_t newlen; |
| 723 | size_t newidx; |
| 724 | int (*newfunc)(struct sysctl_req *, void *, size_t); |
| 725 | size_t validlen; |
| 726 | int flags; |
| 727 | }; |
| 728 | |
| 729 | SLIST_HEAD(sysctl_oid_list, sysctl_oid); |
| 730 | |
| 731 | /* |
| 732 | * This describes one "oid" in the MIB tree. Potentially more nodes can |
| 733 | * be hidden behind it, expanded by the handler. |
| 734 | */ |
| 735 | struct sysctl_oid { |
| 736 | struct sysctl_oid_list *oid_parent; |
| 737 | SLIST_ENTRY(sysctl_oid) oid_link; |
| 738 | int oid_number; |
| 739 | u_int oid_kind; |
| 740 | void *oid_arg1; |
| 741 | intptr_t oid_arg2; |
| 742 | const char *oid_name; |
| 743 | int (*oid_handler)(SYSCTL_HANDLER_ARGS); |
| 744 | const char *oid_fmt; |
| 745 | int oid_refcnt; |
| 746 | u_int oid_running; |
| 747 | const char *oid_descr; |
| 748 | }; |
| 749 | |
| 750 | #define SYSCTL_DECL(...) |
| 751 | #define SYSCTL_NODE(...) |
| 752 | #define SYSCTL_INT(...) |
| 753 | #define SYSCTL_UINT(...) |
| 754 | #define SYSCTL_ULONG(...) |
| 755 | #define SYSCTL_PROC(...) |
| 756 | #define SYSCTL_QUAD(...) |
| 757 | #define SYSCTL_UQUAD(...) |
| 758 | #ifdef TUNABLE_INT |
| 759 | #undef TUNABLE_INT |
| 760 | #undef TUNABLE_ULONG |
| 761 | #undef TUNABLE_QUAD |
| 762 | #endif |
| 763 | #define TUNABLE_INT(...) |
| 764 | #define TUNABLE_ULONG(...) |
| 765 | #define TUNABLE_QUAD(...) |
| 766 | |
| 767 | int sysctl_handle_64(SYSCTL_HANDLER_ARGS); |
| 768 | |
| 769 | /* Errors */ |
| 770 | |
| 771 | #ifndef ERESTART |
| 772 | #define ERESTART (-1) |
| 773 | #endif |
| 774 | |
| 775 | #if defined(illumos) || defined(__NetBSD__) |
| 776 | /* |
| 777 | * Cyclic information |
| 778 | */ |
| 779 | extern kmutex_t cpu_lock; |
| 780 | |
| 781 | typedef uintptr_t cyclic_id_t; |
| 782 | typedef uint16_t cyc_level_t; |
| 783 | typedef void (*cyc_func_t)(void *); |
| 784 | |
| 785 | #define CY_LOW_LEVEL 0 |
| 786 | #define CY_INFINITY INT64_MAX |
| 787 | #define CYCLIC_NONE ((cyclic_id_t)0) |
| 788 | |
| 789 | typedef struct cyc_time { |
| 790 | hrtime_t cyt_when; |
| 791 | hrtime_t cyt_interval; |
| 792 | } cyc_time_t; |
| 793 | |
| 794 | typedef struct cyc_handler { |
| 795 | cyc_func_t cyh_func; |
| 796 | void *cyh_arg; |
| 797 | cyc_level_t cyh_level; |
| 798 | } cyc_handler_t; |
| 799 | |
| 800 | extern cyclic_id_t cyclic_add(cyc_handler_t *, cyc_time_t *); |
| 801 | extern void cyclic_remove(cyclic_id_t); |
| 802 | extern int cyclic_reprogram(cyclic_id_t, hrtime_t); |
| 803 | #endif /* illumos */ |
| 804 | |
| 805 | #ifdef illumos |
| 806 | /* |
| 807 | * Buf structure |
| 808 | */ |
| 809 | #define B_BUSY 0x0001 |
| 810 | #define B_DONE 0x0002 |
| 811 | #define B_ERROR 0x0004 |
| 812 | #define B_READ 0x0040 /* read when I/O occurs */ |
| 813 | #define B_WRITE 0x0100 /* non-read pseudo-flag */ |
| 814 | |
| 815 | typedef struct buf { |
| 816 | int b_flags; |
| 817 | size_t b_bcount; |
| 818 | union { |
| 819 | caddr_t b_addr; |
| 820 | } b_un; |
| 821 | |
| 822 | lldaddr_t _b_blkno; |
| 823 | #define b_lblkno _b_blkno._f |
| 824 | size_t b_resid; |
| 825 | size_t b_bufsize; |
| 826 | int (*b_iodone)(struct buf *); |
| 827 | int b_error; |
| 828 | void *b_private; |
| 829 | } buf_t; |
| 830 | |
| 831 | extern void bioinit(buf_t *); |
| 832 | extern void biodone(buf_t *); |
| 833 | extern void bioerror(buf_t *, int); |
| 834 | extern int geterror(buf_t *); |
| 835 | #endif |
| 836 | |
| 837 | #ifdef __cplusplus |
| 838 | } |
| 839 | #endif |
| 840 | |
| 841 | #endif /* _SYS_ZFS_CONTEXT_H */ |
| 842 | |