libaitsched/src/hooks.c - diff

Return to hooks.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitsched / src

Diff for /libaitsched/src/hooks.c between versions 1.12 and 1.14.2.1

version 1.12, 2012/08/08 08:25:39	version 1.14.2.1, 2012/08/22 10:33:45
Line 207 sched_hook_cancel(void task, void arg __unused)	Line 207 sched_hook_cancel(void task, void arg __unused)
#endif	#endif
break;	break;
#endif	#endif
	case taskTHREAD:
	#ifdef HAVE_LIBPTHREAD
	pthread_cancel((pthread_t) TASK_VAL(t));
	while (!pthread_kill((pthread_t) TASK_VAL(t), 0));
	if (TASK_FLAG(t) == PTHREAD_CREATE_JOINABLE) /* joinable thread */
	schedTask(TASK_ROOT(t), _sched_threadJoin, TASK_ARG(t),
	TASK_VAL(t), TASK_DATA(t), TASK_DATLEN(t));
	#endif
	TASK_UNLOCK(t);
default:	default:
return NULL;	return NULL;
}	}
Line 215 sched_hook_cancel(void task, void arg __unused)	Line 224 sched_hook_cancel(void task, void arg __unused)
return NULL;	return NULL;
}	}

	#ifdef HAVE_LIBPTHREAD
/*	/*
	* sched_hook_thread() - Default THREAD hook
	*
	* @task = current task
	* @arg = pthread attributes
	* return: <0 errors and 0 ok
	*/
	void *
	sched_hook_thread(void task, void arg)
	{
	sched_task_t *t = task;
	pthread_t tid;

	if (!t \|\| !TASK_ROOT(t))
	return (void*) -1;

	if (pthread_create(&tid, (pthread_attr_t*) arg,
	(void ()(void*)) TASK_FUNC(t), t)) {
	LOGERR;
	return (void*) -1;
	}

	if (!TASK_ISLOCKED(t))
	TASK_LOCK(t);

	TASK_VAL(t) = (u_long) tid;
	return NULL;
	}
	#endif

	/*
* sched_hook_read() - Default READ hook	* sched_hook_read() - Default READ hook
*	*
* @task = current task	* @task = current task
Line 592 sched_hook_fetch(void root, void arg __unused)	Line 632 sched_hook_fetch(void root, void arg __unused)
TAILQ_FOREACH_SAFE(task, &r->root_read, task_node, tmp) {	TAILQ_FOREACH_SAFE(task, &r->root_read, task_node, tmp) {
if (TASK_FD(task) != ((intptr_t) res[i].udata))	if (TASK_FD(task) != ((intptr_t) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove read handle */	/* remove read handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskREAD]);	pthread_mutex_lock(&r->root_mtx[taskREAD]);
Line 642 sched_hook_fetch(void root, void arg __unused)	Line 685 sched_hook_fetch(void root, void arg __unused)
TAILQ_FOREACH_SAFE(task, &r->root_write, task_node, tmp) {	TAILQ_FOREACH_SAFE(task, &r->root_write, task_node, tmp) {
if (TASK_FD(task) != ((intptr_t) res[i].udata))	if (TASK_FD(task) != ((intptr_t) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove write handle */	/* remove write handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskWRITE]);	pthread_mutex_lock(&r->root_mtx[taskWRITE]);
Line 692 sched_hook_fetch(void root, void arg __unused)	Line 738 sched_hook_fetch(void root, void arg __unused)
TAILQ_FOREACH_SAFE(task, &r->root_alarm, task_node, tmp) {	TAILQ_FOREACH_SAFE(task, &r->root_alarm, task_node, tmp) {
if ((uintptr_t) TASK_DATA(task) != ((uintptr_t) res[i].udata))	if ((uintptr_t) TASK_DATA(task) != ((uintptr_t) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove alarm handle */	/* remove alarm handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskALARM]);	pthread_mutex_lock(&r->root_mtx[taskALARM]);
Line 722 sched_hook_fetch(void root, void arg __unused)	Line 771 sched_hook_fetch(void root, void arg __unused)
continue;	continue;
else {	else {
flg++;	flg++;
TASK_DATA(task) = (void*) (uintptr_t) res[i].data;	TASK_RET(task) = res[i].data;
TASK_DATLEN(task) = res[i].fflags;	TASK_FLAG(task) = res[i].fflags;
}	}
/* remove node handle */	/* remove node handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
Line 753 sched_hook_fetch(void root, void arg __unused)	Line 802 sched_hook_fetch(void root, void arg __unused)
continue;	continue;
else {	else {
flg++;	flg++;
TASK_DATA(task) = (void*) (uintptr_t) res[i].data;	TASK_RET(task) = res[i].data;
TASK_DATLEN(task) = res[i].fflags;	TASK_FLAG(task) = res[i].fflags;
}	}
/* remove proc handle */	/* remove proc handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
Line 782 sched_hook_fetch(void root, void arg __unused)	Line 831 sched_hook_fetch(void root, void arg __unused)
TAILQ_FOREACH_SAFE(task, &r->root_signal, task_node, tmp) {	TAILQ_FOREACH_SAFE(task, &r->root_signal, task_node, tmp) {
if (TASK_VAL(task) != ((uintptr_t) res[i].udata))	if (TASK_VAL(task) != ((uintptr_t) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove signal handle */	/* remove signal handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskSIGNAL]);	pthread_mutex_lock(&r->root_mtx[taskSIGNAL]);
Line 812 sched_hook_fetch(void root, void arg __unused)	Line 864 sched_hook_fetch(void root, void arg __unused)
acb = (struct aiocb*) TASK_VAL(task);	acb = (struct aiocb*) TASK_VAL(task);
if (acb != ((struct aiocb*) res[i].udata))	if (acb != ((struct aiocb*) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove user handle */	/* remove user handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskAIO]);	pthread_mutex_lock(&r->root_mtx[taskAIO]);
Line 851 sched_hook_fetch(void root, void arg __unused)	Line 906 sched_hook_fetch(void root, void arg __unused)
acbs = (struct aiocb**) TASK_VAL(task);	acbs = (struct aiocb**) TASK_VAL(task);
if (acbs != ((struct aiocb**) res[i].udata))	if (acbs != ((struct aiocb**) res[i].udata))
continue;	continue;
else	else {
flg++;	flg++;
	TASK_RET(task) = res[i].data;
	TASK_FLAG(task) = res[i].fflags;
	}
/* remove user handle */	/* remove user handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskLIO]);	pthread_mutex_lock(&r->root_mtx[taskLIO]);
Line 900 sched_hook_fetch(void root, void arg __unused)	Line 958 sched_hook_fetch(void root, void arg __unused)
continue;	continue;
else {	else {
flg++;	flg++;
TASK_DATA(task) = (void*) res[i].data;	TASK_RET(task) = res[i].data;
TASK_DATLEN(task) = res[i].fflags;	TASK_FLAG(task) = res[i].fflags;
}	}
/* remove user handle */	/* remove user handle */
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
Line 958 sched_hook_fetch(void root, void arg __unused)	Line 1016 sched_hook_fetch(void root, void arg __unused)
}	}

/* put regular task priority task to ready queue,	/* put regular task priority task to ready queue,
if there is no ready task or reach max missing hit events */	if there is no ready task or reach max missing hit for regular task */
if ((task = TAILQ_FIRST(&r->root_task))) {	if ((task = TAILQ_FIRST(&r->root_task))) {
if (!TAILQ_FIRST(&r->root_ready) \|\| r->root_task_miss > r->root_miss) {	if (!TAILQ_FIRST(&r->root_ready) \|\| r->root_miss >= TASK_VAL(task)) {
r->root_task_miss ^= r->root_task_miss;	r->root_miss ^= r->root_miss;

#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_lock(&r->root_mtx[taskTASK]);	pthread_mutex_lock(&r->root_mtx[taskTASK]);
Line 979 sched_hook_fetch(void root, void arg __unused)	Line 1037 sched_hook_fetch(void root, void arg __unused)
pthread_mutex_unlock(&r->root_mtx[taskREADY]);	pthread_mutex_unlock(&r->root_mtx[taskREADY]);
#endif	#endif
} else	} else
r->root_task_miss++;	r->root_miss++;
} else	} else
r->root_task_miss ^= r->root_task_miss;	r->root_miss ^= r->root_miss;

/* OK, lets get ready task !!! */	/* OK, lets get ready task !!! */
task = TAILQ_FIRST(&r->root_ready);	task = TAILQ_FIRST(&r->root_ready);

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.12
changed lines
	Added in v.1.14.2.1