Adam Green / EthernetInterface

Deprecated fork of old network stack source from github. Please use official library instead: https://mbed.org/users/mbed_official/code/EthernetInterface/

lwip/api/tcpip.c@1:eadc868c2acf, 2013-10-26 (annotated)

Committer:
AdamGreen
Date:
Sat Oct 26 08:51:36 2013 +0000
Revision:
1:eadc868c2acf
Parent:
0:3b00827bb0b7 
Fix TCP checksum bug and stranded large TCP segments.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
AdamGreen 0:3b00827bb0b7 1 /**
AdamGreen 0:3b00827bb0b7 2 * @file
AdamGreen 0:3b00827bb0b7 3 * Sequential API Main thread module
AdamGreen 0:3b00827bb0b7 4 *
AdamGreen 0:3b00827bb0b7 5 */
AdamGreen 0:3b00827bb0b7 6
AdamGreen 0:3b00827bb0b7 7 /*
AdamGreen 0:3b00827bb0b7 8 * Copyright (c) 2001-2004 Swedish Institute of Computer Science.
AdamGreen 0:3b00827bb0b7 9 * All rights reserved.
AdamGreen 0:3b00827bb0b7 10 *
AdamGreen 0:3b00827bb0b7 11 * Redistribution and use in source and binary forms, with or without modification,
AdamGreen 0:3b00827bb0b7 12 * are permitted provided that the following conditions are met:
AdamGreen 0:3b00827bb0b7 13 *
AdamGreen 0:3b00827bb0b7 14 * 1. Redistributions of source code must retain the above copyright notice,
AdamGreen 0:3b00827bb0b7 15 * this list of conditions and the following disclaimer.
AdamGreen 0:3b00827bb0b7 16 * 2. Redistributions in binary form must reproduce the above copyright notice,
AdamGreen 0:3b00827bb0b7 17 * this list of conditions and the following disclaimer in the documentation
AdamGreen 0:3b00827bb0b7 18 * and/or other materials provided with the distribution.
AdamGreen 0:3b00827bb0b7 19 * 3. The name of the author may not be used to endorse or promote products
AdamGreen 0:3b00827bb0b7 20 * derived from this software without specific prior written permission.
AdamGreen 0:3b00827bb0b7 21 *
AdamGreen 0:3b00827bb0b7 22 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
AdamGreen 0:3b00827bb0b7 23 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
AdamGreen 0:3b00827bb0b7 24 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
AdamGreen 0:3b00827bb0b7 25 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
AdamGreen 0:3b00827bb0b7 26 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
AdamGreen 0:3b00827bb0b7 27 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
AdamGreen 0:3b00827bb0b7 28 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
AdamGreen 0:3b00827bb0b7 29 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
AdamGreen 0:3b00827bb0b7 30 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
AdamGreen 0:3b00827bb0b7 31 * OF SUCH DAMAGE.
AdamGreen 0:3b00827bb0b7 32 *
AdamGreen 0:3b00827bb0b7 33 * This file is part of the lwIP TCP/IP stack.
AdamGreen 0:3b00827bb0b7 34 *
AdamGreen 0:3b00827bb0b7 35 * Author: Adam Dunkels <adam@sics.se>
AdamGreen 0:3b00827bb0b7 36 *
AdamGreen 0:3b00827bb0b7 37 */
AdamGreen 0:3b00827bb0b7 38
AdamGreen 0:3b00827bb0b7 39 #include "lwip/opt.h"
AdamGreen 0:3b00827bb0b7 40
AdamGreen 0:3b00827bb0b7 41 #if !NO_SYS /* don't build if not configured for use in lwipopts.h */
AdamGreen 0:3b00827bb0b7 42
AdamGreen 0:3b00827bb0b7 43 #include "lwip/sys.h"
AdamGreen 0:3b00827bb0b7 44 #include "lwip/memp.h"
AdamGreen 0:3b00827bb0b7 45 #include "lwip/mem.h"
AdamGreen 0:3b00827bb0b7 46 #include "lwip/pbuf.h"
AdamGreen 0:3b00827bb0b7 47 #include "lwip/tcpip.h"
AdamGreen 0:3b00827bb0b7 48 #include "lwip/init.h"
AdamGreen 0:3b00827bb0b7 49 #include "netif/etharp.h"
AdamGreen 0:3b00827bb0b7 50 #include "netif/ppp_oe.h"
AdamGreen 0:3b00827bb0b7 51
AdamGreen 0:3b00827bb0b7 52 /* global variables */
AdamGreen 0:3b00827bb0b7 53 static tcpip_init_done_fn tcpip_init_done;
AdamGreen 0:3b00827bb0b7 54 static void *tcpip_init_done_arg;
AdamGreen 0:3b00827bb0b7 55 static sys_mbox_t mbox;
AdamGreen 0:3b00827bb0b7 56
AdamGreen 0:3b00827bb0b7 57 #if LWIP_TCPIP_CORE_LOCKING
AdamGreen 0:3b00827bb0b7 58 /** The global semaphore to lock the stack. */
AdamGreen 0:3b00827bb0b7 59 sys_mutex_t lock_tcpip_core;
AdamGreen 0:3b00827bb0b7 60 #endif /* LWIP_TCPIP_CORE_LOCKING */
AdamGreen 0:3b00827bb0b7 61
AdamGreen 0:3b00827bb0b7 62
AdamGreen 0:3b00827bb0b7 63 /**
AdamGreen 0:3b00827bb0b7 64 * The main lwIP thread. This thread has exclusive access to lwIP core functions
AdamGreen 0:3b00827bb0b7 65 * (unless access to them is not locked). Other threads communicate with this
AdamGreen 0:3b00827bb0b7 66 * thread using message boxes.
AdamGreen 0:3b00827bb0b7 67 *
AdamGreen 0:3b00827bb0b7 68 * It also starts all the timers to make sure they are running in the right
AdamGreen 0:3b00827bb0b7 69 * thread context.
AdamGreen 0:3b00827bb0b7 70 *
AdamGreen 0:3b00827bb0b7 71 * @param arg unused argument
AdamGreen 0:3b00827bb0b7 72 */
AdamGreen 0:3b00827bb0b7 73 static void
AdamGreen 0:3b00827bb0b7 74 tcpip_thread(void *arg)
AdamGreen 0:3b00827bb0b7 75 {
AdamGreen 0:3b00827bb0b7 76 struct tcpip_msg *msg;
AdamGreen 0:3b00827bb0b7 77 LWIP_UNUSED_ARG(arg);
AdamGreen 0:3b00827bb0b7 78
AdamGreen 0:3b00827bb0b7 79 if (tcpip_init_done != NULL) {
AdamGreen 0:3b00827bb0b7 80 tcpip_init_done(tcpip_init_done_arg);
AdamGreen 0:3b00827bb0b7 81 }
AdamGreen 0:3b00827bb0b7 82
AdamGreen 0:3b00827bb0b7 83 LOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 84 while (1) { /* MAIN Loop */
AdamGreen 0:3b00827bb0b7 85 UNLOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 86 LWIP_TCPIP_THREAD_ALIVE();
AdamGreen 0:3b00827bb0b7 87 /* wait for a message, timeouts are processed while waiting */
AdamGreen 0:3b00827bb0b7 88 sys_timeouts_mbox_fetch(&mbox, (void **)&msg);
AdamGreen 0:3b00827bb0b7 89 LOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 90 switch (msg->type) {
AdamGreen 0:3b00827bb0b7 91 #if LWIP_NETCONN
AdamGreen 0:3b00827bb0b7 92 case TCPIP_MSG_API:
AdamGreen 0:3b00827bb0b7 93 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: API message %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 94 msg->msg.apimsg->function(&(msg->msg.apimsg->msg));
AdamGreen 0:3b00827bb0b7 95 break;
AdamGreen 0:3b00827bb0b7 96 #endif /* LWIP_NETCONN */
AdamGreen 0:3b00827bb0b7 97
AdamGreen 0:3b00827bb0b7 98 #if !LWIP_TCPIP_CORE_LOCKING_INPUT
AdamGreen 0:3b00827bb0b7 99 case TCPIP_MSG_INPKT:
AdamGreen 0:3b00827bb0b7 100 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: PACKET %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 101 #if LWIP_ETHERNET
AdamGreen 0:3b00827bb0b7 102 if (msg->msg.inp.netif->flags & (NETIF_FLAG_ETHARP | NETIF_FLAG_ETHERNET)) {
AdamGreen 0:3b00827bb0b7 103 ethernet_input(msg->msg.inp.p, msg->msg.inp.netif);
AdamGreen 0:3b00827bb0b7 104 } else
AdamGreen 0:3b00827bb0b7 105 #endif /* LWIP_ETHERNET */
AdamGreen 0:3b00827bb0b7 106 {
AdamGreen 0:3b00827bb0b7 107 ip_input(msg->msg.inp.p, msg->msg.inp.netif);
AdamGreen 0:3b00827bb0b7 108 }
AdamGreen 0:3b00827bb0b7 109 memp_free(MEMP_TCPIP_MSG_INPKT, msg);
AdamGreen 0:3b00827bb0b7 110 break;
AdamGreen 0:3b00827bb0b7 111 #endif /* LWIP_TCPIP_CORE_LOCKING_INPUT */
AdamGreen 0:3b00827bb0b7 112
AdamGreen 0:3b00827bb0b7 113 #if LWIP_NETIF_API
AdamGreen 0:3b00827bb0b7 114 case TCPIP_MSG_NETIFAPI:
AdamGreen 0:3b00827bb0b7 115 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: Netif API message %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 116 msg->msg.netifapimsg->function(&(msg->msg.netifapimsg->msg));
AdamGreen 0:3b00827bb0b7 117 break;
AdamGreen 0:3b00827bb0b7 118 #endif /* LWIP_NETIF_API */
AdamGreen 0:3b00827bb0b7 119
AdamGreen 0:3b00827bb0b7 120 case TCPIP_MSG_CALLBACK:
AdamGreen 0:3b00827bb0b7 121 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: CALLBACK %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 122 msg->msg.cb.function(msg->msg.cb.ctx);
AdamGreen 0:3b00827bb0b7 123 memp_free(MEMP_TCPIP_MSG_API, msg);
AdamGreen 0:3b00827bb0b7 124 break;
AdamGreen 0:3b00827bb0b7 125
AdamGreen 0:3b00827bb0b7 126 #if LWIP_TCPIP_TIMEOUT
AdamGreen 0:3b00827bb0b7 127 case TCPIP_MSG_TIMEOUT:
AdamGreen 0:3b00827bb0b7 128 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: TIMEOUT %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 129 sys_timeout(msg->msg.tmo.msecs, msg->msg.tmo.h, msg->msg.tmo.arg);
AdamGreen 0:3b00827bb0b7 130 memp_free(MEMP_TCPIP_MSG_API, msg);
AdamGreen 0:3b00827bb0b7 131 break;
AdamGreen 0:3b00827bb0b7 132 case TCPIP_MSG_UNTIMEOUT:
AdamGreen 0:3b00827bb0b7 133 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: UNTIMEOUT %p\n", (void *)msg));
AdamGreen 0:3b00827bb0b7 134 sys_untimeout(msg->msg.tmo.h, msg->msg.tmo.arg);
AdamGreen 0:3b00827bb0b7 135 memp_free(MEMP_TCPIP_MSG_API, msg);
AdamGreen 0:3b00827bb0b7 136 break;
AdamGreen 0:3b00827bb0b7 137 #endif /* LWIP_TCPIP_TIMEOUT */
AdamGreen 0:3b00827bb0b7 138
AdamGreen 0:3b00827bb0b7 139 default:
AdamGreen 0:3b00827bb0b7 140 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: invalid message: %d\n", msg->type));
AdamGreen 0:3b00827bb0b7 141 LWIP_ASSERT("tcpip_thread: invalid message", 0);
AdamGreen 0:3b00827bb0b7 142 break;
AdamGreen 0:3b00827bb0b7 143 }
AdamGreen 0:3b00827bb0b7 144 }
AdamGreen 0:3b00827bb0b7 145 }
AdamGreen 0:3b00827bb0b7 146
AdamGreen 0:3b00827bb0b7 147 /**
AdamGreen 0:3b00827bb0b7 148 * Pass a received packet to tcpip_thread for input processing
AdamGreen 0:3b00827bb0b7 149 *
AdamGreen 0:3b00827bb0b7 150 * @param p the received packet, p->payload pointing to the Ethernet header or
AdamGreen 0:3b00827bb0b7 151 * to an IP header (if inp doesn't have NETIF_FLAG_ETHARP or
AdamGreen 0:3b00827bb0b7 152 * NETIF_FLAG_ETHERNET flags)
AdamGreen 0:3b00827bb0b7 153 * @param inp the network interface on which the packet was received
AdamGreen 0:3b00827bb0b7 154 */
AdamGreen 0:3b00827bb0b7 155 err_t
AdamGreen 0:3b00827bb0b7 156 tcpip_input(struct pbuf *p, struct netif *inp)
AdamGreen 0:3b00827bb0b7 157 {
AdamGreen 0:3b00827bb0b7 158 #if LWIP_TCPIP_CORE_LOCKING_INPUT
AdamGreen 0:3b00827bb0b7 159 err_t ret;
AdamGreen 0:3b00827bb0b7 160 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_input: PACKET %p/%p\n", (void *)p, (void *)inp));
AdamGreen 0:3b00827bb0b7 161 LOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 162 #if LWIP_ETHERNET
AdamGreen 0:3b00827bb0b7 163 if (inp->flags & (NETIF_FLAG_ETHARP | NETIF_FLAG_ETHERNET)) {
AdamGreen 0:3b00827bb0b7 164 ret = ethernet_input(p, inp);
AdamGreen 0:3b00827bb0b7 165 } else
AdamGreen 0:3b00827bb0b7 166 #endif /* LWIP_ETHERNET */
AdamGreen 0:3b00827bb0b7 167 {
AdamGreen 0:3b00827bb0b7 168 ret = ip_input(p, inp);
AdamGreen 0:3b00827bb0b7 169 }
AdamGreen 0:3b00827bb0b7 170 UNLOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 171 return ret;
AdamGreen 0:3b00827bb0b7 172 #else /* LWIP_TCPIP_CORE_LOCKING_INPUT */
AdamGreen 0:3b00827bb0b7 173 struct tcpip_msg *msg;
AdamGreen 0:3b00827bb0b7 174
AdamGreen 0:3b00827bb0b7 175 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 176 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_INPKT);
AdamGreen 0:3b00827bb0b7 177 if (msg == NULL) {
AdamGreen 0:3b00827bb0b7 178 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 179 }
AdamGreen 0:3b00827bb0b7 180
AdamGreen 0:3b00827bb0b7 181 msg->type = TCPIP_MSG_INPKT;
AdamGreen 0:3b00827bb0b7 182 msg->msg.inp.p = p;
AdamGreen 0:3b00827bb0b7 183 msg->msg.inp.netif = inp;
AdamGreen 0:3b00827bb0b7 184 if (sys_mbox_trypost(&mbox, msg) != ERR_OK) {
AdamGreen 0:3b00827bb0b7 185 memp_free(MEMP_TCPIP_MSG_INPKT, msg);
AdamGreen 0:3b00827bb0b7 186 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 187 }
AdamGreen 0:3b00827bb0b7 188 return ERR_OK;
AdamGreen 0:3b00827bb0b7 189 }
AdamGreen 0:3b00827bb0b7 190 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 191 #endif /* LWIP_TCPIP_CORE_LOCKING_INPUT */
AdamGreen 0:3b00827bb0b7 192 }
AdamGreen 0:3b00827bb0b7 193
AdamGreen 0:3b00827bb0b7 194 /**
AdamGreen 0:3b00827bb0b7 195 * Call a specific function in the thread context of
AdamGreen 0:3b00827bb0b7 196 * tcpip_thread for easy access synchronization.
AdamGreen 0:3b00827bb0b7 197 * A function called in that way may access lwIP core code
AdamGreen 0:3b00827bb0b7 198 * without fearing concurrent access.
AdamGreen 0:3b00827bb0b7 199 *
AdamGreen 0:3b00827bb0b7 200 * @param f the function to call
AdamGreen 0:3b00827bb0b7 201 * @param ctx parameter passed to f
AdamGreen 0:3b00827bb0b7 202 * @param block 1 to block until the request is posted, 0 to non-blocking mode
AdamGreen 0:3b00827bb0b7 203 * @return ERR_OK if the function was called, another err_t if not
AdamGreen 0:3b00827bb0b7 204 */
AdamGreen 0:3b00827bb0b7 205 err_t
AdamGreen 0:3b00827bb0b7 206 tcpip_callback_with_block(tcpip_callback_fn function, void *ctx, u8_t block)
AdamGreen 0:3b00827bb0b7 207 {
AdamGreen 0:3b00827bb0b7 208 struct tcpip_msg *msg;
AdamGreen 0:3b00827bb0b7 209
AdamGreen 0:3b00827bb0b7 210 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 211 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
AdamGreen 0:3b00827bb0b7 212 if (msg == NULL) {
AdamGreen 0:3b00827bb0b7 213 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 214 }
AdamGreen 0:3b00827bb0b7 215
AdamGreen 0:3b00827bb0b7 216 msg->type = TCPIP_MSG_CALLBACK;
AdamGreen 0:3b00827bb0b7 217 msg->msg.cb.function = function;
AdamGreen 0:3b00827bb0b7 218 msg->msg.cb.ctx = ctx;
AdamGreen 0:3b00827bb0b7 219 if (block) {
AdamGreen 0:3b00827bb0b7 220 sys_mbox_post(&mbox, msg);
AdamGreen 0:3b00827bb0b7 221 } else {
AdamGreen 0:3b00827bb0b7 222 if (sys_mbox_trypost(&mbox, msg) != ERR_OK) {
AdamGreen 0:3b00827bb0b7 223 memp_free(MEMP_TCPIP_MSG_API, msg);
AdamGreen 0:3b00827bb0b7 224 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 225 }
AdamGreen 0:3b00827bb0b7 226 }
AdamGreen 0:3b00827bb0b7 227 return ERR_OK;
AdamGreen 0:3b00827bb0b7 228 }
AdamGreen 0:3b00827bb0b7 229 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 230 }
AdamGreen 0:3b00827bb0b7 231
AdamGreen 0:3b00827bb0b7 232 #if LWIP_TCPIP_TIMEOUT
AdamGreen 0:3b00827bb0b7 233 /**
AdamGreen 0:3b00827bb0b7 234 * call sys_timeout in tcpip_thread
AdamGreen 0:3b00827bb0b7 235 *
AdamGreen 0:3b00827bb0b7 236 * @param msec time in milliseconds for timeout
AdamGreen 0:3b00827bb0b7 237 * @param h function to be called on timeout
AdamGreen 0:3b00827bb0b7 238 * @param arg argument to pass to timeout function h
AdamGreen 0:3b00827bb0b7 239 * @return ERR_MEM on memory error, ERR_OK otherwise
AdamGreen 0:3b00827bb0b7 240 */
AdamGreen 0:3b00827bb0b7 241 err_t
AdamGreen 0:3b00827bb0b7 242 tcpip_timeout(u32_t msecs, sys_timeout_handler h, void *arg)
AdamGreen 0:3b00827bb0b7 243 {
AdamGreen 0:3b00827bb0b7 244 struct tcpip_msg *msg;
AdamGreen 0:3b00827bb0b7 245
AdamGreen 0:3b00827bb0b7 246 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 247 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
AdamGreen 0:3b00827bb0b7 248 if (msg == NULL) {
AdamGreen 0:3b00827bb0b7 249 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 250 }
AdamGreen 0:3b00827bb0b7 251
AdamGreen 0:3b00827bb0b7 252 msg->type = TCPIP_MSG_TIMEOUT;
AdamGreen 0:3b00827bb0b7 253 msg->msg.tmo.msecs = msecs;
AdamGreen 0:3b00827bb0b7 254 msg->msg.tmo.h = h;
AdamGreen 0:3b00827bb0b7 255 msg->msg.tmo.arg = arg;
AdamGreen 0:3b00827bb0b7 256 sys_mbox_post(&mbox, msg);
AdamGreen 0:3b00827bb0b7 257 return ERR_OK;
AdamGreen 0:3b00827bb0b7 258 }
AdamGreen 0:3b00827bb0b7 259 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 260 }
AdamGreen 0:3b00827bb0b7 261
AdamGreen 0:3b00827bb0b7 262 /**
AdamGreen 0:3b00827bb0b7 263 * call sys_untimeout in tcpip_thread
AdamGreen 0:3b00827bb0b7 264 *
AdamGreen 0:3b00827bb0b7 265 * @param msec time in milliseconds for timeout
AdamGreen 0:3b00827bb0b7 266 * @param h function to be called on timeout
AdamGreen 0:3b00827bb0b7 267 * @param arg argument to pass to timeout function h
AdamGreen 0:3b00827bb0b7 268 * @return ERR_MEM on memory error, ERR_OK otherwise
AdamGreen 0:3b00827bb0b7 269 */
AdamGreen 0:3b00827bb0b7 270 err_t
AdamGreen 0:3b00827bb0b7 271 tcpip_untimeout(sys_timeout_handler h, void *arg)
AdamGreen 0:3b00827bb0b7 272 {
AdamGreen 0:3b00827bb0b7 273 struct tcpip_msg *msg;
AdamGreen 0:3b00827bb0b7 274
AdamGreen 0:3b00827bb0b7 275 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 276 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
AdamGreen 0:3b00827bb0b7 277 if (msg == NULL) {
AdamGreen 0:3b00827bb0b7 278 return ERR_MEM;
AdamGreen 0:3b00827bb0b7 279 }
AdamGreen 0:3b00827bb0b7 280
AdamGreen 0:3b00827bb0b7 281 msg->type = TCPIP_MSG_UNTIMEOUT;
AdamGreen 0:3b00827bb0b7 282 msg->msg.tmo.h = h;
AdamGreen 0:3b00827bb0b7 283 msg->msg.tmo.arg = arg;
AdamGreen 0:3b00827bb0b7 284 sys_mbox_post(&mbox, msg);
AdamGreen 0:3b00827bb0b7 285 return ERR_OK;
AdamGreen 0:3b00827bb0b7 286 }
AdamGreen 0:3b00827bb0b7 287 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 288 }
AdamGreen 0:3b00827bb0b7 289 #endif /* LWIP_TCPIP_TIMEOUT */
AdamGreen 0:3b00827bb0b7 290
AdamGreen 0:3b00827bb0b7 291 #if LWIP_NETCONN
AdamGreen 0:3b00827bb0b7 292 /**
AdamGreen 0:3b00827bb0b7 293 * Call the lower part of a netconn_* function
AdamGreen 0:3b00827bb0b7 294 * This function is then running in the thread context
AdamGreen 0:3b00827bb0b7 295 * of tcpip_thread and has exclusive access to lwIP core code.
AdamGreen 0:3b00827bb0b7 296 *
AdamGreen 0:3b00827bb0b7 297 * @param apimsg a struct containing the function to call and its parameters
AdamGreen 0:3b00827bb0b7 298 * @return ERR_OK if the function was called, another err_t if not
AdamGreen 0:3b00827bb0b7 299 */
AdamGreen 0:3b00827bb0b7 300 err_t
AdamGreen 0:3b00827bb0b7 301 tcpip_apimsg(struct api_msg *apimsg)
AdamGreen 0:3b00827bb0b7 302 {
AdamGreen 0:3b00827bb0b7 303 struct tcpip_msg msg;
AdamGreen 0:3b00827bb0b7 304 #ifdef LWIP_DEBUG
AdamGreen 0:3b00827bb0b7 305 /* catch functions that don't set err */
AdamGreen 0:3b00827bb0b7 306 apimsg->msg.err = ERR_VAL;
AdamGreen 0:3b00827bb0b7 307 #endif
AdamGreen 0:3b00827bb0b7 308
AdamGreen 0:3b00827bb0b7 309 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 310 msg.type = TCPIP_MSG_API;
AdamGreen 0:3b00827bb0b7 311 msg.msg.apimsg = apimsg;
AdamGreen 0:3b00827bb0b7 312 sys_mbox_post(&mbox, &msg);
AdamGreen 0:3b00827bb0b7 313 sys_arch_sem_wait(&apimsg->msg.conn->op_completed, 0);
AdamGreen 0:3b00827bb0b7 314 return apimsg->msg.err;
AdamGreen 0:3b00827bb0b7 315 }
AdamGreen 0:3b00827bb0b7 316 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 317 }
AdamGreen 0:3b00827bb0b7 318
AdamGreen 0:3b00827bb0b7 319 #if LWIP_TCPIP_CORE_LOCKING
AdamGreen 0:3b00827bb0b7 320 /**
AdamGreen 0:3b00827bb0b7 321 * Call the lower part of a netconn_* function
AdamGreen 0:3b00827bb0b7 322 * This function has exclusive access to lwIP core code by locking it
AdamGreen 0:3b00827bb0b7 323 * before the function is called.
AdamGreen 0:3b00827bb0b7 324 *
AdamGreen 0:3b00827bb0b7 325 * @param apimsg a struct containing the function to call and its parameters
AdamGreen 0:3b00827bb0b7 326 * @return ERR_OK (only for compatibility fo tcpip_apimsg())
AdamGreen 0:3b00827bb0b7 327 */
AdamGreen 0:3b00827bb0b7 328 err_t
AdamGreen 0:3b00827bb0b7 329 tcpip_apimsg_lock(struct api_msg *apimsg)
AdamGreen 0:3b00827bb0b7 330 {
AdamGreen 0:3b00827bb0b7 331 #ifdef LWIP_DEBUG
AdamGreen 0:3b00827bb0b7 332 /* catch functions that don't set err */
AdamGreen 0:3b00827bb0b7 333 apimsg->msg.err = ERR_VAL;
AdamGreen 0:3b00827bb0b7 334 #endif
AdamGreen 0:3b00827bb0b7 335
AdamGreen 0:3b00827bb0b7 336 LOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 337 apimsg->function(&(apimsg->msg));
AdamGreen 0:3b00827bb0b7 338 UNLOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 339 return apimsg->msg.err;
AdamGreen 0:3b00827bb0b7 340
AdamGreen 0:3b00827bb0b7 341 }
AdamGreen 0:3b00827bb0b7 342 #endif /* LWIP_TCPIP_CORE_LOCKING */
AdamGreen 0:3b00827bb0b7 343 #endif /* LWIP_NETCONN */
AdamGreen 0:3b00827bb0b7 344
AdamGreen 0:3b00827bb0b7 345 #if LWIP_NETIF_API
AdamGreen 0:3b00827bb0b7 346 #if !LWIP_TCPIP_CORE_LOCKING
AdamGreen 0:3b00827bb0b7 347 /**
AdamGreen 0:3b00827bb0b7 348 * Much like tcpip_apimsg, but calls the lower part of a netifapi_*
AdamGreen 0:3b00827bb0b7 349 * function.
AdamGreen 0:3b00827bb0b7 350 *
AdamGreen 0:3b00827bb0b7 351 * @param netifapimsg a struct containing the function to call and its parameters
AdamGreen 0:3b00827bb0b7 352 * @return error code given back by the function that was called
AdamGreen 0:3b00827bb0b7 353 */
AdamGreen 0:3b00827bb0b7 354 err_t
AdamGreen 0:3b00827bb0b7 355 tcpip_netifapi(struct netifapi_msg* netifapimsg)
AdamGreen 0:3b00827bb0b7 356 {
AdamGreen 0:3b00827bb0b7 357 struct tcpip_msg msg;
AdamGreen 0:3b00827bb0b7 358
AdamGreen 0:3b00827bb0b7 359 if (sys_mbox_valid(&mbox)) {
AdamGreen 0:3b00827bb0b7 360 err_t err = sys_sem_new(&netifapimsg->msg.sem, 0);
AdamGreen 0:3b00827bb0b7 361 if (err != ERR_OK) {
AdamGreen 0:3b00827bb0b7 362 netifapimsg->msg.err = err;
AdamGreen 0:3b00827bb0b7 363 return err;
AdamGreen 0:3b00827bb0b7 364 }
AdamGreen 0:3b00827bb0b7 365
AdamGreen 0:3b00827bb0b7 366 msg.type = TCPIP_MSG_NETIFAPI;
AdamGreen 0:3b00827bb0b7 367 msg.msg.netifapimsg = netifapimsg;
AdamGreen 0:3b00827bb0b7 368 sys_mbox_post(&mbox, &msg);
AdamGreen 0:3b00827bb0b7 369 sys_sem_wait(&netifapimsg->msg.sem);
AdamGreen 0:3b00827bb0b7 370 sys_sem_free(&netifapimsg->msg.sem);
AdamGreen 0:3b00827bb0b7 371 return netifapimsg->msg.err;
AdamGreen 0:3b00827bb0b7 372 }
AdamGreen 0:3b00827bb0b7 373 return ERR_VAL;
AdamGreen 0:3b00827bb0b7 374 }
AdamGreen 0:3b00827bb0b7 375 #else /* !LWIP_TCPIP_CORE_LOCKING */
AdamGreen 0:3b00827bb0b7 376 /**
AdamGreen 0:3b00827bb0b7 377 * Call the lower part of a netifapi_* function
AdamGreen 0:3b00827bb0b7 378 * This function has exclusive access to lwIP core code by locking it
AdamGreen 0:3b00827bb0b7 379 * before the function is called.
AdamGreen 0:3b00827bb0b7 380 *
AdamGreen 0:3b00827bb0b7 381 * @param netifapimsg a struct containing the function to call and its parameters
AdamGreen 0:3b00827bb0b7 382 * @return ERR_OK (only for compatibility fo tcpip_netifapi())
AdamGreen 0:3b00827bb0b7 383 */
AdamGreen 0:3b00827bb0b7 384 err_t
AdamGreen 0:3b00827bb0b7 385 tcpip_netifapi_lock(struct netifapi_msg* netifapimsg)
AdamGreen 0:3b00827bb0b7 386 {
AdamGreen 0:3b00827bb0b7 387 LOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 388 netifapimsg->function(&(netifapimsg->msg));
AdamGreen 0:3b00827bb0b7 389 UNLOCK_TCPIP_CORE();
AdamGreen 0:3b00827bb0b7 390 return netifapimsg->msg.err;
AdamGreen 0:3b00827bb0b7 391 }
AdamGreen 0:3b00827bb0b7 392 #endif /* !LWIP_TCPIP_CORE_LOCKING */
AdamGreen 0:3b00827bb0b7 393 #endif /* LWIP_NETIF_API */
AdamGreen 0:3b00827bb0b7 394
AdamGreen 0:3b00827bb0b7 395 /**
AdamGreen 0:3b00827bb0b7 396 * Initialize this module:
AdamGreen 0:3b00827bb0b7 397 * - initialize all sub modules
AdamGreen 0:3b00827bb0b7 398 * - start the tcpip_thread
AdamGreen 0:3b00827bb0b7 399 *
AdamGreen 0:3b00827bb0b7 400 * @param initfunc a function to call when tcpip_thread is running and finished initializing
AdamGreen 0:3b00827bb0b7 401 * @param arg argument to pass to initfunc
AdamGreen 0:3b00827bb0b7 402 */
AdamGreen 0:3b00827bb0b7 403 void
AdamGreen 0:3b00827bb0b7 404 tcpip_init(tcpip_init_done_fn initfunc, void *arg)
AdamGreen 0:3b00827bb0b7 405 {
AdamGreen 0:3b00827bb0b7 406 lwip_init();
AdamGreen 0:3b00827bb0b7 407
AdamGreen 0:3b00827bb0b7 408 tcpip_init_done = initfunc;
AdamGreen 0:3b00827bb0b7 409 tcpip_init_done_arg = arg;
AdamGreen 0:3b00827bb0b7 410 if(sys_mbox_new(&mbox, TCPIP_MBOX_SIZE) != ERR_OK) {
AdamGreen 0:3b00827bb0b7 411 LWIP_ASSERT("failed to create tcpip_thread mbox", 0);
AdamGreen 0:3b00827bb0b7 412 }
AdamGreen 0:3b00827bb0b7 413 #if LWIP_TCPIP_CORE_LOCKING
AdamGreen 0:3b00827bb0b7 414 if(sys_mutex_new(&lock_tcpip_core) != ERR_OK) {
AdamGreen 0:3b00827bb0b7 415 LWIP_ASSERT("failed to create lock_tcpip_core", 0);
AdamGreen 0:3b00827bb0b7 416 }
AdamGreen 0:3b00827bb0b7 417 #endif /* LWIP_TCPIP_CORE_LOCKING */
AdamGreen 0:3b00827bb0b7 418
AdamGreen 0:3b00827bb0b7 419 sys_thread_new(TCPIP_THREAD_NAME, tcpip_thread, NULL, TCPIP_THREAD_STACKSIZE, TCPIP_THREAD_PRIO);
AdamGreen 0:3b00827bb0b7 420 }
AdamGreen 0:3b00827bb0b7 421
AdamGreen 0:3b00827bb0b7 422 /**
AdamGreen 0:3b00827bb0b7 423 * Simple callback function used with tcpip_callback to free a pbuf
AdamGreen 0:3b00827bb0b7 424 * (pbuf_free has a wrong signature for tcpip_callback)
AdamGreen 0:3b00827bb0b7 425 *
AdamGreen 0:3b00827bb0b7 426 * @param p The pbuf (chain) to be dereferenced.
AdamGreen 0:3b00827bb0b7 427 */
AdamGreen 0:3b00827bb0b7 428 static void
AdamGreen 0:3b00827bb0b7 429 pbuf_free_int(void *p)
AdamGreen 0:3b00827bb0b7 430 {
AdamGreen 0:3b00827bb0b7 431 struct pbuf *q = (struct pbuf *)p;
AdamGreen 0:3b00827bb0b7 432 pbuf_free(q);
AdamGreen 0:3b00827bb0b7 433 }
AdamGreen 0:3b00827bb0b7 434
AdamGreen 0:3b00827bb0b7 435 /**
AdamGreen 0:3b00827bb0b7 436 * A simple wrapper function that allows you to free a pbuf from interrupt context.
AdamGreen 0:3b00827bb0b7 437 *
AdamGreen 0:3b00827bb0b7 438 * @param p The pbuf (chain) to be dereferenced.
AdamGreen 0:3b00827bb0b7 439 * @return ERR_OK if callback could be enqueued, an err_t if not
AdamGreen 0:3b00827bb0b7 440 */
AdamGreen 0:3b00827bb0b7 441 err_t
AdamGreen 0:3b00827bb0b7 442 pbuf_free_callback(struct pbuf *p)
AdamGreen 0:3b00827bb0b7 443 {
AdamGreen 0:3b00827bb0b7 444 return tcpip_callback_with_block(pbuf_free_int, p, 0);
AdamGreen 0:3b00827bb0b7 445 }
AdamGreen 0:3b00827bb0b7 446
AdamGreen 0:3b00827bb0b7 447 /**
AdamGreen 0:3b00827bb0b7 448 * A simple wrapper function that allows you to free heap memory from
AdamGreen 0:3b00827bb0b7 449 * interrupt context.
AdamGreen 0:3b00827bb0b7 450 *
AdamGreen 0:3b00827bb0b7 451 * @param m the heap memory to free
AdamGreen 0:3b00827bb0b7 452 * @return ERR_OK if callback could be enqueued, an err_t if not
AdamGreen 0:3b00827bb0b7 453 */
AdamGreen 0:3b00827bb0b7 454 err_t
AdamGreen 0:3b00827bb0b7 455 mem_free_callback(void *m)
AdamGreen 0:3b00827bb0b7 456 {
AdamGreen 0:3b00827bb0b7 457 return tcpip_callback_with_block(mem_free, m, 0);
AdamGreen 0:3b00827bb0b7 458 }
AdamGreen 0:3b00827bb0b7 459
AdamGreen 0:3b00827bb0b7 460 #endif /* !NO_SYS */