xnu-2782.10.72.tar.gz

[apple/xnu.git] / bsd / sys / pthread_internal.h

diff --git a/bsd/sys/pthread_internal.h b/bsd/sys/pthread_internal.h
index 6cc80f5f3bd182200b7370f602ad933125ce083c..4b0c212823a7b5498b03bb5a96c543657d95c01d 100644 (file)
--- a/bsd/sys/pthread_internal.h
+++ b/bsd/sys/pthread_internal.h
@@ -33,135 +33,16 @@
 #include <kern/thread_call.h>
 
 struct ksyn_waitq_element {
 #include <kern/thread_call.h>
 
 struct ksyn_waitq_element {

-       TAILQ_ENTRY(ksyn_waitq_element) kwe_list;       /* link to other list members */
-       void *          kwe_kwqqueue;                   /* queue blocked on */
-       uint32_t        kwe_flags;                      /* flags */
-       uint32_t        kwe_lockseq;                    /* the sequence of the entry */
-       uint32_t        kwe_count;                      /* upper bound on number of matches still pending */
-       uint32_t        kwe_psynchretval;               /* thread retval */
-       void            *kwe_uth;                       /* uthread */
+#if __LP64__
+       char opaque[48];
+#else
+       char opaque[32];
+#endif

 };
 };

-typedef struct ksyn_waitq_element * ksyn_waitq_element_t;
-
-/* kew_flags defns */
-#define KWE_THREAD_INWAIT       1
-#define KWE_THREAD_PREPOST      2
-#define KWE_THREAD_BROADCAST    4
-
-
-#define WORKITEM_SIZE 64
-
-#define WORKQUEUE_HIGH_PRIOQUEUE    0       /* high priority queue */
-#define WORKQUEUE_DEFAULT_PRIOQUEUE 1       /* default priority queue */
-#define WORKQUEUE_LOW_PRIOQUEUE     2       /* low priority queue */
-#define WORKQUEUE_BG_PRIOQUEUE      3       /* background priority queue */
-
-#define WORKQUEUE_NUMPRIOS 4
-
-#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
-#define TH_LIST_CONSTRAINED    0x40
-
-
-struct workitem {
-       TAILQ_ENTRY(workitem) wi_entry;
-       user_addr_t wi_item;
-       uint32_t wi_affinity;
-};
-
-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_constrained_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 WQL_EXCEEDED_CONSTRAINED_THREAD_LIMIT    0x04
-#define WQL_EXCEEDED_TOTAL_THREAD_LIMIT          0x08
-
-
-#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_OBSOLETE 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
-
-extern lck_grp_attr_t   *pthread_lck_grp_attr;
-extern lck_grp_t    *pthread_lck_grp;
-extern lck_attr_t   *pthread_lck_attr;

 
 

+void workqueue_mark_exiting(struct proc *);

 void workqueue_exit(struct proc *);
 void pthread_init(void);
 void workqueue_exit(struct proc *);
 void pthread_init(void);

-void psynch_zoneinit(void);
+

 #endif /* _SYS_PTHREAD_INTERNAL_H_ */
 
 #endif /* _SYS_PTHREAD_INTERNAL_H_ */