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 #include "telit.h"
iva2k 0:e614f7875b60 25
iva2k 0:e614f7875b60 26 #include "mbed.h"
iva2k 0:e614f7875b60 27
iva2k 0:e614f7875b60 28 //#define __DEBUG
iva2k 0:e614f7875b60 29 #include "dbg/dbg.h"
iva2k 0:e614f7875b60 30
iva2k 0:e614f7875b60 31 #include "netCfg.h"
iva2k 0:e614f7875b60 32 #if NET_TELIT
iva2k 0:e614f7875b60 33
iva2k 0:e614f7875b60 34 Telit::Telit(PinName pwrSetPin, PinName pwrMonPin) : m_pwrSetPin(pwrSetPin), m_pwrMonPin(pwrMonPin)
iva2k 0:e614f7875b60 35 {
iva2k 0:e614f7875b60 36 //m_pwrSetPin.write(0);
iva2k 0:e614f7875b60 37
iva2k 0:e614f7875b60 38 //m_pwrMonPin.mode(PullDown);
iva2k 0:e614f7875b60 39 }
iva2k 0:e614f7875b60 40
iva2k 0:e614f7875b60 41 Telit::~Telit() {
iva2k 0:e614f7875b60 42
iva2k 0:e614f7875b60 43 }
iva2k 0:e614f7875b60 44
iva2k 0:e614f7875b60 45 bool Telit::isOn() //True if on
iva2k 0:e614f7875b60 46 {
iva2k 0:e614f7875b60 47 return m_pwrMonPin.read();
iva2k 0:e614f7875b60 48 }
iva2k 0:e614f7875b60 49
iva2k 0:e614f7875b60 50 bool Telit::on() //True if OK
iva2k 0:e614f7875b60 51 {
iva2k 0:e614f7875b60 52 Timer tmr;
iva2k 0:e614f7875b60 53 if(!m_pwrMonPin.read()){
iva2k 0:e614f7875b60 54 //On
iva2k 0:e614f7875b60 55 DBG("Switching On...\n");
iva2k 0:e614f7875b60 56 m_pwrSetPin.write(1);
iva2k 0:e614f7875b60 57 wait(1.);
iva2k 0:e614f7875b60 58 m_pwrSetPin.write(0);
iva2k 0:e614f7875b60 59
iva2k 0:e614f7875b60 60 tmr.start();
iva2k 0:e614f7875b60 61 while(!m_pwrMonPin.read())
iva2k 0:e614f7875b60 62 {
iva2k 0:e614f7875b60 63 wait(.001);
iva2k 0:e614f7875b60 64 if(tmr.read() > 2)
iva2k 0:e614f7875b60 65 {
iva2k 0:e614f7875b60 66 DBG("ERROR - MUST RESET MODULE\n");
iva2k 0:e614f7875b60 67 break;
iva2k 0:e614f7875b60 68 }
iva2k 0:e614f7875b60 69 }
iva2k 0:e614f7875b60 70 tmr.stop();
iva2k 0:e614f7875b60 71 }
iva2k 0:e614f7875b60 72 wait(.1);
iva2k 0:e614f7875b60 73 return m_pwrMonPin.read();
iva2k 0:e614f7875b60 74 }
iva2k 0:e614f7875b60 75
iva2k 0:e614f7875b60 76 bool Telit::off() { //True if OK
iva2k 0:e614f7875b60 77 Timer tmr;
iva2k 0:e614f7875b60 78 if(m_pwrMonPin.read()){
iva2k 0:e614f7875b60 79 //Off
iva2k 0:e614f7875b60 80 DBG("Switching Off...\n");
iva2k 0:e614f7875b60 81 m_pwrSetPin.write(1);
iva2k 0:e614f7875b60 82 wait(3.);
iva2k 0:e614f7875b60 83 m_pwrSetPin.write(0);
iva2k 0:e614f7875b60 84 DBG("Waiting....\n");
iva2k 0:e614f7875b60 85 tmr.start();
iva2k 0:e614f7875b60 86 while(m_pwrMonPin.read())
iva2k 0:e614f7875b60 87 {
iva2k 0:e614f7875b60 88 wait(.001);
iva2k 0:e614f7875b60 89 if(tmr.read() > 15)
iva2k 0:e614f7875b60 90 {
iva2k 0:e614f7875b60 91 DBG("ERROR - MUST RESET MODULE\n");
iva2k 0:e614f7875b60 92 break;
iva2k 0:e614f7875b60 93 }
iva2k 0:e614f7875b60 94 }
iva2k 0:e614f7875b60 95 tmr.stop();
iva2k 0:e614f7875b60 96 }
iva2k 0:e614f7875b60 97 return !m_pwrMonPin.read();
iva2k 0:e614f7875b60 98 }
iva2k 0:e614f7875b60 99
iva2k 0:e614f7875b60 100 #endif