This is a HTTP Server example using the new EthernetInterface and new mbed-rpc libraries.
Dependents: HTTP-RPCServerExample
Fork of HTTPServer by
HTTPServer.cpp@0:7a2421e63e74, 2013-05-26 (annotated)
- Committer:
- leihen
- Date:
- Sun May 26 20:13:28 2013 +0000
- Revision:
- 0:7a2421e63e74
- Child:
- 1:6b7472d5e9ee
First draft, which does not actually handle a request.
; Framework is working though.
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
leihen | 0:7a2421e63e74 | 1 | #include "mbed.h" |
leihen | 0:7a2421e63e74 | 2 | #include "HTTPServer.h" |
leihen | 0:7a2421e63e74 | 3 | |
leihen | 0:7a2421e63e74 | 4 | DigitalOut led1(LED1); |
leihen | 0:7a2421e63e74 | 5 | DigitalOut led2(LED2); |
leihen | 0:7a2421e63e74 | 6 | DigitalOut led3(LED3); |
leihen | 0:7a2421e63e74 | 7 | DigitalOut led4(LED4); |
leihen | 0:7a2421e63e74 | 8 | |
leihen | 0:7a2421e63e74 | 9 | #if (1 && !defined(TARGET_LPC11U24)) |
leihen | 0:7a2421e63e74 | 10 | #define INFO(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__); |
leihen | 0:7a2421e63e74 | 11 | #define WARN(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : WARN]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__); |
leihen | 0:7a2421e63e74 | 12 | #define ERR(x, ...) if (m_pDbg) m_pDbg->printf("[HttpServer : ERR]"x"\r\n", ##__VA_ARGS__); else printf("[HttpServer : DBG]"x"\r\n", ##__VA_ARGS__); |
leihen | 0:7a2421e63e74 | 13 | #else |
leihen | 0:7a2421e63e74 | 14 | #define INFO(x, ...) |
leihen | 0:7a2421e63e74 | 15 | #define WARN(x, ...) |
leihen | 0:7a2421e63e74 | 16 | #define ERR(x, ...) |
leihen | 0:7a2421e63e74 | 17 | #endif |
leihen | 0:7a2421e63e74 | 18 | |
leihen | 0:7a2421e63e74 | 19 | |
leihen | 0:7a2421e63e74 | 20 | HTTPServer::HTTPServer(Serial* pDbg) |
leihen | 0:7a2421e63e74 | 21 | { |
leihen | 0:7a2421e63e74 | 22 | m_pDbg = pDbg; |
leihen | 0:7a2421e63e74 | 23 | m_pSvr = NULL; |
leihen | 0:7a2421e63e74 | 24 | m_bServerListening = false; |
leihen | 0:7a2421e63e74 | 25 | } |
leihen | 0:7a2421e63e74 | 26 | |
leihen | 0:7a2421e63e74 | 27 | HTTPServer::~HTTPServer() |
leihen | 0:7a2421e63e74 | 28 | { |
leihen | 0:7a2421e63e74 | 29 | if (m_pSvr) { |
leihen | 0:7a2421e63e74 | 30 | delete m_pSvr; |
leihen | 0:7a2421e63e74 | 31 | m_pSvr = NULL; |
leihen | 0:7a2421e63e74 | 32 | m_bServerListening = false; |
leihen | 0:7a2421e63e74 | 33 | } |
leihen | 0:7a2421e63e74 | 34 | } |
leihen | 0:7a2421e63e74 | 35 | |
leihen | 0:7a2421e63e74 | 36 | int HTTPServer::start(int port) |
leihen | 0:7a2421e63e74 | 37 | { |
leihen | 0:7a2421e63e74 | 38 | // check if the start member was called already once |
leihen | 0:7a2421e63e74 | 39 | if (m_pSvr != NULL) { |
leihen | 0:7a2421e63e74 | 40 | ERR("start function was already called, server is already in listening state."); |
leihen | 0:7a2421e63e74 | 41 | return -1; |
leihen | 0:7a2421e63e74 | 42 | } |
leihen | 0:7a2421e63e74 | 43 | |
leihen | 0:7a2421e63e74 | 44 | m_bServerListening = false; |
leihen | 0:7a2421e63e74 | 45 | |
leihen | 0:7a2421e63e74 | 46 | // Create a new server object |
leihen | 0:7a2421e63e74 | 47 | m_pSvr = new TCPSocketServer(); |
leihen | 0:7a2421e63e74 | 48 | |
leihen | 0:7a2421e63e74 | 49 | // Bind the local server to the given port |
leihen | 0:7a2421e63e74 | 50 | if (m_pSvr->bind(port) < 0) { |
leihen | 0:7a2421e63e74 | 51 | ERR("Failed to bind to port %d\n", port); |
leihen | 0:7a2421e63e74 | 52 | return -1; |
leihen | 0:7a2421e63e74 | 53 | } |
leihen | 0:7a2421e63e74 | 54 | else { |
leihen | 0:7a2421e63e74 | 55 | INFO("Binding succeeded !\n"); |
leihen | 0:7a2421e63e74 | 56 | } |
leihen | 0:7a2421e63e74 | 57 | |
leihen | 0:7a2421e63e74 | 58 | // Listen to a maximum of 10 concurrent connections |
leihen | 0:7a2421e63e74 | 59 | if (m_pSvr->listen(1) < 0) { |
leihen | 0:7a2421e63e74 | 60 | ERR("Faild to listen !\n"); |
leihen | 0:7a2421e63e74 | 61 | delete m_pSvr; |
leihen | 0:7a2421e63e74 | 62 | m_pSvr = NULL; |
leihen | 0:7a2421e63e74 | 63 | return -1; |
leihen | 0:7a2421e63e74 | 64 | } |
leihen | 0:7a2421e63e74 | 65 | else { |
leihen | 0:7a2421e63e74 | 66 | INFO("Listening\n"); |
leihen | 0:7a2421e63e74 | 67 | m_bServerListening = true; |
leihen | 0:7a2421e63e74 | 68 | } |
leihen | 0:7a2421e63e74 | 69 | |
leihen | 0:7a2421e63e74 | 70 | // set into non blocking operation |
leihen | 0:7a2421e63e74 | 71 | m_pSvr->set_blocking(false, 100); |
leihen | 0:7a2421e63e74 | 72 | |
leihen | 0:7a2421e63e74 | 73 | return 0; |
leihen | 0:7a2421e63e74 | 74 | } |
leihen | 0:7a2421e63e74 | 75 | |
leihen | 0:7a2421e63e74 | 76 | |
leihen | 0:7a2421e63e74 | 77 | int HTTPServer::poll() |
leihen | 0:7a2421e63e74 | 78 | { |
leihen | 0:7a2421e63e74 | 79 | INFO("Listening for new connection requests."); |
leihen | 0:7a2421e63e74 | 80 | |
leihen | 0:7a2421e63e74 | 81 | // This thread basically checks if there is a new incoming connection. |
leihen | 0:7a2421e63e74 | 82 | // If so , a new HTTPConnection is created and the connection thread is started. |
leihen | 0:7a2421e63e74 | 83 | TCPSocketConnection Clnt; |
leihen | 0:7a2421e63e74 | 84 | |
leihen | 0:7a2421e63e74 | 85 | led4 = 1; // Indicate we are waiting for a new connection |
leihen | 0:7a2421e63e74 | 86 | if (m_pSvr->accept(Clnt) < 0) { |
leihen | 0:7a2421e63e74 | 87 | // an error occured |
leihen | 0:7a2421e63e74 | 88 | ERR("There was an error, Accept returned with an error. Probably the connection to the router was lost. Shutting down server"); |
leihen | 0:7a2421e63e74 | 89 | led2 = 0; |
leihen | 0:7a2421e63e74 | 90 | m_bServerListening = false; |
leihen | 0:7a2421e63e74 | 91 | m_pSvr->close(); |
leihen | 0:7a2421e63e74 | 92 | delete m_pSvr; |
leihen | 0:7a2421e63e74 | 93 | m_pSvr = NULL; |
leihen | 0:7a2421e63e74 | 94 | led4 = 0; |
leihen | 0:7a2421e63e74 | 95 | led3 = 1; // ERROR |
leihen | 0:7a2421e63e74 | 96 | led2 = 0; |
leihen | 0:7a2421e63e74 | 97 | led1 = 0; |
leihen | 0:7a2421e63e74 | 98 | return -1; |
leihen | 0:7a2421e63e74 | 99 | } |
leihen | 0:7a2421e63e74 | 100 | else { |
leihen | 0:7a2421e63e74 | 101 | led4 = 0; |
leihen | 0:7a2421e63e74 | 102 | // a new connection was received |
leihen | 0:7a2421e63e74 | 103 | INFO("Client (IP=%s) is connected !\n", Clnt.get_address()); |
leihen | 0:7a2421e63e74 | 104 | // Start the main connection thread |
leihen | 0:7a2421e63e74 | 105 | led3 = 1; |
leihen | 0:7a2421e63e74 | 106 | led2 = 1; |
leihen | 0:7a2421e63e74 | 107 | HTTPConnection con; |
leihen | 0:7a2421e63e74 | 108 | int c = con.poll(); |
leihen | 0:7a2421e63e74 | 109 | if (c == 0) { |
leihen | 0:7a2421e63e74 | 110 | } |
leihen | 0:7a2421e63e74 | 111 | led2 = 0; |
leihen | 0:7a2421e63e74 | 112 | led3 = 0; |
leihen | 0:7a2421e63e74 | 113 | } |
leihen | 0:7a2421e63e74 | 114 | |
leihen | 0:7a2421e63e74 | 115 | |
leihen | 0:7a2421e63e74 | 116 | INFO("Leaving polling thread"); |
leihen | 0:7a2421e63e74 | 117 | return 0; |
leihen | 0:7a2421e63e74 | 118 | } |