Cider Isn't Darwin Emulation, Really
Something went wrong. Try again.
5.4 kB · 156 lines
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157/* * Copyright (c) 2000-2003 Apple Computer, Inc. All rights reserved. * * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ * * This file contains Original Code and/or Modifications of Original Code * as defined in and that are subject to the Apple Public Source License * Version 2.0 (the 'License'). You may not use this file except in * compliance with the License. The rights granted to you under the License * may not be used to create, or enable the creation or redistribution of, * unlawful or unlicensed copies of an Apple operating system, or to * circumvent, violate, or enable the circumvention or violation of, any * terms of an Apple operating system software license agreement. * * Please obtain a copy of the License at * http://www.opensource.apple.com/apsl/ and read it before using this file. * * The Original Code and all software distributed under the License are * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. * Please see the License for the specific language governing rights and * limitations under the License. * * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ */
#ifndef _SYS_PTHREAD_INTERNAL_H_#define _SYS_PTHREAD_INTERNAL_H_
#include <sys/user.h>#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 */};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 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 workqueue { 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; 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_reqcount; TAILQ_HEAD(, threadlist) wq_thrunlist; TAILQ_HEAD(, threadlist) wq_thidlelist; uint16_t wq_requests[WORKQUEUE_NUMPRIOS]; uint16_t wq_ocrequests[WORKQUEUE_NUMPRIOS]; uint16_t wq_reqconc[WORKQUEUE_NUMPRIOS]; /* requested concurrency for each priority level */ uint16_t *wq_thscheduled_count[WORKQUEUE_NUMPRIOS]; uint32_t *wq_thactive_count[WORKQUEUE_NUMPRIOS]; /* must be uint32_t since we OSAddAtomic on these */ 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 WQOPS_QUEUE_NEWSPISUPP 0x10 /* this is to check for newer SPI support */#define WQOPS_QUEUE_REQTHREADS 0x20 /* request number of threads of a prio */
#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 psynch_zoneinit(void);#endif /* _SYS_PTHREAD_INTERNAL_H_ */