StrippedDownNetServices - This library is stripped down version of NetServi…

Users » idinor » Code » StrippedDownNetServices

idinor Launcher / StrippedDownNetServices

This library is stripped down version of NetServices library. HTTP server and client function is NOT supported.

lwip/core/timers.c@0:dcf3c92487ca, 2011-07-20 (annotated)

Committer:: idinor
Date:: Wed Jul 20 11:45:39 2011 +0000
Revision:: 0:dcf3c92487ca

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	20 Jul 2011
Imports:	35
Forks:	0
Commits:	1
Dependents:	1
Dependencies:	0
Followers:	1

lwip/core/timers.c@0:dcf3c92487ca, 2011-07-20 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning