X-Git-Url: https://git.saurik.com/apple/libc.git/blobdiff_plain/224c70764cab4e0e39a26aaf3ad3016552f62f55..065eae9f38780a3602538caa52399f41f061a88e:/pthreads/pthread_workqueue.h diff --git a/pthreads/pthread_workqueue.h b/pthreads/pthread_workqueue.h index c367822..20edf50 100644 --- a/pthreads/pthread_workqueue.h +++ b/pthreads/pthread_workqueue.h @@ -27,47 +27,63 @@ #include #include - +#include #define __PTHREAD_WORKQ_SIZE__ 128 #define __PTHREAD_WORKQ_ATTR_SIZE__ 60 -#define PTHEAD_WRKQUEUE_SIG 0xBEBEBEBE -#define PTHEAD_WRKQUEUE_ATTR_SIG 0xBEBEBEBE +#define PTHREAD_WORKQUEUE_SIG 0xBEBEBEBE +#define PTHREAD_WORKQUEUE_ATTR_SIG 0xBEBEBEBE #ifndef __POSIX_LIB__ typedef struct { unsigned int sig; char opaque[__PTHREAD_WORKQ_SIZE__];} *pthread_workqueue_t; typedef struct { unsigned int sig; char opaque[__PTHREAD_WORKQ_ATTR_SIZE__]; } pthread_workqueue_attr_t; #endif typedef void * pthread_workitem_handle_t; +/* Kernel expected target concurrency of the workqueue clients for the three priority queues */ + +#define WORKQ_HIGH_PRIOQUEUE 0 /* high priority queue */ +#define WORKQ_DEFAULT_PRIOQUEUE 1 /* default priority queue */ +#define WORKQ_LOW_PRIOQUEUE 2 /* low priority queue */ +#define WORKQ_BG_PRIOQUEUE 3 /* background priority queue */ + +#define WORKQ_NUM_PRIOQUEUE 4 + +extern __int32_t workq_targetconc[WORKQ_NUM_PRIOQUEUE]; __BEGIN_DECLS -int pthread_workqueue_init_np(void); -int pthread_workqueue_attr_init_np(pthread_workqueue_attr_t * attr); -int pthread_workqueue_attr_destroy_np(pthread_workqueue_attr_t * attr); -int pthread_workqueue_attr_getqueuepriority_np(const pthread_workqueue_attr_t * attr, int * qprio); -int pthread_workqueue_attr_setqueuepriority_np(pthread_workqueue_attr_t * attr, int qprio); - -#ifdef NOTYET -/* Following attributes not supported yet */ -int pthread_workqueue_attr_getstacksize_np(const pthread_workqueue_attr_t * attr, size_t * stacksizep); -int pthread_workqueue_attr_setstacksize_np(pthread_workqueue_attr_t * attr, size_t stacksize); -int pthread_workqueue_attr_getthreadtimeshare_np(const pthread_workqueue_attr_t * attr, int * istimesahrep); -int pthread_workqueue_attr_settthreadtimeshare_np(pthread_workqueue_attr_t * attr, int istimeshare); -int pthread_workqueue_attr_getthreadimportance_np(const pthread_workqueue_attr_t * attr, int * importancep); -int pthread_workqueue_attr_settthreadimportance_np(pthread_workqueue_attr_t * attr, int importance); -int pthread_workqueue_attr_getthreadaffinity_np(const pthread_workqueue_attr_t * attr, int * affinityp); -int pthread_workqueue_attr_settthreadaffinity_np(pthread_workqueue_attr_t * attr, int affinity); -#endif +int pthread_workqueue_init_np(void) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +int pthread_workqueue_attr_init_np(pthread_workqueue_attr_t * attr) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +int pthread_workqueue_attr_destroy_np(pthread_workqueue_attr_t * attr) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +int pthread_workqueue_attr_getqueuepriority_np(const pthread_workqueue_attr_t * attr, int * qprio) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +/* WORKQ_HIGH/DEFAULT/LOW_PRIOQUEUE are the only valid values */ +int pthread_workqueue_attr_setqueuepriority_np(pthread_workqueue_attr_t * attr, int qprio) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +int pthread_workqueue_attr_getovercommit_np(const pthread_workqueue_attr_t * attr, int * ocommp) __OSX_AVAILABLE_STARTING(__MAC_10_6, __IPHONE_3_2); +int pthread_workqueue_attr_setovercommit_np(pthread_workqueue_attr_t * attr, int ocomm) __OSX_AVAILABLE_STARTING(__MAC_10_6, __IPHONE_3_2); + + +int pthread_workqueue_create_np(pthread_workqueue_t * workqp, const pthread_workqueue_attr_t * attr) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +int pthread_workqueue_additem_np(pthread_workqueue_t workq, void ( *workitem_func)(void *), void * workitem_arg, pthread_workitem_handle_t * itemhandlep, unsigned int *gencountp) __OSX_AVAILABLE_STARTING(__MAC_10_5, __IPHONE_2_0); +/* If the queue value is WORKQ_NUM_PRIOQUEUE, the request for concurrency is for all queues */ +int pthread_workqueue_requestconcurrency_np(int queue, int concurrency) __OSX_AVAILABLE_STARTING(__MAC_10_6, __IPHONE_3_2); +int pthread_workqueue_getovercommit_np(pthread_workqueue_t workq, unsigned int *ocommp) __OSX_AVAILABLE_STARTING(__MAC_10_6, __IPHONE_3_2); +/* + * If the arg is non zero, it enables kill on current thread. + * If the arg of zero, it disables kill on current thread. + */ +int __pthread_workqueue_setkill(int) __OSX_AVAILABLE_STARTING(__MAC_10_6, __IPHONE_3_2); + +/* =================================================================================================== + * NEW SPIs for 10.8 onwards + * + * =================================================================================================== + */ -int pthread_workqueue_create_np(pthread_workqueue_t * workqp, const pthread_workqueue_attr_t * attr); -int pthread_workqueue_destroy_np(pthread_workqueue_t workq, void (* callback_func)(pthread_workqueue_t, void *), void * callback_arg); -int pthread_workqueue_additem_np(pthread_workqueue_t workq, void ( *workitem_func)(void *), void * workitem_arg, pthread_workitem_handle_t * itemhandlep); -int pthread_workqueue_removeitem_np(pthread_workqueue_t workq, pthread_workitem_handle_t itemhandle); -int pthread_workqueue_addbarrier_np(pthread_workqueue_t workq, void (* callback_func)(pthread_workqueue_t, void *), void * callback_arg, int waitforcallback, pthread_workitem_handle_t *itemhandlep); -int pthread_workqueue_suspend_np(pthread_workqueue_t workq); -int pthread_workqueue_resume_np(pthread_workqueue_t workq); +typedef void (*pthread_workqueue_function_t)(int queue_priority, int options, void *ctxt); +int pthread_workqueue_setdispatch_np(pthread_workqueue_function_t worker_func) __OSX_AVAILABLE_STARTING(__MAC_10_8, __IPHONE_6_0); +#define WORKQ_ADDTHREADS_OPTION_OVERCOMMIT 0x00000001 +int pthread_workqueue_addthreads_np(int queue_priority, int options, int numthreads) __OSX_AVAILABLE_STARTING(__MAC_10_8, __IPHONE_6_0); __END_DECLS #endif /* _POSIX_PTHREAD_WORKQUEUE_H */