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.13.2.1 and 1.13.2.2

version 1.13.2.1, 2012/08/21 11:07:16	version 1.13.2.2, 2012/08/21 11:45:35
Line 596 sched_hook_fetch(void root, void arg __unused)	Line 596 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 646 sched_hook_fetch(void root, void arg __unused)	Line 649 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 696 sched_hook_fetch(void root, void arg __unused)	Line 702 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 726 sched_hook_fetch(void root, void arg __unused)	Line 735 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 757 sched_hook_fetch(void root, void arg __unused)	Line 766 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 786 sched_hook_fetch(void root, void arg __unused)	Line 795 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 816 sched_hook_fetch(void root, void arg __unused)	Line 828 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 855 sched_hook_fetch(void root, void arg __unused)	Line 870 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 904 sched_hook_fetch(void root, void arg __unused)	Line 922 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

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

Removed from v.1.13.2.1
changed lines
	Added in v.1.13.2.2