Example program with HTTPServer and sensor data streaming over TCPSockets, using Donatien Garnier's Net APIs and services code on top of LWIP. Files StreamServer.h and .cpp encapsulate streaming over TCPSockets. Broadcast is done by sendToAll(), and all incoming data is echoed back to the client. Echo code can be replaced with some remote control of the streaming interface. See main() that shows how to periodically send some data to all subscribed clients. To subscribe, a client should open a socket at <mbed_ip> port 123. I used few lines in TCL code to set up a quick sink for the data. HTTP files are served on port 80 concurrently to the streaming.

Dependencies:   mbed

Committer:
iva2k
Date:
Mon Jun 14 03:24:33 2010 +0000
Revision:
1:3ee499525aa5
Parent:
0:e614f7875b60

        

Who changed what in which revision?

UserRevisionLine numberNew contents of line
iva2k 0:e614f7875b60 1 /**
iva2k 0:e614f7875b60 2 * @file
iva2k 0:e614f7875b60 3 * Statistics module
iva2k 0:e614f7875b60 4 *
iva2k 0:e614f7875b60 5 */
iva2k 0:e614f7875b60 6
iva2k 0:e614f7875b60 7 /*
iva2k 0:e614f7875b60 8 * Copyright (c) 2001-2004 Swedish Institute of Computer Science.
iva2k 0:e614f7875b60 9 * All rights reserved.
iva2k 0:e614f7875b60 10 *
iva2k 0:e614f7875b60 11 * Redistribution and use in source and binary forms, with or without modification,
iva2k 0:e614f7875b60 12 * are permitted provided that the following conditions are met:
iva2k 0:e614f7875b60 13 *
iva2k 0:e614f7875b60 14 * 1. Redistributions of source code must retain the above copyright notice,
iva2k 0:e614f7875b60 15 * this list of conditions and the following disclaimer.
iva2k 0:e614f7875b60 16 * 2. Redistributions in binary form must reproduce the above copyright notice,
iva2k 0:e614f7875b60 17 * this list of conditions and the following disclaimer in the documentation
iva2k 0:e614f7875b60 18 * and/or other materials provided with the distribution.
iva2k 0:e614f7875b60 19 * 3. The name of the author may not be used to endorse or promote products
iva2k 0:e614f7875b60 20 * derived from this software without specific prior written permission.
iva2k 0:e614f7875b60 21 *
iva2k 0:e614f7875b60 22 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
iva2k 0:e614f7875b60 23 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
iva2k 0:e614f7875b60 24 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
iva2k 0:e614f7875b60 25 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
iva2k 0:e614f7875b60 26 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
iva2k 0:e614f7875b60 27 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
iva2k 0:e614f7875b60 28 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
iva2k 0:e614f7875b60 29 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
iva2k 0:e614f7875b60 30 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
iva2k 0:e614f7875b60 31 * OF SUCH DAMAGE.
iva2k 0:e614f7875b60 32 *
iva2k 0:e614f7875b60 33 * This file is part of the lwIP TCP/IP stack.
iva2k 0:e614f7875b60 34 *
iva2k 0:e614f7875b60 35 * Author: Adam Dunkels <adam@sics.se>
iva2k 0:e614f7875b60 36 *
iva2k 0:e614f7875b60 37 */
iva2k 0:e614f7875b60 38
iva2k 0:e614f7875b60 39 #include "lwip/opt.h"
iva2k 0:e614f7875b60 40
iva2k 0:e614f7875b60 41 #if LWIP_STATS /* don't build if not configured for use in lwipopts.h */
iva2k 0:e614f7875b60 42
iva2k 0:e614f7875b60 43 #include "lwip/def.h"
iva2k 0:e614f7875b60 44 #include "lwip/stats.h"
iva2k 0:e614f7875b60 45 #include "lwip/mem.h"
iva2k 0:e614f7875b60 46
iva2k 0:e614f7875b60 47 #include <string.h>
iva2k 0:e614f7875b60 48
iva2k 0:e614f7875b60 49 struct stats_ lwip_stats;
iva2k 0:e614f7875b60 50
iva2k 0:e614f7875b60 51 void stats_init()
iva2k 0:e614f7875b60 52 {
iva2k 0:e614f7875b60 53 #ifdef LWIP_DEBUG
iva2k 0:e614f7875b60 54 #if MEMP_STATS
iva2k 0:e614f7875b60 55 char * memp_names[] = {
iva2k 0:e614f7875b60 56 #define LWIP_MEMPOOL(name,num,size,desc) desc,
iva2k 0:e614f7875b60 57 #include "lwip/memp_std.h"
iva2k 0:e614f7875b60 58 };
iva2k 0:e614f7875b60 59 int i;
iva2k 0:e614f7875b60 60 for (i = 0; i < MEMP_MAX; i++) {
iva2k 0:e614f7875b60 61 lwip_stats.memp[i].name = memp_names[i];
iva2k 0:e614f7875b60 62 }
iva2k 0:e614f7875b60 63 #endif /* MEMP_STATS */
iva2k 0:e614f7875b60 64 #if MEM_STATS
iva2k 0:e614f7875b60 65 lwip_stats.mem.name = "MEM";
iva2k 0:e614f7875b60 66 #endif /* MEM_STATS */
iva2k 0:e614f7875b60 67 #endif /* LWIP_DEBUG */
iva2k 0:e614f7875b60 68 }
iva2k 0:e614f7875b60 69
iva2k 0:e614f7875b60 70 #if LWIP_STATS_DISPLAY
iva2k 0:e614f7875b60 71 void
iva2k 0:e614f7875b60 72 stats_display_proto(struct stats_proto *proto, char *name)
iva2k 0:e614f7875b60 73 {
iva2k 0:e614f7875b60 74 LWIP_PLATFORM_DIAG(("\n%s\n\t", name));
iva2k 0:e614f7875b60 75 LWIP_PLATFORM_DIAG(("xmit: %"STAT_COUNTER_F"\n\t", proto->xmit));
iva2k 0:e614f7875b60 76 LWIP_PLATFORM_DIAG(("recv: %"STAT_COUNTER_F"\n\t", proto->recv));
iva2k 0:e614f7875b60 77 LWIP_PLATFORM_DIAG(("fw: %"STAT_COUNTER_F"\n\t", proto->fw));
iva2k 0:e614f7875b60 78 LWIP_PLATFORM_DIAG(("drop: %"STAT_COUNTER_F"\n\t", proto->drop));
iva2k 0:e614f7875b60 79 LWIP_PLATFORM_DIAG(("chkerr: %"STAT_COUNTER_F"\n\t", proto->chkerr));
iva2k 0:e614f7875b60 80 LWIP_PLATFORM_DIAG(("lenerr: %"STAT_COUNTER_F"\n\t", proto->lenerr));
iva2k 0:e614f7875b60 81 LWIP_PLATFORM_DIAG(("memerr: %"STAT_COUNTER_F"\n\t", proto->memerr));
iva2k 0:e614f7875b60 82 LWIP_PLATFORM_DIAG(("rterr: %"STAT_COUNTER_F"\n\t", proto->rterr));
iva2k 0:e614f7875b60 83 LWIP_PLATFORM_DIAG(("proterr: %"STAT_COUNTER_F"\n\t", proto->proterr));
iva2k 0:e614f7875b60 84 LWIP_PLATFORM_DIAG(("opterr: %"STAT_COUNTER_F"\n\t", proto->opterr));
iva2k 0:e614f7875b60 85 LWIP_PLATFORM_DIAG(("err: %"STAT_COUNTER_F"\n\t", proto->err));
iva2k 0:e614f7875b60 86 LWIP_PLATFORM_DIAG(("cachehit: %"STAT_COUNTER_F"\n", proto->cachehit));
iva2k 0:e614f7875b60 87 }
iva2k 0:e614f7875b60 88
iva2k 0:e614f7875b60 89 #if IGMP_STATS
iva2k 0:e614f7875b60 90 void
iva2k 0:e614f7875b60 91 stats_display_igmp(struct stats_igmp *igmp)
iva2k 0:e614f7875b60 92 {
iva2k 0:e614f7875b60 93 LWIP_PLATFORM_DIAG(("\nIGMP\n\t"));
iva2k 0:e614f7875b60 94 LWIP_PLATFORM_DIAG(("xmit: %"STAT_COUNTER_F"\n\t", igmp->xmit));
iva2k 0:e614f7875b60 95 LWIP_PLATFORM_DIAG(("recv: %"STAT_COUNTER_F"\n\t", igmp->recv));
iva2k 0:e614f7875b60 96 LWIP_PLATFORM_DIAG(("drop: %"STAT_COUNTER_F"\n\t", igmp->drop));
iva2k 0:e614f7875b60 97 LWIP_PLATFORM_DIAG(("chkerr: %"STAT_COUNTER_F"\n\t", igmp->chkerr));
iva2k 0:e614f7875b60 98 LWIP_PLATFORM_DIAG(("lenerr: %"STAT_COUNTER_F"\n\t", igmp->lenerr));
iva2k 0:e614f7875b60 99 LWIP_PLATFORM_DIAG(("memerr: %"STAT_COUNTER_F"\n\t", igmp->memerr));
iva2k 0:e614f7875b60 100 LWIP_PLATFORM_DIAG(("proterr: %"STAT_COUNTER_F"\n\t", igmp->proterr));
iva2k 0:e614f7875b60 101 LWIP_PLATFORM_DIAG(("rx_v1: %"STAT_COUNTER_F"\n\t", igmp->rx_v1));
iva2k 0:e614f7875b60 102 LWIP_PLATFORM_DIAG(("rx_group: %"STAT_COUNTER_F"\n", igmp->rx_group));
iva2k 0:e614f7875b60 103 LWIP_PLATFORM_DIAG(("rx_general: %"STAT_COUNTER_F"\n", igmp->rx_general));
iva2k 0:e614f7875b60 104 LWIP_PLATFORM_DIAG(("rx_report: %"STAT_COUNTER_F"\n\t", igmp->rx_report));
iva2k 0:e614f7875b60 105 LWIP_PLATFORM_DIAG(("tx_join: %"STAT_COUNTER_F"\n\t", igmp->tx_join));
iva2k 0:e614f7875b60 106 LWIP_PLATFORM_DIAG(("tx_leave: %"STAT_COUNTER_F"\n\t", igmp->tx_leave));
iva2k 0:e614f7875b60 107 LWIP_PLATFORM_DIAG(("tx_report: %"STAT_COUNTER_F"\n\t", igmp->tx_report));
iva2k 0:e614f7875b60 108 }
iva2k 0:e614f7875b60 109 #endif /* IGMP_STATS */
iva2k 0:e614f7875b60 110
iva2k 0:e614f7875b60 111 #if MEM_STATS || MEMP_STATS
iva2k 0:e614f7875b60 112 void
iva2k 0:e614f7875b60 113 stats_display_mem(struct stats_mem *mem, char *name)
iva2k 0:e614f7875b60 114 {
iva2k 0:e614f7875b60 115 LWIP_PLATFORM_DIAG(("\nMEM %s\n\t", name));
iva2k 0:e614f7875b60 116 LWIP_PLATFORM_DIAG(("avail: %"U32_F"\n\t", (u32_t)mem->avail));
iva2k 0:e614f7875b60 117 LWIP_PLATFORM_DIAG(("used: %"U32_F"\n\t", (u32_t)mem->used));
iva2k 0:e614f7875b60 118 LWIP_PLATFORM_DIAG(("max: %"U32_F"\n\t", (u32_t)mem->max));
iva2k 0:e614f7875b60 119 LWIP_PLATFORM_DIAG(("err: %"U32_F"\n", (u32_t)mem->err));
iva2k 0:e614f7875b60 120 }
iva2k 0:e614f7875b60 121
iva2k 0:e614f7875b60 122 #if MEMP_STATS
iva2k 0:e614f7875b60 123 void
iva2k 0:e614f7875b60 124 stats_display_memp(struct stats_mem *mem, int index)
iva2k 0:e614f7875b60 125 {
iva2k 0:e614f7875b60 126 char * memp_names[] = {
iva2k 0:e614f7875b60 127 #define LWIP_MEMPOOL(name,num,size,desc) desc,
iva2k 0:e614f7875b60 128 #include "lwip/memp_std.h"
iva2k 0:e614f7875b60 129 };
iva2k 0:e614f7875b60 130 if(index < MEMP_MAX) {
iva2k 0:e614f7875b60 131 stats_display_mem(mem, memp_names[index]);
iva2k 0:e614f7875b60 132 }
iva2k 0:e614f7875b60 133 }
iva2k 0:e614f7875b60 134 #endif /* MEMP_STATS */
iva2k 0:e614f7875b60 135 #endif /* MEM_STATS || MEMP_STATS */
iva2k 0:e614f7875b60 136
iva2k 0:e614f7875b60 137 #if SYS_STATS
iva2k 0:e614f7875b60 138 void
iva2k 0:e614f7875b60 139 stats_display_sys(struct stats_sys *sys)
iva2k 0:e614f7875b60 140 {
iva2k 0:e614f7875b60 141 LWIP_PLATFORM_DIAG(("\nSYS\n\t"));
iva2k 0:e614f7875b60 142 LWIP_PLATFORM_DIAG(("sem.used: %"U32_F"\n\t", (u32_t)sys->sem.used));
iva2k 0:e614f7875b60 143 LWIP_PLATFORM_DIAG(("sem.max: %"U32_F"\n\t", (u32_t)sys->sem.max));
iva2k 0:e614f7875b60 144 LWIP_PLATFORM_DIAG(("sem.err: %"U32_F"\n\t", (u32_t)sys->sem.err));
iva2k 0:e614f7875b60 145 LWIP_PLATFORM_DIAG(("mutex.used: %"U32_F"\n\t", (u32_t)sys->mutex.used));
iva2k 0:e614f7875b60 146 LWIP_PLATFORM_DIAG(("mutex.max: %"U32_F"\n\t", (u32_t)sys->mutex.max));
iva2k 0:e614f7875b60 147 LWIP_PLATFORM_DIAG(("mutex.err: %"U32_F"\n\t", (u32_t)sys->mutex.err));
iva2k 0:e614f7875b60 148 LWIP_PLATFORM_DIAG(("mbox.used: %"U32_F"\n\t", (u32_t)sys->mbox.used));
iva2k 0:e614f7875b60 149 LWIP_PLATFORM_DIAG(("mbox.max: %"U32_F"\n\t", (u32_t)sys->mbox.max));
iva2k 0:e614f7875b60 150 LWIP_PLATFORM_DIAG(("mbox.err: %"U32_F"\n\t", (u32_t)sys->mbox.err));
iva2k 0:e614f7875b60 151 }
iva2k 0:e614f7875b60 152 #endif /* SYS_STATS */
iva2k 0:e614f7875b60 153
iva2k 0:e614f7875b60 154 void
iva2k 0:e614f7875b60 155 stats_display(void)
iva2k 0:e614f7875b60 156 {
iva2k 0:e614f7875b60 157 s16_t i;
iva2k 0:e614f7875b60 158
iva2k 0:e614f7875b60 159 LINK_STATS_DISPLAY();
iva2k 0:e614f7875b60 160 ETHARP_STATS_DISPLAY();
iva2k 0:e614f7875b60 161 IPFRAG_STATS_DISPLAY();
iva2k 0:e614f7875b60 162 IP_STATS_DISPLAY();
iva2k 0:e614f7875b60 163 IGMP_STATS_DISPLAY();
iva2k 0:e614f7875b60 164 ICMP_STATS_DISPLAY();
iva2k 0:e614f7875b60 165 UDP_STATS_DISPLAY();
iva2k 0:e614f7875b60 166 TCP_STATS_DISPLAY();
iva2k 0:e614f7875b60 167 MEM_STATS_DISPLAY();
iva2k 0:e614f7875b60 168 for (i = 0; i < MEMP_MAX; i++) {
iva2k 0:e614f7875b60 169 MEMP_STATS_DISPLAY(i);
iva2k 0:e614f7875b60 170 }
iva2k 0:e614f7875b60 171 SYS_STATS_DISPLAY();
iva2k 0:e614f7875b60 172 }
iva2k 0:e614f7875b60 173 #endif /* LWIP_STATS_DISPLAY */
iva2k 0:e614f7875b60 174
iva2k 0:e614f7875b60 175 #endif /* LWIP_STATS */
iva2k 0:e614f7875b60 176