Ilya I / Mbed 2 deprecated iva2k_NetHttpServerTcpSockets

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

services/ntp/NTPClient.h@1:3ee499525aa5, 2010-06-14 (annotated)

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 NTP_CLIENT_H





iva2k

0:e614f7875b60


    25

#define NTP_CLIENT_H





iva2k

0:e614f7875b60


    26







iva2k

0:e614f7875b60


    27

#include "if/net/net.h"





iva2k

0:e614f7875b60


    28

#include "api/UDPSocket.h"





iva2k

0:e614f7875b60


    29

#include "api/DNSRequest.h"





iva2k

0:e614f7875b60


    30

#include "mbed.h"





iva2k

0:e614f7875b60


    31







iva2k

0:e614f7875b60


    32

enum NTPResult





iva2k

0:e614f7875b60


    33

{





iva2k

0:e614f7875b60


    34

  NTP_OK,





iva2k

0:e614f7875b60


    35

  NTP_PROCESSING,





iva2k

0:e614f7875b60


    36

  NTP_PRTCL, //Protocol error





iva2k

0:e614f7875b60


    37

  NTP_TIMEOUT, //Connection timeout





iva2k

0:e614f7875b60


    38

  NTP_DNS //Could not resolve DNS Addr





iva2k

0:e614f7875b60


    39

};





iva2k

0:e614f7875b60


    40







iva2k

0:e614f7875b60


    41

class NTPClient





iva2k

0:e614f7875b60


    42

{





iva2k

0:e614f7875b60


    43

public:





iva2k

0:e614f7875b60


    44

  NTPClient();





iva2k

0:e614f7875b60


    45

  virtual ~NTPClient();





iva2k

0:e614f7875b60


    46

  





iva2k

0:e614f7875b60


    47

  //High level setup functions





iva2k

0:e614f7875b60


    48

  NTPResult setTime(const Host& host); //Blocking





iva2k

0:e614f7875b60


    49

  NTPResult setTime(const Host& host, void (*pMethod)(NTPResult)); //Non blocking





iva2k

0:e614f7875b60


    50

  template<class T> 





iva2k

0:e614f7875b60


    51

  NTPResult setTime(const Host& host, T* pItem, void (T::*pMethod)(NTPResult)) //Non blocking





iva2k

0:e614f7875b60


    52

  {





iva2k

0:e614f7875b60


    53

    setOnResult(pItem, pMethod);





iva2k

0:e614f7875b60


    54

    doSetTime(host);





iva2k

0:e614f7875b60


    55

    return NTP_PROCESSING;





iva2k

0:e614f7875b60


    56

  }





iva2k

0:e614f7875b60


    57

  





iva2k

0:e614f7875b60


    58

  void doSetTime(const Host& host);





iva2k

0:e614f7875b60


    59

  





iva2k

0:e614f7875b60


    60

  void setOnResult( void (*pMethod)(NTPResult) );





iva2k

0:e614f7875b60


    61

  class CDummy;





iva2k

0:e614f7875b60


    62

  template<class T> 





iva2k

0:e614f7875b60


    63

  void setOnResult( T* pItem, void (T::*pMethod)(NTPResult) )





iva2k

0:e614f7875b60


    64

  {





iva2k

0:e614f7875b60


    65

    m_pCbItem = (CDummy*) pItem;





iva2k

0:e614f7875b60


    66

    m_pCbMeth = (void (CDummy::*)(NTPResult)) pMethod;





iva2k

0:e614f7875b60


    67

  }





iva2k

0:e614f7875b60


    68

  





iva2k

0:e614f7875b60


    69

  void init();





iva2k

0:e614f7875b60


    70

  void close();





iva2k

0:e614f7875b60


    71

  





iva2k

0:e614f7875b60


    72

private:





iva2k

0:e614f7875b60


    73

  __packed struct NTPPacket //See RFC 4330 for Simple NTP





iva2k

0:e614f7875b60


    74

  {





iva2k

0:e614f7875b60


    75

    //WARN: We are in LE! Network is BE!





iva2k

0:e614f7875b60


    76

    //LSb first





iva2k

0:e614f7875b60


    77

    unsigned mode : 3;





iva2k

0:e614f7875b60


    78

    unsigned vn : 3;





iva2k

0:e614f7875b60


    79

    unsigned li : 2;





iva2k

0:e614f7875b60


    80

    





iva2k

0:e614f7875b60


    81

    uint8_t stratum;





iva2k

0:e614f7875b60


    82

    uint8_t poll;





iva2k

0:e614f7875b60


    83

    uint8_t precision;





iva2k

0:e614f7875b60


    84

    //32 bits header





iva2k

0:e614f7875b60


    85

    





iva2k

0:e614f7875b60


    86

    uint32_t rootDelay;





iva2k

0:e614f7875b60


    87

    uint32_t rootDispersion;





iva2k

0:e614f7875b60


    88

    uint32_t refId;





iva2k

0:e614f7875b60


    89

    





iva2k

0:e614f7875b60


    90

    uint32_t refTm_s;





iva2k

0:e614f7875b60


    91

    uint32_t refTm_f;





iva2k

0:e614f7875b60


    92

    uint32_t origTm_s;





iva2k

0:e614f7875b60


    93

    uint32_t origTm_f;





iva2k

0:e614f7875b60


    94

    uint32_t rxTm_s;





iva2k

0:e614f7875b60


    95

    uint32_t rxTm_f;





iva2k

0:e614f7875b60


    96

    uint32_t txTm_s;





iva2k

0:e614f7875b60


    97

    uint32_t txTm_f;





iva2k

0:e614f7875b60


    98

  };





iva2k

0:e614f7875b60


    99







iva2k

0:e614f7875b60


   100

  void process(); //Main state-machine





iva2k

0:e614f7875b60


   101







iva2k

0:e614f7875b60


   102

  void setTimeout(int ms);





iva2k

0:e614f7875b60


   103

  void resetTimeout();





iva2k

0:e614f7875b60


   104

  





iva2k

0:e614f7875b60


   105

  void onTimeout(); //Connection has timed out





iva2k

0:e614f7875b60


   106

  void onDNSReply(DNSReply r);





iva2k

0:e614f7875b60


   107

  void onUDPSocketEvent(UDPSocketEvent e);





iva2k

0:e614f7875b60


   108

  void onResult(NTPResult r); //Called when exchange completed or on failure





iva2k

0:e614f7875b60


   109

  





iva2k

0:e614f7875b60


   110

  NTPResult blockingProcess(); //Called in blocking mode, calls Net::poll() until return code is available





iva2k

0:e614f7875b60


   111







iva2k

0:e614f7875b60


   112

  UDPSocket* m_pUDPSocket;





iva2k

0:e614f7875b60


   113







iva2k

0:e614f7875b60


   114

  enum NTPStep





iva2k

0:e614f7875b60


   115

  {





iva2k

0:e614f7875b60


   116

    NTP_PING,





iva2k

0:e614f7875b60


   117

    NTP_PONG





iva2k

0:e614f7875b60


   118

  };





iva2k

0:e614f7875b60


   119

  





iva2k

0:e614f7875b60


   120

  NTPStep m_state;





iva2k

0:e614f7875b60


   121

  





iva2k

0:e614f7875b60


   122

  CDummy* m_pCbItem;





iva2k

0:e614f7875b60


   123

  void (CDummy::*m_pCbMeth)(NTPResult);





iva2k

0:e614f7875b60


   124

  





iva2k

0:e614f7875b60


   125

  void (*m_pCb)(NTPResult);





iva2k

0:e614f7875b60


   126

  





iva2k

0:e614f7875b60


   127

  Timeout m_watchdog;





iva2k

0:e614f7875b60


   128

  int m_timeout;





iva2k

0:e614f7875b60


   129

  





iva2k

0:e614f7875b60


   130

  bool m_closed;





iva2k

0:e614f7875b60


   131

  





iva2k

0:e614f7875b60


   132

  Host m_host;





iva2k

0:e614f7875b60


   133

  





iva2k

0:e614f7875b60


   134

  DNSRequest* m_pDnsReq;





iva2k

0:e614f7875b60


   135

  





iva2k

0:e614f7875b60


   136

  NTPResult m_blockingResult; //Result if blocking mode





iva2k

0:e614f7875b60


   137







iva2k

0:e614f7875b60


   138

};





iva2k

0:e614f7875b60


   139







iva2k

0:e614f7875b60


   140

#endif