[dragonfly.git] / sys / netinet / tcp_timer2.h

/*
 * Copyright (c) 1982, 1986, 1993
 *	The Regents of the University of California.  All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *	This product includes software developed by the University of
 *	California, Berkeley and its contributors.
 * 4. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 *	@(#)tcp_timer.h	8.1 (Berkeley) 6/10/93
 * $FreeBSD: src/sys/netinet/tcp_timer.h,v 1.18.2.1 2002/08/16 22:16:39 dillon Exp $
 * $DragonFly: src/sys/netinet/tcp_timer.h,v 1.3 2003/08/23 11:18:00 rob Exp $
 */

#ifndef _NETINET_TCP_TIMER2_H_
#define _NETINET_TCP_TIMER2_H_

#ifdef _KERNEL

#ifndef _SYS_PARAM_H_
#include <sys/param.h>
#endif

#ifndef _SYS_SYSTM_H_
#include <sys/systm.h>
#endif

#ifndef _SYS_THREAD2_H_
#include <sys/thread2.h>
#endif

#ifndef _SYS_CALLOUT_H_
#include <sys/callout.h>
#endif

#ifndef _NETINET_TCP_VAR_H_
#include <netinet/tcp_var.h>
#endif

#ifndef _NETINET_TCP_TIMER_H_
#include <netinet/tcp_timer.h>
#endif

static __inline void
tcp_callout_stop(struct tcpcb *_tp, struct tcp_callout *_tc)
{
	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);

	crit_enter();
	callout_stop(&_tc->tc_callout);
	_tp->tt_msg->tt_tasks &= ~_tc->tc_task;
	_tp->tt_msg->tt_running_tasks &= ~_tc->tc_task;
	crit_exit();
}

static __inline void
tcp_callout_reset(struct tcpcb *_tp, struct tcp_callout *_tc, int _to_ticks,
		  void (*_func)(void *))
{
	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);

	crit_enter();
	callout_reset(&_tc->tc_callout, _to_ticks, _func, _tp);
	_tp->tt_msg->tt_tasks &= ~_tc->tc_task;
	_tp->tt_msg->tt_running_tasks &= ~_tc->tc_task;
	crit_exit();
}

static __inline int
tcp_callout_active(struct tcpcb *_tp, struct tcp_callout *_tc)
{
	int _act;

	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);

	crit_enter();
	_act = callout_active(&_tc->tc_callout);
	if (!_act) {
		_act = (_tp->tt_msg->tt_tasks |
			_tp->tt_msg->tt_running_tasks) & _tc->tc_task;
	}
	crit_exit();
	return _act;
}

static __inline int
tcp_callout_pending(struct tcpcb *_tp, struct tcp_callout *_tc)
{
	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);

	return callout_pending(&_tc->tc_callout);
}

#endif	/* !_KERNEL */

#endif	/* _NETINET_TCP_TIMER2_H_ */
Commit	Line	Data
a48c5dd5 SZ	1	/*
	2	* Copyright (c) 1982, 1986, 1993
	3	* The Regents of the University of California. All rights reserved.
	4	*
	5	* Redistribution and use in source and binary forms, with or without
	6	* modification, are permitted provided that the following conditions
	7	* are met:
	8	* 1. Redistributions of source code must retain the above copyright
	9	* notice, this list of conditions and the following disclaimer.
	10	* 2. Redistributions in binary form must reproduce the above copyright
	11	* notice, this list of conditions and the following disclaimer in the
	12	* documentation and/or other materials provided with the distribution.
	13	* 3. All advertising materials mentioning features or use of this software
	14	* must display the following acknowledgement:
	15	* This product includes software developed by the University of
	16	* California, Berkeley and its contributors.
	17	* 4. Neither the name of the University nor the names of its contributors
	18	* may be used to endorse or promote products derived from this software
	19	* without specific prior written permission.
	20	*
	21	* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
	22	* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
	23	* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
	24	* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
	25	* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
	26	* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
	27	* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
	28	* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
	29	* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
	30	* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
	31	* SUCH DAMAGE.
	32	*
	33	* @(#)tcp_timer.h 8.1 (Berkeley) 6/10/93
	34	* $FreeBSD: src/sys/netinet/tcp_timer.h,v 1.18.2.1 2002/08/16 22:16:39 dillon Exp $
	35	* $DragonFly: src/sys/netinet/tcp_timer.h,v 1.3 2003/08/23 11:18:00 rob Exp $
	36	*/
	37
	38	#ifndef _NETINET_TCP_TIMER2_H_
	39	#define _NETINET_TCP_TIMER2_H_
	40
	41	#ifdef _KERNEL
	42
e6f59cda SZ	43	#ifndef _SYS_PARAM_H_
	44	#include <sys/param.h>
	45	#endif
	46
	47	#ifndef _SYS_SYSTM_H_
	48	#include <sys/systm.h>
	49	#endif
	50
a48c5dd5 SZ	51	#ifndef _SYS_THREAD2_H_
	52	#include <sys/thread2.h>
	53	#endif
	54
	55	#ifndef _SYS_CALLOUT_H_
	56	#include <sys/callout.h>
	57	#endif
	58
	59	#ifndef _NETINET_TCP_VAR_H_
	60	#include <netinet/tcp_var.h>
	61	#endif
	62
	63	#ifndef _NETINET_TCP_TIMER_H_
	64	#include <netinet/tcp_timer.h>
	65	#endif
	66
	67	static __inline void
	68	tcp_callout_stop(struct tcpcb _tp, struct tcp_callout _tc)
	69	{
e6f59cda SZ	70	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	71
a48c5dd5 SZ	72	crit_enter();
a48c5dd5 SZ	73	callout_stop(&_tc->tc_callout);
2d42d2b0 SZ	74	_tp->tt_msg->tt_tasks &= ~_tc->tc_task;
2d42d2b0 SZ	75	_tp->tt_msg->tt_running_tasks &= ~_tc->tc_task;
a48c5dd5 SZ	76	crit_exit();
	77	}
	78
	79	static __inline void
	80	tcp_callout_reset(struct tcpcb _tp, struct tcp_callout _tc, int _to_ticks,
	81	void (_func)(void ))
	82	{
e6f59cda SZ	83	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	84
a48c5dd5 SZ	85	crit_enter();
a48c5dd5 SZ	86	callout_reset(&_tc->tc_callout, _to_ticks, _func, _tp);
2d42d2b0 SZ	87	_tp->tt_msg->tt_tasks &= ~_tc->tc_task;
2d42d2b0 SZ	88	_tp->tt_msg->tt_running_tasks &= ~_tc->tc_task;
a48c5dd5 SZ	89	crit_exit();
	90	}
	91
	92	static __inline int
	93	tcp_callout_active(struct tcpcb _tp, struct tcp_callout _tc)
	94	{
	95	int _act;
	96
e6f59cda SZ	97	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	98
a48c5dd5 SZ	99	crit_enter();
a48c5dd5 SZ	100	_act = callout_active(&_tc->tc_callout);
2d42d2b0	101	if (!_act) {
a48c5dd5 SZ	102	_act = (_tp->tt_msg->tt_tasks \|
	103	_tp->tt_msg->tt_running_tasks) & _tc->tc_task;
	104	}
	105	crit_exit();
	106	return _act;
	107	}
	108
	109	static __inline int
e6f59cda	110	tcp_callout_pending(struct tcpcb _tp, struct tcp_callout _tc)
a48c5dd5	111	{
e6f59cda SZ	112	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	113
a48c5dd5 SZ	114	return callout_pending(&_tc->tc_callout);
	115	}
	116
	117	#endif /* !_KERNEL */
	118
	119	#endif /* _NETINET_TCP_TIMER2_H_ */