X-Git-Url: https://git.saurik.com/apple/xnu.git/blobdiff_plain/b7266188b87f3620ec3f9f717e57194a7dd989fe..eee3565979933af707c711411001ba11fe406a3c:/bsd/sys/pthread_internal.h diff --git a/bsd/sys/pthread_internal.h b/bsd/sys/pthread_internal.h index 7d0cfae29..634470f89 100644 --- a/bsd/sys/pthread_internal.h +++ b/bsd/sys/pthread_internal.h @@ -29,112 +29,22 @@ #ifndef _SYS_PTHREAD_INTERNAL_H_ #define _SYS_PTHREAD_INTERNAL_H_ -#undef pthread_mutexattr_t; - +#include #include -#define WORKITEM_SIZE 64 -#define WORKQUEUE_NUMPRIOS 3 - -#define WORKQUEUE_OVERCOMMIT 0x10000 - -struct threadlist { - TAILQ_ENTRY(threadlist) th_entry; - thread_t th_thread; - int th_flags; - uint16_t th_affinity_tag; - uint8_t th_priority; - uint8_t th_policy; - struct workqueue *th_workq; - mach_vm_size_t th_stacksize; - mach_vm_size_t th_allocsize; - mach_vm_offset_t th_stackaddr; - mach_port_name_t th_thport; -}; -#define TH_LIST_INITED 0x01 -#define TH_LIST_RUNNING 0x02 -#define TH_LIST_BLOCKED 0x04 -#define TH_LIST_SUSPENDED 0x08 -#define TH_LIST_BUSY 0x10 -#define TH_LIST_NEED_WAKEUP 0x20 - -struct workitem { - TAILQ_ENTRY(workitem) wi_entry; - user_addr_t wi_item; - uint32_t wi_affinity; +struct ksyn_waitq_element { +#if __LP64__ + char opaque[48]; +#else + char opaque[32]; +#endif }; -struct workitemlist { - TAILQ_HEAD(, workitem) wl_itemlist; - TAILQ_HEAD(, workitem) wl_freelist; -}; - -struct workqueue { - struct workitem wq_array[WORKITEM_SIZE * WORKQUEUE_NUMPRIOS]; - proc_t wq_proc; - vm_map_t wq_map; - task_t wq_task; - thread_call_t wq_atimer_call; - int wq_flags; - int wq_lflags; - int wq_itemcount; - uint64_t wq_thread_yielded_timestamp; - uint32_t wq_thread_yielded_count; - uint32_t wq_timer_interval; - uint32_t wq_affinity_max; - uint32_t wq_threads_scheduled; - uint32_t wq_nthreads; - uint32_t wq_thidlecount; - uint32_t wq_reqconc[WORKQUEUE_NUMPRIOS]; /* requested concurrency for each priority level */ - struct workitemlist wq_list[WORKQUEUE_NUMPRIOS]; /* priority based item list */ - uint32_t wq_list_bitmap; - TAILQ_HEAD(, threadlist) wq_thrunlist; - TAILQ_HEAD(, threadlist) wq_thidlelist; - uint32_t *wq_thactive_count[WORKQUEUE_NUMPRIOS]; - uint32_t *wq_thscheduled_count[WORKQUEUE_NUMPRIOS]; - uint64_t *wq_lastblocked_ts[WORKQUEUE_NUMPRIOS]; -}; -#define WQ_LIST_INITED 0x01 -#define WQ_ATIMER_RUNNING 0x02 -#define WQ_EXITING 0x04 - -#define WQL_ATIMER_BUSY 0x01 -#define WQL_ATIMER_WAITING 0x02 - - -#define WQ_VECT_SET_BIT(vector, bit) \ - vector[(bit) / 32] |= (1 << ((bit) % 32)) - -#define WQ_VECT_CLEAR_BIT(vector, bit) \ - vector[(bit) / 32] &= ~(1 << ((bit) % 32)) - -#define WQ_VECT_TEST_BIT(vector, bit) \ - vector[(bit) / 32] & (1 << ((bit) % 32)) - - -#define WORKQUEUE_MAXTHREADS 512 -#define WQ_YIELDED_THRESHOLD 2000 -#define WQ_YIELDED_WINDOW_USECS 30000 -#define WQ_STALLED_WINDOW_USECS 200 -#define WQ_REDUCE_POOL_WINDOW_USECS 5000000 -#define WQ_MAX_TIMER_INTERVAL_USECS 50000 - -/* workq_kernreturn commands */ -#define WQOPS_QUEUE_ADD 1 -#define WQOPS_QUEUE_REMOVE 2 -#define WQOPS_THREAD_RETURN 4 -#define WQOPS_THREAD_SETCONC 8 - -#define PTH_DEFAULT_STACKSIZE 512*1024 -#define PTH_DEFAULT_GUARDSIZE 4*1024 -#define MAX_PTHREAD_SIZE 64*1024 - +void workqueue_mark_exiting(struct proc *); void workqueue_exit(struct proc *); - void pthread_init(void); -extern lck_grp_attr_t *pthread_lck_grp_attr; -extern lck_grp_t *pthread_lck_grp; -extern lck_attr_t *pthread_lck_attr; +int thread_qos_from_pthread_priority(unsigned long, unsigned long *); +unsigned long pthread_priority_canonicalize(unsigned long priority, boolean_t propagation); #endif /* _SYS_PTHREAD_INTERNAL_H_ */