version 1.4.2.5, 2012/01/24 14:34:49
|
version 1.4.2.8, 2012/01/24 15:30:55
|
Line 132 schedInit(void ** __restrict data, size_t datlen)
|
Line 132 schedInit(void ** __restrict data, size_t datlen)
|
} else { |
} else { |
memset(root, 0, sizeof(sched_root_task_t)); |
memset(root, 0, sizeof(sched_root_task_t)); |
|
|
|
/* INFINIT polling period by default */ |
|
sched_timespecinf(&root->root_poll); |
|
|
#ifdef HAVE_LIBPTHREAD |
#ifdef HAVE_LIBPTHREAD |
for (i = 0; i < taskMAX; i++) |
for (i = 0; i < taskMAX; i++) |
if (pthread_mutex_init(&root->root_mtx[i], NULL)) { |
if (pthread_mutex_init(&root->root_mtx[i], NULL)) { |
Line 416 schedCancelby(sched_root_task_t * __restrict root, sch
|
Line 419 schedCancelby(sched_root_task_t * __restrict root, sch
|
break; |
break; |
} |
} |
} else if (criteria == CRITERIA_TV) { |
} else if (criteria == CRITERIA_TV) { |
if (!timespeccmp(&TASK_TS(task), (struct timespec*) param, -)) { | if (!sched_timespeccmp(&TASK_TS(task), (struct timespec*) param, -)) { |
flg++; |
flg++; |
break; |
break; |
} |
} |
Line 502 schedPolling(sched_root_task_t * __restrict root, stru
|
Line 505 schedPolling(sched_root_task_t * __restrict root, stru
|
*tsold = root->root_poll; |
*tsold = root->root_poll; |
|
|
if (!ts) |
if (!ts) |
root->root_poll.tv_sec = root->root_poll.tv_nsec = -1; | sched_timespecinf(&root->root_poll); |
else |
else |
root->root_poll = *ts; |
root->root_poll = *ts; |
|
|