version 1.2.2.6, 2011/11/30 23:44:57
|
version 1.4.2.1, 2012/01/08 02:01:41
|
Line 114 typedef struct sched_HooksTask hooks_task_t;
|
Line 114 typedef struct sched_HooksTask hooks_task_t;
|
/* task callback, like pthread callback! */ |
/* task callback, like pthread callback! */ |
typedef void *(*sched_task_func_t)(sched_task_t * /* current task data*/); |
typedef void *(*sched_task_func_t)(sched_task_t * /* current task data*/); |
|
|
|
/* task lock helpers */ |
|
#define TASK_LOCK(x) ((x)->task_lock++) |
|
#define TASK_UNLOCK(x) ((x)->task_lock ^= (x)->task_lock) |
|
#define TASK_ISLOCKED(x) ((x)->task_lock) |
|
|
/* task & queue */ |
/* task & queue */ |
struct sched_Task { |
struct sched_Task { |
|
volatile int task_lock; |
unsigned int task_id; |
unsigned int task_id; |
sched_task_type_t task_type; |
sched_task_type_t task_type; |
|
|
Line 142 struct sched_Task {
|
Line 148 struct sched_Task {
|
}; |
}; |
typedef TAILQ_HEAD(, sched_Task) sched_queue_t; |
typedef TAILQ_HEAD(, sched_Task) sched_queue_t; |
|
|
|
/* root lock helpers */ |
|
#define ROOT_QLOCK(x, q) (pthread_mutex_lock(&(x)->root_mtx[(q)])) |
|
#define ROOT_QUNLOCK(x, q) (pthread_mutex_unlock(&(x)->root_mtx[(q)])) |
|
|
/* root task */ |
/* root task */ |
struct sched_RootTask { |
struct sched_RootTask { |
int root_kq; |
int root_kq; |
struct timeval root_wait; |
struct timeval root_wait; |
|
pthread_mutex_t root_mtx[taskMAX]; |
|
|
sched_queue_t root_read; |
sched_queue_t root_read; |
sched_queue_t root_write; |
sched_queue_t root_write; |
Line 219 int schedCancel(sched_task_t * __restrict task);
|
Line 230 int schedCancel(sched_task_t * __restrict task);
|
* @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
* @criteria = find task by criteria [CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_TV] |
* @param = search parameter |
* @param = search parameter |
* @hook = custom cleanup hook function, may be NULL |
* @hook = custom cleanup hook function, may be NULL |
* return: -1 error or 0 ok | * return: -1 error, -2 error in sub-stage cancel execution, -3 error from custom hook or 0 ok |
*/ |
*/ |
int schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
int schedCancelby(sched_root_task_t * __restrict root, sched_queue_t * __restrict queue, |
u_char criteria, void *param, sched_hook_func_t hook); |
u_char criteria, void *param, sched_hook_func_t hook); |