AutoIpNetStack - Net stack with AutoIP enabled

Users » darran » Code » AutoIpNetStack

Darran Shepherd / Mbed 2 deprecated AutoIpNetStack

Net stack with AutoIP enabled

lwip/core/timers.c@0:ac21159e27f4, 2010-07-02 (annotated)

Committer:: darran
Date:: Fri Jul 02 17:21:58 2010 +0000
Revision:: 0:ac21159e27f4

Who changed what in which revision?

User	Revision	Line number	New contents of line
darran	0:ac21159e27f4	1	/**
darran	0:ac21159e27f4	2	* @file
darran	0:ac21159e27f4	3	* Stack-internal timers implementation.
darran	0:ac21159e27f4	4	* This file includes timer callbacks for stack-internal timers as well as
darran	0:ac21159e27f4	5	* functions to set up or stop timers and check for expired timers.
darran	0:ac21159e27f4	6	*
darran	0:ac21159e27f4	7	*/
darran	0:ac21159e27f4	8
darran	0:ac21159e27f4	9	/*
darran	0:ac21159e27f4	10	* Copyright (c) 2001-2004 Swedish Institute of Computer Science.
darran	0:ac21159e27f4	11	* All rights reserved.
darran	0:ac21159e27f4	12	*
darran	0:ac21159e27f4	13	* Redistribution and use in source and binary forms, with or without modification,
darran	0:ac21159e27f4	14	* are permitted provided that the following conditions are met:
darran	0:ac21159e27f4	15	*
darran	0:ac21159e27f4	16	* 1. Redistributions of source code must retain the above copyright notice,
darran	0:ac21159e27f4	17	* this list of conditions and the following disclaimer.
darran	0:ac21159e27f4	18	* 2. Redistributions in binary form must reproduce the above copyright notice,
darran	0:ac21159e27f4	19	* this list of conditions and the following disclaimer in the documentation
darran	0:ac21159e27f4	20	* and/or other materials provided with the distribution.
darran	0:ac21159e27f4	21	* 3. The name of the author may not be used to endorse or promote products
darran	0:ac21159e27f4	22	* derived from this software without specific prior written permission.
darran	0:ac21159e27f4	23	*
darran	0:ac21159e27f4	24	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
darran	0:ac21159e27f4	25	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
darran	0:ac21159e27f4	26	* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
darran	0:ac21159e27f4	27	* SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
darran	0:ac21159e27f4	28	* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
darran	0:ac21159e27f4	29	* OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
darran	0:ac21159e27f4	30	* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
darran	0:ac21159e27f4	31	* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
darran	0:ac21159e27f4	32	* IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
darran	0:ac21159e27f4	33	* OF SUCH DAMAGE.
darran	0:ac21159e27f4	34	*
darran	0:ac21159e27f4	35	* This file is part of the lwIP TCP/IP stack.
darran	0:ac21159e27f4	36	*
darran	0:ac21159e27f4	37	* Author: Adam Dunkels <adam@sics.se>
darran	0:ac21159e27f4	38	* Simon Goldschmidt
darran	0:ac21159e27f4	39	*
darran	0:ac21159e27f4	40	*/
darran	0:ac21159e27f4	41
darran	0:ac21159e27f4	42	#include "lwip/opt.h"
darran	0:ac21159e27f4	43
darran	0:ac21159e27f4	44	#include "lwip/timers.h"
darran	0:ac21159e27f4	45	#include "lwip/def.h"
darran	0:ac21159e27f4	46	#include "lwip/memp.h"
darran	0:ac21159e27f4	47	#include "lwip/tcpip.h"
darran	0:ac21159e27f4	48
darran	0:ac21159e27f4	49	#include "lwip/tcp_impl.h"
darran	0:ac21159e27f4	50	#include "lwip/ip_frag.h"
darran	0:ac21159e27f4	51	#include "netif/etharp.h"
darran	0:ac21159e27f4	52	#include "lwip/dhcp.h"
darran	0:ac21159e27f4	53	#include "lwip/autoip.h"
darran	0:ac21159e27f4	54	#include "lwip/igmp.h"
darran	0:ac21159e27f4	55	#include "lwip/dns.h"
darran	0:ac21159e27f4	56
darran	0:ac21159e27f4	57
darran	0:ac21159e27f4	58	/** The one and only timeout list */
darran	0:ac21159e27f4	59	static struct sys_timeo *next_timeout;
darran	0:ac21159e27f4	60	#if NO_SYS
darran	0:ac21159e27f4	61	static u32_t timeouts_last_time;
darran	0:ac21159e27f4	62	#endif /* NO_SYS */
darran	0:ac21159e27f4	63
darran	0:ac21159e27f4	64	#if LWIP_TCP
darran	0:ac21159e27f4	65	/** global variable that shows if the tcp timer is currently scheduled or not */
darran	0:ac21159e27f4	66	static int tcpip_tcp_timer_active;
darran	0:ac21159e27f4	67
darran	0:ac21159e27f4	68	/**
darran	0:ac21159e27f4	69	* Timer callback function that calls tcp_tmr() and reschedules itself.
darran	0:ac21159e27f4	70	*
darran	0:ac21159e27f4	71	* @param arg unused argument
darran	0:ac21159e27f4	72	*/
darran	0:ac21159e27f4	73	static void
darran	0:ac21159e27f4	74	tcpip_tcp_timer(void *arg)
darran	0:ac21159e27f4	75	{
darran	0:ac21159e27f4	76	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	77
darran	0:ac21159e27f4	78	/* call TCP timer handler */
darran	0:ac21159e27f4	79	tcp_tmr();
darran	0:ac21159e27f4	80	/* timer still needed? */
darran	0:ac21159e27f4	81	if (tcp_active_pcbs \|\| tcp_tw_pcbs) {
darran	0:ac21159e27f4	82	/* restart timer */
darran	0:ac21159e27f4	83	sys_timeout(TCP_TMR_INTERVAL, tcpip_tcp_timer, NULL);
darran	0:ac21159e27f4	84	} else {
darran	0:ac21159e27f4	85	/* disable timer */
darran	0:ac21159e27f4	86	tcpip_tcp_timer_active = 0;
darran	0:ac21159e27f4	87	}
darran	0:ac21159e27f4	88	}
darran	0:ac21159e27f4	89
darran	0:ac21159e27f4	90	/**
darran	0:ac21159e27f4	91	* Called from TCP_REG when registering a new PCB:
darran	0:ac21159e27f4	92	* the reason is to have the TCP timer only running when
darran	0:ac21159e27f4	93	* there are active (or time-wait) PCBs.
darran	0:ac21159e27f4	94	*/
darran	0:ac21159e27f4	95	void
darran	0:ac21159e27f4	96	tcp_timer_needed(void)
darran	0:ac21159e27f4	97	{
darran	0:ac21159e27f4	98	/* timer is off but needed again? */
darran	0:ac21159e27f4	99	if (!tcpip_tcp_timer_active && (tcp_active_pcbs \|\| tcp_tw_pcbs)) {
darran	0:ac21159e27f4	100	/* enable and start timer */
darran	0:ac21159e27f4	101	tcpip_tcp_timer_active = 1;
darran	0:ac21159e27f4	102	sys_timeout(TCP_TMR_INTERVAL, tcpip_tcp_timer, NULL);
darran	0:ac21159e27f4	103	}
darran	0:ac21159e27f4	104	}
darran	0:ac21159e27f4	105	#endif /* LWIP_TCP */
darran	0:ac21159e27f4	106
darran	0:ac21159e27f4	107	#if IP_REASSEMBLY
darran	0:ac21159e27f4	108	/**
darran	0:ac21159e27f4	109	* Timer callback function that calls ip_reass_tmr() and reschedules itself.
darran	0:ac21159e27f4	110	*
darran	0:ac21159e27f4	111	* @param arg unused argument
darran	0:ac21159e27f4	112	*/
darran	0:ac21159e27f4	113	static void
darran	0:ac21159e27f4	114	ip_reass_timer(void *arg)
darran	0:ac21159e27f4	115	{
darran	0:ac21159e27f4	116	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	117	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: ip_reass_tmr()\n"));
darran	0:ac21159e27f4	118	ip_reass_tmr();
darran	0:ac21159e27f4	119	sys_timeout(IP_TMR_INTERVAL, ip_reass_timer, NULL);
darran	0:ac21159e27f4	120	}
darran	0:ac21159e27f4	121	#endif /* IP_REASSEMBLY */
darran	0:ac21159e27f4	122
darran	0:ac21159e27f4	123	#if LWIP_ARP
darran	0:ac21159e27f4	124	/**
darran	0:ac21159e27f4	125	* Timer callback function that calls etharp_tmr() and reschedules itself.
darran	0:ac21159e27f4	126	*
darran	0:ac21159e27f4	127	* @param arg unused argument
darran	0:ac21159e27f4	128	*/
darran	0:ac21159e27f4	129	static void
darran	0:ac21159e27f4	130	arp_timer(void *arg)
darran	0:ac21159e27f4	131	{
darran	0:ac21159e27f4	132	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	133	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: etharp_tmr()\n"));
darran	0:ac21159e27f4	134	etharp_tmr();
darran	0:ac21159e27f4	135	sys_timeout(ARP_TMR_INTERVAL, arp_timer, NULL);
darran	0:ac21159e27f4	136	}
darran	0:ac21159e27f4	137	#endif /* LWIP_ARP */
darran	0:ac21159e27f4	138
darran	0:ac21159e27f4	139	#if LWIP_DHCP
darran	0:ac21159e27f4	140	/**
darran	0:ac21159e27f4	141	* Timer callback function that calls dhcp_coarse_tmr() and reschedules itself.
darran	0:ac21159e27f4	142	*
darran	0:ac21159e27f4	143	* @param arg unused argument
darran	0:ac21159e27f4	144	*/
darran	0:ac21159e27f4	145	static void
darran	0:ac21159e27f4	146	dhcp_timer_coarse(void *arg)
darran	0:ac21159e27f4	147	{
darran	0:ac21159e27f4	148	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	149	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: dhcp_coarse_tmr()\n"));
darran	0:ac21159e27f4	150	dhcp_coarse_tmr();
darran	0:ac21159e27f4	151	sys_timeout(DHCP_COARSE_TIMER_MSECS, dhcp_timer_coarse, NULL);
darran	0:ac21159e27f4	152	}
darran	0:ac21159e27f4	153
darran	0:ac21159e27f4	154	/**
darran	0:ac21159e27f4	155	* Timer callback function that calls dhcp_fine_tmr() and reschedules itself.
darran	0:ac21159e27f4	156	*
darran	0:ac21159e27f4	157	* @param arg unused argument
darran	0:ac21159e27f4	158	*/
darran	0:ac21159e27f4	159	static void
darran	0:ac21159e27f4	160	dhcp_timer_fine(void *arg)
darran	0:ac21159e27f4	161	{
darran	0:ac21159e27f4	162	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	163	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: dhcp_fine_tmr()\n"));
darran	0:ac21159e27f4	164	dhcp_fine_tmr();
darran	0:ac21159e27f4	165	sys_timeout(DHCP_FINE_TIMER_MSECS, dhcp_timer_fine, NULL);
darran	0:ac21159e27f4	166	}
darran	0:ac21159e27f4	167	#endif /* LWIP_DHCP */
darran	0:ac21159e27f4	168
darran	0:ac21159e27f4	169	#if LWIP_AUTOIP
darran	0:ac21159e27f4	170	/**
darran	0:ac21159e27f4	171	* Timer callback function that calls autoip_tmr() and reschedules itself.
darran	0:ac21159e27f4	172	*
darran	0:ac21159e27f4	173	* @param arg unused argument
darran	0:ac21159e27f4	174	*/
darran	0:ac21159e27f4	175	static void
darran	0:ac21159e27f4	176	autoip_timer(void *arg)
darran	0:ac21159e27f4	177	{
darran	0:ac21159e27f4	178	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	179	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: autoip_tmr()\n"));
darran	0:ac21159e27f4	180	autoip_tmr();
darran	0:ac21159e27f4	181	sys_timeout(AUTOIP_TMR_INTERVAL, autoip_timer, NULL);
darran	0:ac21159e27f4	182	}
darran	0:ac21159e27f4	183	#endif /* LWIP_AUTOIP */
darran	0:ac21159e27f4	184
darran	0:ac21159e27f4	185	#if LWIP_IGMP
darran	0:ac21159e27f4	186	/**
darran	0:ac21159e27f4	187	* Timer callback function that calls igmp_tmr() and reschedules itself.
darran	0:ac21159e27f4	188	*
darran	0:ac21159e27f4	189	* @param arg unused argument
darran	0:ac21159e27f4	190	*/
darran	0:ac21159e27f4	191	static void
darran	0:ac21159e27f4	192	igmp_timer(void *arg)
darran	0:ac21159e27f4	193	{
darran	0:ac21159e27f4	194	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	195	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: igmp_tmr()\n"));
darran	0:ac21159e27f4	196	igmp_tmr();
darran	0:ac21159e27f4	197	sys_timeout(IGMP_TMR_INTERVAL, igmp_timer, NULL);
darran	0:ac21159e27f4	198	}
darran	0:ac21159e27f4	199	#endif /* LWIP_IGMP */
darran	0:ac21159e27f4	200
darran	0:ac21159e27f4	201	#if LWIP_DNS
darran	0:ac21159e27f4	202	/**
darran	0:ac21159e27f4	203	* Timer callback function that calls dns_tmr() and reschedules itself.
darran	0:ac21159e27f4	204	*
darran	0:ac21159e27f4	205	* @param arg unused argument
darran	0:ac21159e27f4	206	*/
darran	0:ac21159e27f4	207	static void
darran	0:ac21159e27f4	208	dns_timer(void *arg)
darran	0:ac21159e27f4	209	{
darran	0:ac21159e27f4	210	LWIP_UNUSED_ARG(arg);
darran	0:ac21159e27f4	211	LWIP_DEBUGF(TIMERS_DEBUG, ("tcpip: dns_tmr()\n"));
darran	0:ac21159e27f4	212	dns_tmr();
darran	0:ac21159e27f4	213	sys_timeout(DNS_TMR_INTERVAL, dns_timer, NULL);
darran	0:ac21159e27f4	214	}
darran	0:ac21159e27f4	215	#endif /* LWIP_DNS */
darran	0:ac21159e27f4	216
darran	0:ac21159e27f4	217	/** Initialize this module */
darran	0:ac21159e27f4	218	void sys_timeouts_init(void)
darran	0:ac21159e27f4	219	{
darran	0:ac21159e27f4	220	#if IP_REASSEMBLY
darran	0:ac21159e27f4	221	sys_timeout(IP_TMR_INTERVAL, ip_reass_timer, NULL);
darran	0:ac21159e27f4	222	#endif /* IP_REASSEMBLY */
darran	0:ac21159e27f4	223	#if LWIP_ARP
darran	0:ac21159e27f4	224	sys_timeout(ARP_TMR_INTERVAL, arp_timer, NULL);
darran	0:ac21159e27f4	225	#endif /* LWIP_ARP */
darran	0:ac21159e27f4	226	#if LWIP_DHCP
darran	0:ac21159e27f4	227	sys_timeout(DHCP_COARSE_TIMER_MSECS, dhcp_timer_coarse, NULL);
darran	0:ac21159e27f4	228	sys_timeout(DHCP_FINE_TIMER_MSECS, dhcp_timer_fine, NULL);
darran	0:ac21159e27f4	229	#endif /* LWIP_DHCP */
darran	0:ac21159e27f4	230	#if LWIP_AUTOIP
darran	0:ac21159e27f4	231	sys_timeout(AUTOIP_TMR_INTERVAL, autoip_timer, NULL);
darran	0:ac21159e27f4	232	#endif /* LWIP_AUTOIP */
darran	0:ac21159e27f4	233	#if LWIP_IGMP
darran	0:ac21159e27f4	234	sys_timeout(IGMP_TMR_INTERVAL, igmp_timer, NULL);
darran	0:ac21159e27f4	235	#endif /* LWIP_IGMP */
darran	0:ac21159e27f4	236	#if LWIP_DNS
darran	0:ac21159e27f4	237	sys_timeout(DNS_TMR_INTERVAL, dns_timer, NULL);
darran	0:ac21159e27f4	238	#endif /* LWIP_DNS */
darran	0:ac21159e27f4	239
darran	0:ac21159e27f4	240	#if NO_SYS
darran	0:ac21159e27f4	241	/* Initialise timestamp for sys_check_timeouts */
darran	0:ac21159e27f4	242	timeouts_last_time = sys_now();
darran	0:ac21159e27f4	243	#endif
darran	0:ac21159e27f4	244	}
darran	0:ac21159e27f4	245
darran	0:ac21159e27f4	246	/**
darran	0:ac21159e27f4	247	* Create a one-shot timer (aka timeout). Timeouts are processed in the
darran	0:ac21159e27f4	248	* following cases:
darran	0:ac21159e27f4	249	* - while waiting for a message using sys_timeouts_mbox_fetch()
darran	0:ac21159e27f4	250	* - by calling sys_check_timeouts() (NO_SYS==1 only)
darran	0:ac21159e27f4	251	*
darran	0:ac21159e27f4	252	* @param msecs time in milliseconds after that the timer should expire
darran	0:ac21159e27f4	253	* @param h callback function to call when msecs have elapsed
darran	0:ac21159e27f4	254	* @param arg argument to pass to the callback function
darran	0:ac21159e27f4	255	*/
darran	0:ac21159e27f4	256	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	257	void
darran	0:ac21159e27f4	258	sys_timeout_debug(u32_t msecs, sys_timeout_handler h, void arg, const char handler_name)
darran	0:ac21159e27f4	259	#else /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	260	void
darran	0:ac21159e27f4	261	sys_timeout(u32_t msecs, sys_timeout_handler h, void *arg)
darran	0:ac21159e27f4	262	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	263	{
darran	0:ac21159e27f4	264	struct sys_timeo timeout, t;
darran	0:ac21159e27f4	265
darran	0:ac21159e27f4	266	timeout = (struct sys_timeo *)memp_malloc(MEMP_SYS_TIMEOUT);
darran	0:ac21159e27f4	267	if (timeout == NULL) {
darran	0:ac21159e27f4	268	LWIP_ASSERT("sys_timeout: timeout != NULL, pool MEMP_SYS_TIMEOUT is empty", timeout != NULL);
darran	0:ac21159e27f4	269	return;
darran	0:ac21159e27f4	270	}
darran	0:ac21159e27f4	271	timeout->next = NULL;
darran	0:ac21159e27f4	272	timeout->h = h;
darran	0:ac21159e27f4	273	timeout->arg = arg;
darran	0:ac21159e27f4	274	timeout->time = msecs;
darran	0:ac21159e27f4	275	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	276	timeout->handler_name = handler_name;
darran	0:ac21159e27f4	277	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	278
darran	0:ac21159e27f4	279	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	280	LWIP_DEBUGF(TIMERS_DEBUG, ("sys_timeout: %p msecs=%"U32_F" h=%p arg=%p name=%s\n",
darran	0:ac21159e27f4	281	(void )timeout, msecs, (void*)&h, (void )arg, handler_name));
darran	0:ac21159e27f4	282	#else /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	283	LWIP_DEBUGF(TIMERS_DEBUG, ("sys_timeout: %p msecs=%"U32_F" h=%p arg=%p\n",
darran	0:ac21159e27f4	284	(void )timeout, msecs, (void*)&h, (void )arg));
darran	0:ac21159e27f4	285	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	286
darran	0:ac21159e27f4	287	if (next_timeout == NULL) {
darran	0:ac21159e27f4	288	next_timeout = timeout;
darran	0:ac21159e27f4	289	return;
darran	0:ac21159e27f4	290	}
darran	0:ac21159e27f4	291
darran	0:ac21159e27f4	292	if (next_timeout->time > msecs) {
darran	0:ac21159e27f4	293	next_timeout->time -= msecs;
darran	0:ac21159e27f4	294	timeout->next = next_timeout;
darran	0:ac21159e27f4	295	next_timeout = timeout;
darran	0:ac21159e27f4	296	} else {
darran	0:ac21159e27f4	297	for(t = next_timeout; t != NULL; t = t->next) {
darran	0:ac21159e27f4	298	timeout->time -= t->time;
darran	0:ac21159e27f4	299	if (t->next == NULL \|\| t->next->time > timeout->time) {
darran	0:ac21159e27f4	300	if (t->next != NULL) {
darran	0:ac21159e27f4	301	t->next->time -= timeout->time;
darran	0:ac21159e27f4	302	}
darran	0:ac21159e27f4	303	timeout->next = t->next;
darran	0:ac21159e27f4	304	t->next = timeout;
darran	0:ac21159e27f4	305	break;
darran	0:ac21159e27f4	306	}
darran	0:ac21159e27f4	307	}
darran	0:ac21159e27f4	308	}
darran	0:ac21159e27f4	309	}
darran	0:ac21159e27f4	310
darran	0:ac21159e27f4	311	/**
darran	0:ac21159e27f4	312	* Go through timeout list (for this task only) and remove the first matching
darran	0:ac21159e27f4	313	* entry, even though the timeout has not triggered yet.
darran	0:ac21159e27f4	314	*
darran	0:ac21159e27f4	315	* @note This function only works as expected if there is only one timeout
darran	0:ac21159e27f4	316	* calling 'h' in the list of timeouts.
darran	0:ac21159e27f4	317	*
darran	0:ac21159e27f4	318	* @param h callback function that would be called by the timeout
darran	0:ac21159e27f4	319	* @param arg callback argument that would be passed to h
darran	0:ac21159e27f4	320	*/
darran	0:ac21159e27f4	321	void
darran	0:ac21159e27f4	322	sys_untimeout(sys_timeout_handler h, void *arg)
darran	0:ac21159e27f4	323	{
darran	0:ac21159e27f4	324	struct sys_timeo prev_t, t;
darran	0:ac21159e27f4	325
darran	0:ac21159e27f4	326	if (next_timeout == NULL) {
darran	0:ac21159e27f4	327	return;
darran	0:ac21159e27f4	328	}
darran	0:ac21159e27f4	329
darran	0:ac21159e27f4	330	for (t = next_timeout, prev_t = NULL; t != NULL; prev_t = t, t = t->next) {
darran	0:ac21159e27f4	331	if ((t->h == h) && (t->arg == arg)) {
darran	0:ac21159e27f4	332	/* We have a match */
darran	0:ac21159e27f4	333	/* Unlink from previous in list */
darran	0:ac21159e27f4	334	if (prev_t == NULL) {
darran	0:ac21159e27f4	335	next_timeout = t->next;
darran	0:ac21159e27f4	336	} else {
darran	0:ac21159e27f4	337	prev_t->next = t->next;
darran	0:ac21159e27f4	338	}
darran	0:ac21159e27f4	339	/* If not the last one, add time of this one back to next */
darran	0:ac21159e27f4	340	if (t->next != NULL) {
darran	0:ac21159e27f4	341	t->next->time += t->time;
darran	0:ac21159e27f4	342	}
darran	0:ac21159e27f4	343	memp_free(MEMP_SYS_TIMEOUT, t);
darran	0:ac21159e27f4	344	return;
darran	0:ac21159e27f4	345	}
darran	0:ac21159e27f4	346	}
darran	0:ac21159e27f4	347	return;
darran	0:ac21159e27f4	348	}
darran	0:ac21159e27f4	349
darran	0:ac21159e27f4	350	#if NO_SYS
darran	0:ac21159e27f4	351
darran	0:ac21159e27f4	352	/** Handle timeouts for NO_SYS==1 (i.e. without using
darran	0:ac21159e27f4	353	* tcpip_thread/sys_timeouts_mbox_fetch(). Uses sys_now() to call timeout
darran	0:ac21159e27f4	354	* handler functions when timeouts expire.
darran	0:ac21159e27f4	355	*
darran	0:ac21159e27f4	356	* Must be called periodically from your main loop.
darran	0:ac21159e27f4	357	*/
darran	0:ac21159e27f4	358	void
darran	0:ac21159e27f4	359	sys_check_timeouts(void)
darran	0:ac21159e27f4	360	{
darran	0:ac21159e27f4	361	struct sys_timeo *tmptimeout;
darran	0:ac21159e27f4	362	u32_t diff;
darran	0:ac21159e27f4	363	sys_timeout_handler h;
darran	0:ac21159e27f4	364	void *arg;
darran	0:ac21159e27f4	365	int had_one;
darran	0:ac21159e27f4	366	u32_t now;
darran	0:ac21159e27f4	367	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	368	const char *handler_name;
darran	0:ac21159e27f4	369	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	370
darran	0:ac21159e27f4	371	now = sys_now();
darran	0:ac21159e27f4	372	if (next_timeout) {
darran	0:ac21159e27f4	373	/* @todo: wrap around? */
darran	0:ac21159e27f4	374	diff = now - timeouts_last_time;
darran	0:ac21159e27f4	375	do
darran	0:ac21159e27f4	376	{
darran	0:ac21159e27f4	377	had_one = 0;
darran	0:ac21159e27f4	378	tmptimeout = next_timeout;
darran	0:ac21159e27f4	379	if (tmptimeout->time <= diff) {
darran	0:ac21159e27f4	380	/* timeout has expired */
darran	0:ac21159e27f4	381	had_one = 1;
darran	0:ac21159e27f4	382	timeouts_last_time = now;
darran	0:ac21159e27f4	383	diff -= tmptimeout->time;
darran	0:ac21159e27f4	384	next_timeout = tmptimeout->next;
darran	0:ac21159e27f4	385	h = tmptimeout->h;
darran	0:ac21159e27f4	386	arg = tmptimeout->arg;
darran	0:ac21159e27f4	387	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	388	handler_name = tmptimeout->handler_name;
darran	0:ac21159e27f4	389	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	390	memp_free(MEMP_SYS_TIMEOUT, tmptimeout);
darran	0:ac21159e27f4	391	if (h != NULL) {
darran	0:ac21159e27f4	392	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	393	LWIP_DEBUGF(TIMERS_DEBUG, ("sct calling h=%p(%p) (%s)\n", (void*)&h, arg, handler_name));
darran	0:ac21159e27f4	394	#else /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	395	LWIP_DEBUGF(TIMERS_DEBUG, ("sct calling h=%p(%p)\n", (void*)&h, arg));
darran	0:ac21159e27f4	396	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	397	h(arg);
darran	0:ac21159e27f4	398	}
darran	0:ac21159e27f4	399	}
darran	0:ac21159e27f4	400	/* repeat until all expired timers have been called */
darran	0:ac21159e27f4	401	}while(had_one);
darran	0:ac21159e27f4	402	}
darran	0:ac21159e27f4	403	}
darran	0:ac21159e27f4	404
darran	0:ac21159e27f4	405	/** Set back the timestamp of the last call to sys_check_timeouts()
darran	0:ac21159e27f4	406	* This is necessary if sys_check_timeouts() hasn't been called for a long
darran	0:ac21159e27f4	407	* time (e.g. while saving energy) to prevent all timer functions of that
darran	0:ac21159e27f4	408	* period being called.
darran	0:ac21159e27f4	409	*/
darran	0:ac21159e27f4	410	void
darran	0:ac21159e27f4	411	sys_restart_timeouts(void)
darran	0:ac21159e27f4	412	{
darran	0:ac21159e27f4	413	timeouts_last_time = sys_now();
darran	0:ac21159e27f4	414	}
darran	0:ac21159e27f4	415
darran	0:ac21159e27f4	416	#else /* NO_SYS */
darran	0:ac21159e27f4	417
darran	0:ac21159e27f4	418	/**
darran	0:ac21159e27f4	419	* Wait (forever) for a message to arrive in an mbox.
darran	0:ac21159e27f4	420	* While waiting, timeouts are processed.
darran	0:ac21159e27f4	421	*
darran	0:ac21159e27f4	422	* @param mbox the mbox to fetch the message from
darran	0:ac21159e27f4	423	* @param msg the place to store the message
darran	0:ac21159e27f4	424	*/
darran	0:ac21159e27f4	425	void
darran	0:ac21159e27f4	426	sys_timeouts_mbox_fetch(sys_mbox_t mbox, void *msg)
darran	0:ac21159e27f4	427	{
darran	0:ac21159e27f4	428	u32_t time_needed;
darran	0:ac21159e27f4	429	struct sys_timeo *tmptimeout;
darran	0:ac21159e27f4	430	sys_timeout_handler h;
darran	0:ac21159e27f4	431	void *arg;
darran	0:ac21159e27f4	432	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	433	const char *handler_name;
darran	0:ac21159e27f4	434	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	435
darran	0:ac21159e27f4	436	again:
darran	0:ac21159e27f4	437	if (!next_timeout) {
darran	0:ac21159e27f4	438	time_needed = sys_arch_mbox_fetch(mbox, msg, 0);
darran	0:ac21159e27f4	439	} else {
darran	0:ac21159e27f4	440	if (next_timeout->time > 0) {
darran	0:ac21159e27f4	441	time_needed = sys_arch_mbox_fetch(mbox, msg, next_timeout->time);
darran	0:ac21159e27f4	442	} else {
darran	0:ac21159e27f4	443	time_needed = SYS_ARCH_TIMEOUT;
darran	0:ac21159e27f4	444	}
darran	0:ac21159e27f4	445
darran	0:ac21159e27f4	446	if (time_needed == SYS_ARCH_TIMEOUT) {
darran	0:ac21159e27f4	447	/* If time == SYS_ARCH_TIMEOUT, a timeout occured before a message
darran	0:ac21159e27f4	448	could be fetched. We should now call the timeout handler and
darran	0:ac21159e27f4	449	deallocate the memory allocated for the timeout. */
darran	0:ac21159e27f4	450	tmptimeout = next_timeout;
darran	0:ac21159e27f4	451	next_timeout = tmptimeout->next;
darran	0:ac21159e27f4	452	h = tmptimeout->h;
darran	0:ac21159e27f4	453	arg = tmptimeout->arg;
darran	0:ac21159e27f4	454	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	455	handler_name = tmptimeout->handler_name;
darran	0:ac21159e27f4	456	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	457	memp_free(MEMP_SYS_TIMEOUT, tmptimeout);
darran	0:ac21159e27f4	458	if (h != NULL) {
darran	0:ac21159e27f4	459	#if LWIP_DEBUG_TIMERNAMES
darran	0:ac21159e27f4	460	LWIP_DEBUGF(TIMERS_DEBUG, ("stmf calling h=%p(%p) (%s)\n", (void*)&h, arg, handler_name));
darran	0:ac21159e27f4	461	#else /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	462	LWIP_DEBUGF(TIMERS_DEBUG, ("stmf calling h=%p(%p)\n", (void*)&h, arg));
darran	0:ac21159e27f4	463	#endif /* LWIP_DEBUG_TIMERNAMES */
darran	0:ac21159e27f4	464	/* For LWIP_TCPIP_CORE_LOCKING, lock the core before calling the
darran	0:ac21159e27f4	465	timeout handler function. */
darran	0:ac21159e27f4	466	LOCK_TCPIP_CORE();
darran	0:ac21159e27f4	467	h(arg);
darran	0:ac21159e27f4	468	UNLOCK_TCPIP_CORE();
darran	0:ac21159e27f4	469	}
darran	0:ac21159e27f4	470
darran	0:ac21159e27f4	471	/* We try again to fetch a message from the mbox. */
darran	0:ac21159e27f4	472	goto again;
darran	0:ac21159e27f4	473	} else {
darran	0:ac21159e27f4	474	/* If time != SYS_ARCH_TIMEOUT, a message was received before the timeout
darran	0:ac21159e27f4	475	occured. The time variable is set to the number of
darran	0:ac21159e27f4	476	milliseconds we waited for the message. */
darran	0:ac21159e27f4	477	if (time_needed < next_timeout->time) {
darran	0:ac21159e27f4	478	next_timeout->time -= time_needed;
darran	0:ac21159e27f4	479	} else {
darran	0:ac21159e27f4	480	next_timeout->time = 0;
darran	0:ac21159e27f4	481	}
darran	0:ac21159e27f4	482	}
darran	0:ac21159e27f4	483	}
darran	0:ac21159e27f4	484	}
darran	0:ac21159e27f4	485
darran	0:ac21159e27f4	486	#endif /* NO_SYS */

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	02 Jul 2010
Imports:	2
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	1
Followers:	1

lwip/core/timers.c@0:ac21159e27f4, 2010-07-02 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning