version 1.21.6.1, 2013/08/26 18:42:32
|
version 1.24.2.1, 2014/01/27 15:01:52
|
Line 49 SUCH DAMAGE.
|
Line 49 SUCH DAMAGE.
|
|
|
#include <sys/types.h> |
#include <sys/types.h> |
#include <sys/queue.h> |
#include <sys/queue.h> |
|
#ifndef KQ_DISABLE |
#include <sys/event.h> |
#include <sys/event.h> |
|
#endif |
#include <sys/uio.h> |
#include <sys/uio.h> |
#include <stdint.h> |
#include <stdint.h> |
#include <pthread.h> |
#include <pthread.h> |
Line 67 SUCH DAMAGE.
|
Line 69 SUCH DAMAGE.
|
#define CRITERIA_VAL 4 |
#define CRITERIA_VAL 4 |
#define CRITERIA_TS 5 |
#define CRITERIA_TS 5 |
#define CRITERIA_DATA 6 |
#define CRITERIA_DATA 6 |
#define CRITERIA_ID 7 | #define CRITERIA_DATLEN 7 |
| #define CRITERIA_ID 8 |
|
|
|
|
/* early declaration for root & task */ |
/* early declaration for root & task */ |
Line 210 typedef TAILQ_HEAD(, sched_Task) sched_queue_t;
|
Line 213 typedef TAILQ_HEAD(, sched_Task) sched_queue_t;
|
/* root task */ |
/* root task */ |
struct sched_RootTask { |
struct sched_RootTask { |
int root_kq; |
int root_kq; |
|
fd_set root_fds; |
unsigned long root_miss; |
unsigned long root_miss; |
struct timespec root_wait; |
struct timespec root_wait; |
struct timespec root_poll; |
struct timespec root_poll; |
Line 339 int schedCancel(sched_task_t * __restrict task);
|
Line 343 int schedCancel(sched_task_t * __restrict task);
|
* @root = root task |
* @root = root task |
* @type = cancel from queue type, if =taskMAX cancel same task from all queues |
* @type = cancel from queue type, if =taskMAX cancel same task from all queues |
* @criteria = find task by criteria |
* @criteria = find task by criteria |
* [CRITERIA_ANY|CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL|CRITERIA_ID|CRITERIA_TS|CRITERIA_DATA] | * [ CRITERIA_ANY|CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL| |
| * CRITERIA_ID|CRITERIA_TS|CRITERIA_DATA|CRITERIA_DATLEN ] |
* @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, -2 error in sub-stage cancel execution, -3 error from custom hook 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_task_type_t type, |
int schedCancelby(sched_root_task_t * __restrict root, sched_task_type_t type, |
u_char criteria, void *param, sched_hook_func_t hook); | unsigned char criteria, void *param, sched_hook_func_t hook); |
| /* |
| * schedQuery() - Query task in scheduler |
| * |
| * @task = task |
| * return: -1 error, 0 found and 1 not found |
| */ |
| int schedQuery(sched_task_t * __restrict task); |
| /* |
| * schedQueryby() - Query task in scheduler by criteria |
| * |
| * @root = root task |
| * @type = query from queue type, if =taskMAX query same task from all queues |
| * @criteria = find task by criteria |
| * [ CRITERIA_ANY|CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL| |
| * CRITERIA_ID|CRITERIA_TS|CRITERIA_DATA|CRITERIA_DATLEN ] |
| * @param = search parameter |
| * return: -1 error, 0 found or 1 not found |
| */ |
| int schedQueryby(sched_root_task_t * __restrict root, sched_task_type_t type, |
| unsigned char criteria, void *param); |
|
|
|
|
/* |
/* |
Line 626 sched_task_t *schedSuspend(sched_root_task_t * __restr
|
Line 651 sched_task_t *schedSuspend(sched_root_task_t * __restr
|
* |
* |
* @root = root task |
* @root = root task |
* @criteria = find task by criteria |
* @criteria = find task by criteria |
* [CRITERIA_ANY|CRITERIA_ID|CRITERIA_DATA] | * [ CRITERIA_ANY|CRITERIA_ID|CRITERIA_VAL|CRITERIA_DATA ] |
* @param = search parameter (sched_task_t *task| u_long id) | * @param = search parameter (sched_task_t *task| unsigned long id) |
* return: -1 error or 0 resumed ok |
* return: -1 error or 0 resumed ok |
*/ |
*/ |
int schedResumeby(sched_root_task_t * __restrict root, unsigned char criteria, void *param); |
int schedResumeby(sched_root_task_t * __restrict root, unsigned char criteria, void *param); |