孙 毅明 / Mbed 2 deprecated 123

创建mbed

Dependencies:   EthernetInterface SDFileSystem mbed-rtos mbed

EthernetInterface/lwip/core/timers.c@1:6465a3f5c58a, 2018-03-06 (annotated)

Committer:
sunyiming
Date:
Tue Mar 06 08:53:46 2018 +0000
Revision:
1:6465a3f5c58a
??OK

Who changed what in which revision?

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