]> git.saurik.com Git - apple/xnu.git/blobdiff - bsd/kern/bsd_stubs.c
xnu-2050.48.11.tar.gz
[apple/xnu.git] / bsd / kern / bsd_stubs.c
index cc8e42431c09565efe290d42180f5e567a357053..bc4537d355142402001eef7b920a24fea6a813a4 100644 (file)
 #include <mach/mach_types.h>
 #include <mach/vm_prot.h>
 #include <vm/vm_kern.h>
+#include <sys/stat.h>
 #include <vm/vm_map.h>
 #include <sys/systm.h>
+#include <kern/assert.h>
 #include <sys/conf.h>
 #include <sys/proc_internal.h>
 #include <sys/buf.h>   /* for SET */
+#include <sys/kernel.h>
 #include <sys/user.h>
 #include <sys/sysent.h>
 #include <sys/sysproto.h>
 
+/* XXX these should be in a common header somwhere, but aren't */
+extern int chrtoblk_set(int, int);
+extern vm_offset_t kmem_mb_alloc(vm_map_t, int, int);
+
+/* XXX most of these just exist to export; there's no good header for them*/
+void   pcb_synch(void);
+void   tbeproc(void *);
+
+TAILQ_HEAD(,devsw_lock) devsw_locks;
+lck_mtx_t devsw_lock_list_mtx;
+lck_grp_t *devsw_lock_grp;
+
 /* Just to satisfy pstat command */
 int     dmmin, dmmax, dmtext;
 
 vm_offset_t
-kmem_mb_alloc(vm_map_t  mbmap, int size) 
+kmem_mb_alloc(vm_map_t  mbmap, int size, int physContig
 {
-        vm_offset_t addr;
-       if (kernel_memory_allocate(mbmap, &addr, size,
-               0,
-               KMA_NOPAGEWAIT|KMA_KOBJECT|KMA_LOMEM) == KERN_SUCCESS)
-                       return(addr);
+        vm_offset_t addr = 0;
+       kern_return_t kr = KERN_SUCCESS;
+
+       if(!physContig)
+               kr = kernel_memory_allocate(mbmap, &addr, size,
+                       0, KMA_NOPAGEWAIT|KMA_KOBJECT|KMA_LOMEM);
        else
-               return(0);
-               
+               kr = kmem_alloc_contig(mbmap, &addr, size, PAGE_MASK, 
+                       0xfffff, 0, KMA_NOPAGEWAIT | KMA_KOBJECT | KMA_LOMEM);
+
+       if( kr != KERN_SUCCESS)
+               addr = 0;
+
+       return addr;
 }
 
 /*
@@ -70,14 +91,14 @@ current_proc(void)
        /* Never returns a NULL */
        struct uthread * ut;
        struct proc *p; 
-       thread_t thr_act = current_thread();
+       thread_t thread = current_thread();
 
-       ut = (struct uthread *)get_bsdthread_info(thr_act); 
+       ut = (struct uthread *)get_bsdthread_info(thread); 
        if (ut &&  (ut->uu_flag & UT_VFORK) && ut->uu_proc) {
                p = ut->uu_proc;
-               if ((p->p_flag & P_INVFORK) == 0) 
+               if ((p->p_lflag & P_LINVFORK) == 0) 
                        panic("returning child proc not under vfork");
-               if (p->p_vforkact != (void *)thr_act
+               if (p->p_vforkact != (void *)thread
                        panic("returning child proc which is not cur_act");
                return(p);
        }
@@ -92,8 +113,6 @@ current_proc(void)
 
 /* Device switch add delete routines */
 
-extern int nblkdev, nchrdev;
-
 struct bdevsw nobdev = NO_BDEVICE;
 struct cdevsw nocdev = NO_CDEVICE;
 /* 
@@ -101,24 +120,29 @@ struct cdevsw nocdev = NO_CDEVICE;
  *       else see whether the index is free
  *     return the major number that is free else -1
  *
+ *     if index is negative, we start
+ *     looking for a free slot at the absolute value of index,
+ *     instead of starting at 0
  */
 int
 bdevsw_isfree(int index)
 {
        struct bdevsw *devsw;
-       if (index == -1) {
-           devsw = bdevsw;
-           for(index=0; index < nblkdev; index++, devsw++) {
-               if(memcmp((char *)devsw, 
-                           (char *)&nobdev, 
-                           sizeof(struct bdevsw)) == 0)
-                   break;
+
+       if (index < 0) {
+           if (index == -1)
+               index = 1;      /* start at 1 to avoid collision with volfs (Radar 2842228) */
+           else
+               index = -index; /* start at least this far up in the table */
+           devsw = &bdevsw[index];
+           for(; index < nblkdev; index++, devsw++) {
+               if(memcmp((char *)devsw, 
+                           (char *)&nobdev, 
+                           sizeof(struct bdevsw)) == 0)
+                   break;
            }
-       } else {
-               /* NB: Not used below unless index is in range */
-               devsw = &bdevsw[index];
        }
-
+       devsw = &bdevsw[index];
        if ((index < 0) || (index >= nblkdev) ||
            (memcmp((char *)devsw, 
                          (char *)&nobdev, 
@@ -132,33 +156,22 @@ bdevsw_isfree(int index)
  *     if index is -1, find a free slot to add
  *       else see whether the slot is free
  *     return the major number that is used else -1
+ *
+ *     if index is negative, we start
+ *     looking for a free slot at the absolute value of index,
+ *     instead of starting at 0
  */
 int
 bdevsw_add(int index, struct bdevsw * bsw) 
 {
-       struct bdevsw *devsw;
-
-       if (index == -1) {
-           devsw = &bdevsw[1];         /* Start at slot 1 - this is a hack to fix the index=1 hack */
-           /* yes, start at 1 to avoid collision with volfs (Radar 2842228) */
-           for(index=1; index < nblkdev; index++, devsw++) {
-               if(memcmp((char *)devsw, 
-                           (char *)&nobdev, 
-                           sizeof(struct bdevsw)) == 0)
-                   break;
-           }
-       }
-       devsw = &bdevsw[index];
-       if ((index < 0) || (index >= nblkdev) ||
-           (memcmp((char *)devsw, 
-                         (char *)&nobdev, 
-                         sizeof(struct bdevsw)) != 0)) {
+       index = bdevsw_isfree(index);
+       if (index < 0) {
                return(-1);
        }
        bdevsw[index] = *bsw;
        return(index);
 }
-/* 
+/*
  *     if the slot has the same bsw, then remove
  *     else -1
  */
@@ -182,19 +195,27 @@ bdevsw_remove(int index, struct bdevsw * bsw)
  *     if index is -1, return a free slot if avaliable
  *       else see whether the index is free
  *     return the major number that is free else -1
+ *
+ *     if index is negative, we start
+ *     looking for a free slot at the absolute value of index,
+ *     instead of starting at 0
  */
 int
 cdevsw_isfree(int index)
 {
        struct cdevsw *devsw;
 
-       if (index == -1) {
-           devsw = cdevsw;
-           for(index=0; index < nchrdev; index++, devsw++) {
-               if(memcmp((char *)devsw, 
-                           (char *)&nocdev, 
-                           sizeof(struct cdevsw)) == 0)
-                   break;
+       if (index < 0) {
+           if (index == -1)
+               index = 0;
+           else
+               index = -index; /* start at least this far up in the table */
+           devsw = &cdevsw[index];
+           for(; index < nchrdev; index++, devsw++) {
+               if(memcmp((char *)devsw, 
+                           (char *)&nocdev, 
+                           sizeof(struct cdevsw)) == 0)
+                   break;
            }
        }
        devsw = &cdevsw[index];
@@ -211,33 +232,28 @@ cdevsw_isfree(int index)
  *     if index is -1, find a free slot to add
  *       else see whether the slot is free
  *     return the major number that is used else -1
+ *
+ *     if index is negative, we start
+ *     looking for a free slot at the absolute value of index,
+ *     instead of starting at 0
+ *
+ * NOTE:       In practice, -1 is unusable, since there are kernel internal
+ *             devices that call this function with absolute index values,
+ *             which will stomp on free-slot based assignments that happen
+ *             before them.  -24 is currently a safe starting point.
  */
 int
 cdevsw_add(int index, struct cdevsw * csw) 
 {
-       struct cdevsw *devsw;
-
-       if (index == -1) {
-           devsw = cdevsw;
-           for(index=0; index < nchrdev; index++, devsw++) {
-               if(memcmp((char *)devsw, 
-                           (char *)&nocdev, 
-                           sizeof(struct cdevsw)) == 0)
-                   break;
-           }
-       }
-       devsw = &cdevsw[index];
-       if ((index < 0) || (index >= nchrdev) ||
-           (memcmp((char *)devsw, 
-                         (char *)&nocdev, 
-                         sizeof(struct cdevsw)) != 0)) {
+       index = cdevsw_isfree(index);
+       if (index < 0) {
                return(-1);
        }
        cdevsw[index] = *csw;
        return(index);
 }
 /*
- *     if the index has the same bsw, then remove
+ *     if the slot has the same csw, then remove
  *     else -1
  */
 int
@@ -253,14 +269,13 @@ cdevsw_remove(int index, struct cdevsw * csw)
                return(-1);
        }
        cdevsw[index] = nocdev;
+       cdevsw_flags[index] = 0;
        return(index);
 }
 
 static int
 cdev_set_bdev(int cdev, int bdev)
 {
-       extern int chrtoblk_add(int cdev, int bdev);
-
        return (chrtoblk_set(cdev, bdev));
 }
 
@@ -278,88 +293,126 @@ cdevsw_add_with_bdev(int index, struct cdevsw * csw, int bdev)
        return (index);
 }
 
-issingleuser(void)
+int
+cdevsw_setkqueueok(int index, struct cdevsw *csw, int use_offset)
 {
-       char namep[16];
+       struct cdevsw *devsw;
+       uint64_t flags = CDEVSW_SELECT_KQUEUE;
 
+       devsw = &cdevsw[index];
+       if ((index < 0) || (index >= nchrdev) ||
+           (memcmp((char *)devsw, 
+                         (char *)csw, 
+                         sizeof(struct cdevsw)) != 0)) {
+               return(-1);
+       }
 
-       if (PE_parse_boot_arg("-s", namep)) {
-               return(1);
-       } else {
-               return(0);
+       if (use_offset) {
+               flags |= CDEVSW_USE_OFFSET;
        }
+
+       cdevsw_flags[index] = flags;
+       return 0;
 }
 
-void *
+#include <pexpert/pexpert.h>   /* for PE_parse_boot_arg */
+
+void
 tbeproc(void *procp)
 {
        struct proc *p = procp;
 
        if (p)
-               SET(p->p_flag, P_TBE);
+               OSBitOrAtomic(P_TBE, &p->p_flag);
        return;
 }
 
-
-/* 
- * WARNING - this is a temporary workaround for binary compatibility issues
- * with anti-piracy software that relies on patching ptrace (3928003).
- * This KPI will be removed in the system release after Tiger.
+/*
+ * Copy the "hostname" variable into a caller-provided buffer
+ * Returns: 0 for success, ENAMETOOLONG for insufficient buffer space.
+ * On success, "len" will be set to the number of characters preceding 
+ * the NULL character in the hostname.
  */
-uintptr_t temp_patch_ptrace(uintptr_t new_ptrace)
+int
+bsd_hostname(char *buf, int bufsize, int *len)
+{
+       /*
+        * "hostname" is null-terminated, and "hostnamelen" is equivalent to strlen(hostname).
+        */
+       if (hostnamelen < bufsize) {
+               strlcpy(buf, hostname, bufsize);
+               *len = hostnamelen;
+               return 0;
+       } else {
+               return ENAMETOOLONG;
+       }    
+}
+
+void
+devsw_lock(dev_t dev, int mode)
 {
-       struct sysent *         callp;
-       sy_call_t *                     old_ptrace;
-#ifndef __ppc__
-       boolean_t       funnel_state;
-#endif
-
-       if (new_ptrace == 0)
-               return(0);
-               
-#ifdef __ppc__
-       enter_funnel_section(kernel_flock);
-#else
-       funnel_state = thread_funnel_set(kernel_flock, TRUE);
-#endif
-       callp = &sysent[26];
-       old_ptrace = callp->sy_call;
+       devsw_lock_t newlock, tmplock;
+       int res;
+
+       assert(0 <= major(dev) && major(dev) < nchrdev);        
+       assert(mode == S_IFCHR || mode == S_IFBLK);
+
+       MALLOC(newlock, devsw_lock_t, sizeof(struct devsw_lock), M_TEMP, M_WAITOK | M_ZERO);
+       newlock->dl_dev = dev;
+       newlock->dl_thread = current_thread();
+       newlock->dl_mode = mode;
        
-       /* only allow one patcher of ptrace */
-       if (old_ptrace == (sy_call_t *) ptrace) {
-               callp->sy_call = (sy_call_t *) new_ptrace;
+       lck_mtx_lock_spin(&devsw_lock_list_mtx);
+retry:
+       TAILQ_FOREACH(tmplock, &devsw_locks, dl_list) {
+               if (tmplock->dl_dev == dev && tmplock->dl_mode == mode) {
+                       res = msleep(tmplock, &devsw_lock_list_mtx, PVFS, "devsw_lock", NULL);  
+                       assert(res == 0);
+                       goto retry;
+               }
+       }
+
+       TAILQ_INSERT_TAIL(&devsw_locks, newlock, dl_list);
+       lck_mtx_unlock(&devsw_lock_list_mtx);
+
+}
+void
+devsw_unlock(dev_t dev, int mode)
+{
+       devsw_lock_t tmplock;
+
+       assert(0 <= major(dev) && major(dev) < nchrdev);        
+
+       lck_mtx_lock_spin(&devsw_lock_list_mtx);
+
+       TAILQ_FOREACH(tmplock, &devsw_locks, dl_list) {
+               if (tmplock->dl_dev == dev && tmplock->dl_mode == mode) {       
+                       break;
+               }
        }
-       else {
-               old_ptrace = NULL;
+
+       if (tmplock == NULL) {
+               panic("Trying to unlock, and couldn't find lock.");
        }
-#ifdef __ppc__
-       exit_funnel_section( );
-#else
-       (void)thread_funnel_set(kernel_flock, funnel_state);
-#endif
+
+       if (tmplock->dl_thread != current_thread()) {
+               panic("Trying to unlock, but I don't hold the lock.");
+       }
+
+       wakeup(tmplock);
+       TAILQ_REMOVE(&devsw_locks, tmplock, dl_list);
        
-       return((uintptr_t)old_ptrace);
+       lck_mtx_unlock(&devsw_lock_list_mtx);
+       
+       FREE(tmplock, M_TEMP);
 }
 
-void temp_unpatch_ptrace(void)
+void
+devsw_init()
 {
-       struct sysent *         callp;
-#ifndef __ppc__
-       boolean_t       funnel_state;
-#endif
-               
-#ifdef __ppc__
-       enter_funnel_section(kernel_flock);
-#else
-       funnel_state = thread_funnel_set(kernel_flock, TRUE);
-#endif
-       callp = &sysent[26];
-       callp->sy_call = (sy_call_t *) ptrace;
-#ifdef __ppc__
-       exit_funnel_section( );
-#else
-       (void)thread_funnel_set(kernel_flock, funnel_state);
-#endif
-       
-       return;
+       devsw_lock_grp = lck_grp_alloc_init("devsw", NULL);
+       assert(devsw_lock_grp != NULL);
+
+       lck_mtx_init(&devsw_lock_list_mtx, devsw_lock_grp, NULL);
+       TAILQ_INIT(&devsw_locks);
 }