/**************************************************************************** * net/uip/uip_callback.c * * Copyright (C) 2008 Gregory Nutt. All rights reserved. * Author: Gregory Nutt * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * 3. Neither the name NuttX nor the names of its contributors may be * used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. * ****************************************************************************/ /**************************************************************************** * Included Files ****************************************************************************/ #include #if defined(CONFIG_NET) #include #include #include #include #include #include #include "uip_internal.h" /**************************************************************************** * Private Data ****************************************************************************/ static struct uip_callback_s g_cbprealloc[CONFIG_NET_NACTIVESOCKETS]; static FAR struct uip_callback_s *g_cbfreelist = NULL; /**************************************************************************** * Private Functions ****************************************************************************/ /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Function: uip_callbackinit * * Description: * Configure the pre-allocated callaback structures into a free list. * This is called internally as part of uIP initialization and should not * be accessed from the application or socket layer. * * Assumptions: * This function is called with interrupts disabled. * ****************************************************************************/ void uip_callbackinit(void) { int i; for (i = 0; i < CONFIG_NET_NACTIVESOCKETS; i++) { g_cbprealloc[i].flink = g_cbfreelist; g_cbfreelist = &g_cbprealloc[i]; } } /**************************************************************************** * Function: uip_callbackalloc * * Description: * Allocate a callback container from the free list. * This is called internally as part of uIP initialization and should not * be accessed from the application or socket layer. * * Assumptions: * This function is called with interrupts disabled. * ****************************************************************************/ FAR struct uip_callback_s *uip_callbackalloc(FAR struct uip_callback_s **list) { struct uip_callback_s *ret; irqstate_t save; /* Check the head of the free list */ save = irqsave(); ret = g_cbfreelist; if (ret) { /* Remove the next instance from the head of the free list */ g_cbfreelist = ret->flink; memset(ret, 0, sizeof(struct uip_callback_s)); /* Add the newly allocated instance to the head of the specified list */ if (list) { ret->flink = *list; *list = ret; } else { ret->flink = NULL; } } #ifdef CONFIG_DEBUG else { dbg("Failed to allocate callback\n"); } #endif irqrestore(save); return ret; } /**************************************************************************** * Function: uip_callbackfree * * Description: * Return a callback container to the free list. * This is called internally as part of uIP initialization and should not * be accessed from the application or socket layer. * * Assumptions: * This function is called with interrupts disabled. * ****************************************************************************/ void uip_callbackfree(FAR struct uip_callback_s *cb, FAR struct uip_callback_s **list) { FAR struct uip_callback_s *prev; FAR struct uip_callback_s *curr; irqstate_t save; if (cb) { /* Find the callback structure in the connection's list */ save = irqsave(); if (list) { for (prev = NULL, curr = *list; curr && curr != cb; prev = curr, curr = curr->flink); /* Remove the structure from the connection's list */ if (curr) { if (prev) { prev->flink = cb->flink; } else { *list = cb->flink; } } } /* Put the structure into the free list */ cb->flink = g_cbfreelist; g_cbfreelist = cb; irqrestore(save); } } /**************************************************************************** * Function: uip_callbackexecute * * Description: * Execute a list of callbacks. * This is called internally as part of uIP initialization and should not * be accessed from the application or socket layer. * * Assumptions: * This function is called with interrupts disabled. * ****************************************************************************/ uint16 uip_callbackexecute(FAR struct uip_driver_s *dev, void *pvconn, uint16 flags, FAR struct uip_callback_s *list) { FAR struct uip_callback_s *next; irqstate_t save; /* Loop for each callback in the list and while there are still events * set in the flags set. */ save = irqsave(); while (list && flags) { /* Save the pointer to the next callback in the lists. This is done * because the callback action might delete the entry pointed to by * list. */ next = list->flink; /* Check if this callback handles any of the events in the flag set */ if (list->event && (flags & list->flags) != 0) { /* Yes.. perform the callback. Actions perform by the callback * may delete the current list entry or add a new list entry to * beginning of the list (which will be ignored on this pass) */ nvdbg("Call event=%p with flags=%04x\n", list->event, flags); flags = list->event(dev, pvconn, list->private, flags); } /* Set up for the next time through the loop */ list = next; } irqrestore(save); return flags; } #endif /* CONFIG_NET */