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.10.2.6 and 1.10.2.9

version 1.10.2.6, 2012/08/01 16:47:06	version 1.10.2.9, 2012/08/02 12:32:07
Line 107 sched_hook_cancel(void task, void arg __unused)	Line 107 sched_hook_cancel(void task, void arg __unused)
sched_task_t *t = task;	sched_task_t *t = task;
struct kevent chg[1];	struct kevent chg[1];
struct timespec timeout = { 0, 0 };	struct timespec timeout = { 0, 0 };
#ifdef EVFILT_AIO	#if defined(EVFILT_AIO) && defined(SIGEV_KEVENT)
struct aiocb *acb;	struct aiocb *acb;
#endif	#endif

Line 159 sched_hook_cancel(void task, void arg __unused)	Line 159 sched_hook_cancel(void task, void arg __unused)
EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, EV_DELETE, 0, 0, (void*) TASK_VAL(t));	EV_SET(&chg[0], TASK_VAL(t), EVFILT_SIGNAL, EV_DELETE, 0, 0, (void*) TASK_VAL(t));
#endif	#endif
break;	break;
#ifdef EVFILT_AIO	#if defined(EVFILT_AIO) && defined(SIGEV_KEVENT)
case taskAIO:	case taskAIO:
#ifdef __NetBSD__	#ifdef __NetBSD__
EV_SET(&chg[0], TASK_VAL(t), EVFILT_AIO, EV_DELETE, 0, 0, (intptr_t) TASK_VAL(t));	EV_SET(&chg[0], TASK_VAL(t), EVFILT_AIO, EV_DELETE, 0, 0, (intptr_t) TASK_VAL(t));
Line 454 sched_hook_fetch(void root, void arg __unused)	Line 454 sched_hook_fetch(void root, void arg __unused)
struct kevent evt[1], res[KQ_EVENTS];	struct kevent evt[1], res[KQ_EVENTS];
register int i, flg;	register int i, flg;
int en;	int en;
#ifdef EVFILT_AIO	#if defined(EVFILT_AIO) && defined(SIGEV_KEVENT)
int len, fd;	int len, fd;
struct aiocb *acb;	struct aiocb *acb;
#endif	#ifdef EVFILT_LIO
	int l;
	register int j;
	off_t off;
	struct aiocb **acbs;
	struct iovec *iv;
	#endif /* EVFILT_LIO */
	#endif /* EVFILT_AIO */

if (!r)	if (!r)
return NULL;	return NULL;
Line 775 sched_hook_fetch(void root, void arg __unused)	Line 782 sched_hook_fetch(void root, void arg __unused)
if (flg > 1)	if (flg > 1)
evt->flags ^= evt->flags;	evt->flags ^= evt->flags;
break;	break;
#ifdef EVFILT_AIO	#if defined(EVFILT_AIO) && defined(SIGEV_KEVENT)
case EVFILT_AIO:	case EVFILT_AIO:
	#ifdef EVFILT_LIO
	case EVFILT_LIO:
	#endif /* EVFILT_LIO */
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);
Line 800 sched_hook_fetch(void root, void arg __unused)	Line 810 sched_hook_fetch(void root, void arg __unused)
#ifdef HAVE_LIBPTHREAD	#ifdef HAVE_LIBPTHREAD
pthread_mutex_unlock(&r->root_mtx[taskREADY]);	pthread_mutex_unlock(&r->root_mtx[taskREADY]);
#endif	#endif
fd = acb->aio_fildes;	#ifdef EVFILT_LIO
if ((len = aio_return(acb)) != -1) {	if (res[i].filter == EVFILT_LIO) {
if (lseek(fd, acb->aio_offset + len, SEEK_CUR) == -1)	acbs = (struct aiocb**) TASK_VAL(task);
	iv = (struct iovec*) TASK_DATA(task);
	fd = acbs[0]->aio_fildes;
	off = acbs[0]->aio_offset;
	for (j = len = 0; i < TASK_DATLEN(task); len += l, i++) {
	if ((iv[i].iov_len = aio_return(acbs[i])) == -1)
	l = 0;
	else
	l = iv[i].iov_len;
	free(acbs[i]);
	}
	free(acbs);
	if (lseek(fd, off + len, SEEK_CUR) == -1)
LOGERR;	LOGERR;
} else	} else
LOGERR;	#endif /* EVFILT_LIO */
	{
	fd = acb->aio_fildes;
	if ((len = aio_return(acb)) != -1) {
	if (lseek(fd, acb->aio_offset + len, SEEK_CUR) == -1)
	LOGERR;
	} else
	LOGERR;

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

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

Removed from v.1.10.2.6
changed lines
	Added in v.1.10.2.9