|
version 1.24.2.3, 2014/01/27 17:08:02
|
version 1.29, 2019/01/14 15:58:50
|
|
Line 12 terms:
|
Line 12 terms:
|
| All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
| Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
| |
|
| Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 | Copyright 2004 - 2018 |
| by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
| |
|
| Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
|
Line 160 typedef struct sched_HooksTask hooks_task_t;
|
Line 160 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*/); |
| |
#define SCHED_TASK_DEFINE(x) void *(x)(sched_task_t*) |
| |
|
| /* task lock helpers */ |
/* task lock helpers */ |
| #define TASK_LOCK(x) ((x)->task_lock = 42) |
#define TASK_LOCK(x) ((x)->task_lock = 42) |
|
Line 218 struct sched_RootTask {
|
Line 219 struct sched_RootTask {
|
| struct timespec root_wait; |
struct timespec root_wait; |
| struct timespec root_poll; |
struct timespec root_poll; |
| unsigned long root_miss; |
unsigned long root_miss; |
| intptr_t root_cond; | intptr_t root_cond[1]; |
| void *root_ret; |
void *root_ret; |
| |
|
| pthread_mutex_t root_mtx[taskMAX]; |
pthread_mutex_t root_mtx[taskMAX]; |
|
Line 308 int schedPolling(sched_root_task_t * __restrict root,
|
Line 309 int schedPolling(sched_root_task_t * __restrict root,
|
| * @condValue = condition value, kill schedRun() if condValue == killState |
* @condValue = condition value, kill schedRun() if condValue == killState |
| * return: -1 error or 0 ok |
* return: -1 error or 0 ok |
| */ |
*/ |
| int schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue); | int schedTermCondition(sched_root_task_t * __restrict root, intptr_t * __restrict condValue); |
| /* |
/* |
| * schedCall() - Call task execution function |
* schedCall() - Call task execution function |
| * |
* |
|
Line 448 sched_task_t *schedRTC(sched_root_task_t * __restrict
|
Line 449 sched_task_t *schedRTC(sched_root_task_t * __restrict
|
| sched_task_t *schedNode(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
sched_task_t *schedNode(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
| int fd, void *opt_data, size_t opt_dlen); |
int fd, void *opt_data, size_t opt_dlen); |
| #define schedNodeSelf(x) schedNode(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
#define schedNodeSelf(x) schedNode(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
| |
TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
| |
/* |
| |
* schedNode2() - Add NODE task with all events to scheduler queue |
| |
* |
| |
* @root = root task |
| |
* @func = task execution function |
| |
* @arg = 1st func argument |
| |
* @fd = fd handle |
| |
* @opt_data = Optional data |
| |
* @opt_dlen = Optional data length |
| |
* return: NULL error or !=NULL new queued task |
| |
*/ |
| |
sched_task_t *schedNode2(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
| |
int fd, void *opt_data, size_t opt_dlen); |
| |
#define schedNode2Self(x) schedNode2(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
| TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
TASK_FD((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
| /* |
/* |
| * schedProc() - Add PROC task to scheduler queue |
* schedProc() - Add PROC task to scheduler queue |