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 /*
iva2k 0:e614f7875b60 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
iva2k 0:e614f7875b60 4
iva2k 0:e614f7875b60 5 Permission is hereby granted, free of charge, to any person obtaining a copy
iva2k 0:e614f7875b60 6 of this software and associated documentation files (the "Software"), to deal
iva2k 0:e614f7875b60 7 in the Software without restriction, including without limitation the rights
iva2k 0:e614f7875b60 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
iva2k 0:e614f7875b60 9 copies of the Software, and to permit persons to whom the Software is
iva2k 0:e614f7875b60 10 furnished to do so, subject to the following conditions:
iva2k 0:e614f7875b60 11
iva2k 0:e614f7875b60 12 The above copyright notice and this permission notice shall be included in
iva2k 0:e614f7875b60 13 all copies or substantial portions of the Software.
iva2k 0:e614f7875b60 14
iva2k 0:e614f7875b60 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
iva2k 0:e614f7875b60 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
iva2k 0:e614f7875b60 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
iva2k 0:e614f7875b60 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
iva2k 0:e614f7875b60 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
iva2k 0:e614f7875b60 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
iva2k 0:e614f7875b60 21 THE SOFTWARE.
iva2k 0:e614f7875b60 22 */
iva2k 0:e614f7875b60 23
iva2k 0:e614f7875b60 24 #ifndef USB_SERIAL_H
iva2k 0:e614f7875b60 25 #define USB_SERIAL_H
iva2k 0:e614f7875b60 26
iva2k 0:e614f7875b60 27 //DG 2010
iva2k 0:e614f7875b60 28 //Essentially a clone of Serial if
iva2k 0:e614f7875b60 29 #include "Stream.h"
iva2k 0:e614f7875b60 30 #include "mbed.h"
iva2k 0:e614f7875b60 31
iva2k 0:e614f7875b60 32 namespace mbed {
iva2k 0:e614f7875b60 33
iva2k 0:e614f7875b60 34 class UsbSerial : public Stream {
iva2k 0:e614f7875b60 35
iva2k 0:e614f7875b60 36 public:
iva2k 0:e614f7875b60 37
iva2k 0:e614f7875b60 38 UsbSerial(int usbDev, int usbIf, const char *name = NULL);
iva2k 0:e614f7875b60 39 virtual ~UsbSerial();
iva2k 0:e614f7875b60 40 //Apart from the ctor/dtor, exactly the same protos as Serial
iva2k 0:e614f7875b60 41
iva2k 0:e614f7875b60 42
iva2k 0:e614f7875b60 43 void baud(int baudrate);
iva2k 0:e614f7875b60 44
iva2k 0:e614f7875b60 45 enum Parity {
iva2k 0:e614f7875b60 46 None = 0,
iva2k 0:e614f7875b60 47 Odd = 1,
iva2k 0:e614f7875b60 48 Even = 2,
iva2k 0:e614f7875b60 49 Forced1 = 3,
iva2k 0:e614f7875b60 50 Forced0 = 4
iva2k 0:e614f7875b60 51 };
iva2k 0:e614f7875b60 52
iva2k 0:e614f7875b60 53 void format(int bits, int parity, int stop);
iva2k 0:e614f7875b60 54
iva2k 0:e614f7875b60 55
iva2k 0:e614f7875b60 56 #if 0 // Inhereted from Stream, for documentation only
iva2k 0:e614f7875b60 57
iva2k 0:e614f7875b60 58 /* Function: putc
iva2k 0:e614f7875b60 59 * Write a character
iva2k 0:e614f7875b60 60 *
iva2k 0:e614f7875b60 61 * Variables:
iva2k 0:e614f7875b60 62 * c - The character to write to the serial port
iva2k 0:e614f7875b60 63 */
iva2k 0:e614f7875b60 64 int putc(int c);
iva2k 0:e614f7875b60 65
iva2k 0:e614f7875b60 66 /* Function: getc
iva2k 0:e614f7875b60 67 * Read a character
iva2k 0:e614f7875b60 68 *
iva2k 0:e614f7875b60 69 * Variables:
iva2k 0:e614f7875b60 70 * returns - The character read from the serial port
iva2k 0:e614f7875b60 71 */
iva2k 0:e614f7875b60 72 int getc();
iva2k 0:e614f7875b60 73
iva2k 0:e614f7875b60 74 /* Function: printf
iva2k 0:e614f7875b60 75 * Write a formated string
iva2k 0:e614f7875b60 76 *
iva2k 0:e614f7875b60 77 * Variables:
iva2k 0:e614f7875b60 78 * format - A printf-style format string, followed by the
iva2k 0:e614f7875b60 79 * variables to use in formating the string.
iva2k 0:e614f7875b60 80 */
iva2k 0:e614f7875b60 81 int printf(const char* format, ...);
iva2k 0:e614f7875b60 82
iva2k 0:e614f7875b60 83 /* Function: scanf
iva2k 0:e614f7875b60 84 * Read a formated string
iva2k 0:e614f7875b60 85 *
iva2k 0:e614f7875b60 86 * Variables:
iva2k 0:e614f7875b60 87 * format - A scanf-style format string,
iva2k 0:e614f7875b60 88 * followed by the pointers to variables to store the results.
iva2k 0:e614f7875b60 89 */
iva2k 0:e614f7875b60 90 int scanf(const char* format, ...);
iva2k 0:e614f7875b60 91
iva2k 0:e614f7875b60 92 #endif
iva2k 0:e614f7875b60 93
iva2k 0:e614f7875b60 94 /* Function: readable
iva2k 0:e614f7875b60 95 * Determine if there is a character available to read
iva2k 0:e614f7875b60 96 *
iva2k 0:e614f7875b60 97 * Variables:
iva2k 0:e614f7875b60 98 * returns - 1 if there is a character available to read, else 0
iva2k 0:e614f7875b60 99 */
iva2k 0:e614f7875b60 100 int readable();
iva2k 0:e614f7875b60 101
iva2k 0:e614f7875b60 102 /* Function: writeable
iva2k 0:e614f7875b60 103 * Determine if there is space available to write a character
iva2k 0:e614f7875b60 104 *
iva2k 0:e614f7875b60 105 * Variables:
iva2k 0:e614f7875b60 106 * returns - 1 if there is space to write a character, else 0
iva2k 0:e614f7875b60 107 */
iva2k 0:e614f7875b60 108 int writeable();
iva2k 0:e614f7875b60 109
iva2k 0:e614f7875b60 110 virtual const struct rpc_method *get_rpc_methods();
iva2k 0:e614f7875b60 111 static struct rpc_class *get_rpc_class();
iva2k 0:e614f7875b60 112
iva2k 0:e614f7875b60 113 protected:
iva2k 0:e614f7875b60 114
iva2k 0:e614f7875b60 115 virtual int _getc();
iva2k 0:e614f7875b60 116 virtual int _putc(int c);
iva2k 0:e614f7875b60 117
iva2k 0:e614f7875b60 118 private:
iva2k 0:e614f7875b60 119
iva2k 0:e614f7875b60 120 void startTx();
iva2k 0:e614f7875b60 121 void startRx();
iva2k 0:e614f7875b60 122
iva2k 0:e614f7875b60 123 Timeout m_txTimeout;
iva2k 0:e614f7875b60 124
iva2k 0:e614f7875b60 125 volatile char* m_inBufEven;
iva2k 0:e614f7875b60 126 volatile char* m_inBufOdd;
iva2k 0:e614f7875b60 127 volatile char* m_inBufUsr;
iva2k 0:e614f7875b60 128 volatile char* m_inBufTrmt;
iva2k 0:e614f7875b60 129
iva2k 0:e614f7875b60 130 volatile char* m_outBufEven;
iva2k 0:e614f7875b60 131 volatile char* m_outBufOdd;
iva2k 0:e614f7875b60 132 volatile char* m_outBufUsr;
iva2k 0:e614f7875b60 133 volatile char* m_outBufTrmt;
iva2k 0:e614f7875b60 134
iva2k 0:e614f7875b60 135 volatile int m_inBufLen;
iva2k 0:e614f7875b60 136 volatile int m_outBufLen;
iva2k 0:e614f7875b60 137
iva2k 0:e614f7875b60 138 volatile char* m_pInBufPos;
iva2k 0:e614f7875b60 139 volatile char* m_pOutBufPos;
iva2k 0:e614f7875b60 140
iva2k 0:e614f7875b60 141
iva2k 0:e614f7875b60 142
iva2k 0:e614f7875b60 143 };
iva2k 0:e614f7875b60 144
iva2k 0:e614f7875b60 145 }
iva2k 0:e614f7875b60 146
iva2k 0:e614f7875b60 147
iva2k 0:e614f7875b60 148
iva2k 0:e614f7875b60 149 #endif