libaitsched/src/hooks.c - diff

Return to hooks.c CVS log

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

version 1.10.2.5, 2012/08/01 15:17:38	version 1.10.2.6, 2012/08/01 16:47:06
Line 168 sched_hook_cancel(void task, void arg __unused)	Line 168 sched_hook_cancel(void task, void arg __unused)
#endif	#endif
acb = (struct aiocb*) TASK_VAL(t);	acb = (struct aiocb*) TASK_VAL(t);
if (acb) {	if (acb) {
aio_cancel(acb->aio_fildes, acb);	if (aio_cancel(acb->aio_fildes, acb) == AIO_CANCELED)
	aio_return(acb);
free(acb);	free(acb);
TASK_VAL(t) = 0;	TASK_VAL(t) = 0;
}	}
Line 779 sched_hook_fetch(void root, void arg __unused)	Line 780 sched_hook_fetch(void root, void arg __unused)
flg = 0;	flg = 0;
TAILQ_FOREACH_SAFE(task, &r->root_aio, task_node, tmp) {	TAILQ_FOREACH_SAFE(task, &r->root_aio, task_node, tmp) {
acb = (struct aiocb*) TASK_VAL(task);	acb = (struct aiocb*) TASK_VAL(task);
if (acb != ((struct aiocb*) res[i].ident) \|\|	if (acb != ((struct aiocb*) res[i].udata))
acb->aio_sigevent.sigev_value.sival_ptr != res[i].udata)
continue;	continue;
else	else
flg++;	flg++;
Line 808 sched_hook_fetch(void root, void arg __unused)	Line 808 sched_hook_fetch(void root, void arg __unused)
LOGERR;	LOGERR;

free(acb);	free(acb);
TASK_FD(task) = (u_long) fd;	TASK_FD(task) = fd;
TASK_DATLEN(task) = (u_long) len;	TASK_DATLEN(task) = (u_long) len;
}	}
/* if match at least 2, don't remove resouce of event */	/* if match at least 2, don't remove resouce of event */