* 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
* 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,
* 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@
*/
#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];
+#if __LP64__
+ char opaque[48];
+#else
+ char opaque[32];
+#endif
};
-#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 workq_mark_exiting(struct proc *);
+void workq_exit(struct proc *);
void pthread_init(void);
-void psynch_zoneinit(void);
-#endif /* _SYS_PTHREAD_INTERNAL_H_ */
+#endif /* _SYS_PTHREAD_INTERNAL_H_ */
projects / apple / xnu.git / blobdiff