[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

/*
 * The TCP_FASTKEEP option uses keepintvl for the initial keepidle timeout
 * instead of keepidle.
 */
static __inline int
tcp_getkeepidle(struct tcpcb *_tp)
{
	if (_tp->t_flags & TF_FASTKEEP)
		return (_tp->t_keepintvl);
	else
		return (_tp->t_keepidle);
}

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
2a0c7c52 MD	67	/*
	68	* The TCP_FASTKEEP option uses keepintvl for the initial keepidle timeout
	69	* instead of keepidle.
	70	*/
	71	static __inline int
	72	tcp_getkeepidle(struct tcpcb *_tp)
	73	{
	74	if (_tp->t_flags & TF_FASTKEEP)
5d61ded3	75	return (_tp->t_keepintvl);
2a0c7c52	76	else
7ea3a353	77	return (_tp->t_keepidle);
2a0c7c52 MD	78	}
2a0c7c52 MD	79
a48c5dd5 SZ	80	static __inline void
	81	tcp_callout_stop(struct tcpcb _tp, struct tcp_callout _tc)
	82	{
e6f59cda SZ	83	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	84
a48c5dd5 SZ	85	crit_enter();
a48c5dd5 SZ	86	callout_stop(&_tc->tc_callout);
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 void
	93	tcp_callout_reset(struct tcpcb _tp, struct tcp_callout _tc, int _to_ticks,
	94	void (_func)(void ))
	95	{
e6f59cda SZ	96	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	97
a48c5dd5 SZ	98	crit_enter();
a48c5dd5 SZ	99	callout_reset(&_tc->tc_callout, _to_ticks, _func, _tp);
2d42d2b0 SZ	100	_tp->tt_msg->tt_tasks &= ~_tc->tc_task;
2d42d2b0 SZ	101	_tp->tt_msg->tt_running_tasks &= ~_tc->tc_task;
a48c5dd5 SZ	102	crit_exit();
	103	}
	104
	105	static __inline int
	106	tcp_callout_active(struct tcpcb _tp, struct tcp_callout _tc)
	107	{
	108	int _act;
	109
e6f59cda SZ	110	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	111
a48c5dd5 SZ	112	crit_enter();
a48c5dd5 SZ	113	_act = callout_active(&_tc->tc_callout);
2d42d2b0	114	if (!_act) {
a48c5dd5 SZ	115	_act = (_tp->tt_msg->tt_tasks \|
	116	_tp->tt_msg->tt_running_tasks) & _tc->tc_task;
	117	}
	118	crit_exit();
	119	return _act;
	120	}
	121
	122	static __inline int
e6f59cda	123	tcp_callout_pending(struct tcpcb _tp, struct tcp_callout _tc)
a48c5dd5	124	{
e6f59cda SZ	125	KKASSERT(_tp->tt_msg->tt_cpuid == mycpuid);
e6f59cda SZ	126
a48c5dd5 SZ	127	return callout_pending(&_tc->tc_callout);
	128	}
	129
	130	#endif /* !_KERNEL */
	131
	132	#endif /* _NETINET_TCP_TIMER2_H_ */