libaitsched/src/tasks.c - diff

Return to tasks.c CVS log

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

Diff for /libaitsched/src/tasks.c between versions 1.24 and 1.24.2.3

version 1.24, 2014/04/27 16:20:37	version 1.24.2.3, 2014/05/21 22:09:01
Line 323 sched_task_t *	Line 323 sched_task_t *
schedNode(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,	schedNode(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,
void *opt_data, size_t opt_dlen)	void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 364 schedNode(sched_root_task_t * __restrict root, sched_t	Line 364 schedNode(sched_root_task_t * __restrict root, sched_t
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 382 sched_task_t *	Line 382 sched_task_t *
schedProc(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long pid,	schedProc(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long pid,
void *opt_data, size_t opt_dlen)	void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 423 schedProc(sched_root_task_t * __restrict root, sched_t	Line 423 schedProc(sched_root_task_t * __restrict root, sched_t
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 441 sched_task_t *	Line 441 sched_task_t *
schedUser(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long id,	schedUser(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long id,
void *opt_data, size_t opt_dlen)	void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 487 schedUser(sched_root_task_t * __restrict root, sched_t	Line 487 schedUser(sched_root_task_t * __restrict root, sched_t

return task;	return task;
#endif /* EVFILT_USER */	#endif /* EVFILT_USER */
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 505 sched_task_t *	Line 505 sched_task_t *
schedSignal(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long sig,	schedSignal(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, u_long sig,
void *opt_data, size_t opt_dlen)	void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 546 schedSignal(sched_root_task_t * __restrict root, sched	Line 546 schedSignal(sched_root_task_t * __restrict root, sched
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 564 sched_task_t *	Line 564 sched_task_t *
schedAlarm(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, struct timespec ts,	schedAlarm(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, struct timespec ts,
void *opt_data, size_t opt_dlen)	void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 605 schedAlarm(sched_root_task_t * __restrict root, sched_	Line 605 schedAlarm(sched_root_task_t * __restrict root, sched_
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

#ifdef AIO_SUPPORT	#ifdef AIO_SUPPORT
Line 624 sched_task_t *	Line 624 sched_task_t *
schedAIO(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg,	schedAIO(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg,
struct aiocb * __restrict acb, void *opt_data, size_t opt_dlen)	struct aiocb * __restrict acb, void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 665 schedAIO(sched_root_task_t * __restrict root, sched_ta	Line 665 schedAIO(sched_root_task_t * __restrict root, sched_ta
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 684 sched_task_t *	Line 684 sched_task_t *
schedAIORead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,	schedAIORead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,
void *buffer, size_t buflen, off_t offset)	void *buffer, size_t buflen, off_t offset)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 724 schedAIORead(sched_root_task_t * __restrict root, sche	Line 724 schedAIORead(sched_root_task_t * __restrict root, sche
}	}

return schedAIO(root, func, arg, acb, buffer, buflen);	return schedAIO(root, func, arg, acb, buffer, buflen);
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 743 sched_task_t *	Line 743 sched_task_t *
schedAIOWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,	schedAIOWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,
void *buffer, size_t buflen, off_t offset)	void *buffer, size_t buflen, off_t offset)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 783 schedAIOWrite(sched_root_task_t * __restrict root, sch	Line 783 schedAIOWrite(sched_root_task_t * __restrict root, sch
}	}

return schedAIO(root, func, arg, acb, buffer, buflen);	return schedAIO(root, func, arg, acb, buffer, buflen);
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

#ifdef EVFILT_LIO	#ifdef EVFILT_LIO
Line 802 sched_task_t *	Line 802 sched_task_t *
schedLIO(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg,	schedLIO(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg,
struct aiocb ** __restrict acbs, void *opt_data, size_t opt_dlen)	struct aiocb ** __restrict acbs, void *opt_data, size_t opt_dlen)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 843 schedLIO(sched_root_task_t * __restrict root, sched_ta	Line 843 schedLIO(sched_root_task_t * __restrict root, sched_ta
task = sched_unuseTask(task);	task = sched_unuseTask(task);

return task;	return task;
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 862 sched_task_t *	Line 862 sched_task_t *
schedLIORead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,	schedLIORead(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,
struct iovec *bufs, size_t nbufs, off_t offset)	struct iovec *bufs, size_t nbufs, off_t offset)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 920 schedLIORead(sched_root_task_t * __restrict root, sche	Line 920 schedLIORead(sched_root_task_t * __restrict root, sche
}	}

return schedLIO(root, func, arg, (void*) acb, bufs, nbufs);	return schedLIO(root, func, arg, (void*) acb, bufs, nbufs);
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}

/*	/*
Line 939 sched_task_t *	Line 939 sched_task_t *
schedLIOWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,	schedLIOWrite(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, int fd,
struct iovec *bufs, size_t nbufs, off_t offset)	struct iovec *bufs, size_t nbufs, off_t offset)
{	{
#ifdef KQ_DISABLE	#if SUP_ENABLE != KQ_SUPPORT
sched_SetErr(ENOTSUP, "disabled kqueue support");	sched_SetErr(ENOTSUP, "disabled kqueue support");
return NULL;	return NULL;
#else	#else
Line 997 schedLIOWrite(sched_root_task_t * __restrict root, sch	Line 997 schedLIOWrite(sched_root_task_t * __restrict root, sch
}	}

return schedLIO(root, func, arg, (void*) acb, bufs, nbufs);	return schedLIO(root, func, arg, (void*) acb, bufs, nbufs);
#endif /* KQ_DISABLE */	#endif /* KQ_SUPPORT */
}	}
#endif /* EVFILT_LIO */	#endif /* EVFILT_LIO */
#endif /* AIO_SUPPORT */	#endif /* AIO_SUPPORT */
Line 1330 schedThread(sched_root_task_t * __restrict root, sched	Line 1330 schedThread(sched_root_task_t * __restrict root, sched
TASK_DATLEN(task) = opt_dlen;	TASK_DATLEN(task) = opt_dlen;

pthread_attr_init(&attr);	pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_DETACHED);	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
if (ss && (errno = pthread_attr_setstacksize(&attr, ss))) {	if (ss && (errno = pthread_attr_setstacksize(&attr, ss))) {
LOGERR;	LOGERR;
pthread_attr_destroy(&attr);	pthread_attr_destroy(&attr);
Line 1342 schedThread(sched_root_task_t * __restrict root, sched	Line 1342 schedThread(sched_root_task_t * __restrict root, sched
return sched_unuseTask(task);	return sched_unuseTask(task);
} else	} else
TASK_FLAG(task) = ss;	TASK_FLAG(task) = ss;
if ((errno = pthread_attr_setguardsize(&attr, ss))) {
LOGERR;
pthread_attr_destroy(&attr);
return sched_unuseTask(task);
}
#ifdef SCHED_RR	#ifdef SCHED_RR
pthread_attr_setschedpolicy(&attr, SCHED_RR);	pthread_attr_setschedpolicy(&attr, SCHED_RR);
#else	#else

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

Removed from v.1.24
changed lines
	Added in v.1.24.2.3