raf vervoort / HTTPServer

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Fork of HTTPServer by Sam Kirsch

HTTPServer.cpp@4:d065642c32cc, 2013-05-28 (annotated)

Committer:
leihen
Date:
Tue May 28 21:20:58 2013 +0000
Revision:
4:d065642c32cc
Parent:
3:d6224049b3bf
Child:
5:dc88012caef1
Added parameter parsing from uri in http webrequest.

; Documentation updated.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
leihen 0:7a2421e63e74 1 #include "mbed.h"
leihen 0:7a2421e63e74 2 #include "HTTPServer.h"
leihen 0:7a2421e63e74 3
leihen 4:d065642c32cc 4 #define _DEBUG 1
leihen 4:d065642c32cc 5
leihen 4:d065642c32cc 6 #ifdef _DEBUG
leihen 0:7a2421e63e74 7 DigitalOut led1(LED1);
leihen 0:7a2421e63e74 8 DigitalOut led2(LED2);
leihen 0:7a2421e63e74 9 DigitalOut led3(LED3);
leihen 0:7a2421e63e74 10 DigitalOut led4(LED4);
leihen 4:d065642c32cc 11 #endif
leihen 0:7a2421e63e74 12
leihen 4:d065642c32cc 13 #if (_DEBUG && !defined(TARGET_LPC11U24))
leihen 0:7a2421e63e74 14 #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 15 #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 16 #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 17 #else
leihen 0:7a2421e63e74 18 #define INFO(x, ...)
leihen 0:7a2421e63e74 19 #define WARN(x, ...)
leihen 0:7a2421e63e74 20 #define ERR(x, ...)
leihen 0:7a2421e63e74 21 #endif
leihen 0:7a2421e63e74 22
leihen 4:d065642c32cc 23
leihen 4:d065642c32cc 24 /* Constructor */
leihen 4:d065642c32cc 25 /* initialize all members and set the standard error handler. */
leihen 3:d6224049b3bf 26 HTTPServer::HTTPServer(Serial *dbg)
leihen 0:7a2421e63e74 27 {
leihen 3:d6224049b3bf 28 m_pDbg = dbg;
leihen 0:7a2421e63e74 29 m_pSvr = NULL;
leihen 2:8653bbcf7e58 30 m_pErrorHandler = StdErrorHandler;
leihen 0:7a2421e63e74 31 }
leihen 0:7a2421e63e74 32
leihen 0:7a2421e63e74 33 HTTPServer::~HTTPServer()
leihen 0:7a2421e63e74 34 {
leihen 0:7a2421e63e74 35 if (m_pSvr) {
leihen 0:7a2421e63e74 36 delete m_pSvr;
leihen 0:7a2421e63e74 37 m_pSvr = NULL;
leihen 0:7a2421e63e74 38 }
leihen 0:7a2421e63e74 39 }
leihen 0:7a2421e63e74 40
leihen 2:8653bbcf7e58 41
leihen 4:d065642c32cc 42 static const char* szStdErrorPage = "<HTML><HEAD><META content=\"text/html\" http-equiv=Content-Type></HEAD><BODY><h1>Error 404</h1><P>This resource is not available<P></BODY></HTML>\r\n\r\n";
leihen 2:8653bbcf7e58 43
leihen 3:d6224049b3bf 44 void HTTPServer::StdErrorHandler(HTTPConnection::HTTPMessage& msg, TCPSocketConnection& tcp)
leihen 2:8653bbcf7e58 45 {
leihen 4:d065642c32cc 46 char echoHeader[256];
leihen 2:8653bbcf7e58 47 tcp.set_blocking(true, 1500);
leihen 2:8653bbcf7e58 48 sprintf(echoHeader,"HTTP/1.1 404 Fail\r\nContent-Length: %d\r\nContent-Type: text/html\r\nServer: mbed embedded\r\n\n\r",strlen(szStdErrorPage));
leihen 2:8653bbcf7e58 49 tcp.send(echoHeader, strlen(echoHeader));
leihen 2:8653bbcf7e58 50 tcp.send((char*)szStdErrorPage, strlen(szStdErrorPage));
leihen 2:8653bbcf7e58 51 }
leihen 2:8653bbcf7e58 52
leihen 2:8653bbcf7e58 53
leihen 0:7a2421e63e74 54 int HTTPServer::start(int port)
leihen 0:7a2421e63e74 55 {
leihen 0:7a2421e63e74 56 // check if the start member was called already once
leihen 0:7a2421e63e74 57 if (m_pSvr != NULL) {
leihen 0:7a2421e63e74 58 ERR("start function was already called, server is already in listening state.");
leihen 0:7a2421e63e74 59 return -1;
leihen 0:7a2421e63e74 60 }
leihen 0:7a2421e63e74 61
leihen 0:7a2421e63e74 62 // Create a new server object
leihen 0:7a2421e63e74 63 m_pSvr = new TCPSocketServer();
leihen 0:7a2421e63e74 64
leihen 0:7a2421e63e74 65 // Bind the local server to the given port
leihen 0:7a2421e63e74 66 if (m_pSvr->bind(port) < 0) {
leihen 0:7a2421e63e74 67 ERR("Failed to bind to port %d\n", port);
leihen 0:7a2421e63e74 68 return -1;
leihen 0:7a2421e63e74 69 }
leihen 0:7a2421e63e74 70 else {
leihen 0:7a2421e63e74 71 INFO("Binding succeeded !\n");
leihen 0:7a2421e63e74 72 }
leihen 0:7a2421e63e74 73
leihen 0:7a2421e63e74 74 // Listen to a maximum of 10 concurrent connections
leihen 0:7a2421e63e74 75 if (m_pSvr->listen(1) < 0) {
leihen 0:7a2421e63e74 76 ERR("Faild to listen !\n");
leihen 0:7a2421e63e74 77 delete m_pSvr;
leihen 0:7a2421e63e74 78 m_pSvr = NULL;
leihen 0:7a2421e63e74 79 return -1;
leihen 0:7a2421e63e74 80 }
leihen 0:7a2421e63e74 81 else {
leihen 0:7a2421e63e74 82 INFO("Listening\n");
leihen 0:7a2421e63e74 83 }
leihen 0:7a2421e63e74 84
leihen 0:7a2421e63e74 85 // set into non blocking operation
leihen 0:7a2421e63e74 86 m_pSvr->set_blocking(false, 100);
leihen 0:7a2421e63e74 87
leihen 0:7a2421e63e74 88 return 0;
leihen 0:7a2421e63e74 89 }
leihen 0:7a2421e63e74 90
leihen 0:7a2421e63e74 91
leihen 0:7a2421e63e74 92 int HTTPServer::poll()
leihen 0:7a2421e63e74 93 {
leihen 0:7a2421e63e74 94 INFO("Listening for new connection requests.");
leihen 0:7a2421e63e74 95
leihen 0:7a2421e63e74 96 // This thread basically checks if there is a new incoming connection.
leihen 0:7a2421e63e74 97 // If so , a new HTTPConnection is created and the connection thread is started.
leihen 0:7a2421e63e74 98 TCPSocketConnection Clnt;
leihen 0:7a2421e63e74 99
leihen 4:d065642c32cc 100 #ifdef _DEBUG
leihen 0:7a2421e63e74 101 led4 = 1; // Indicate we are waiting for a new connection
leihen 4:d065642c32cc 102 #endif
leihen 0:7a2421e63e74 103 if (m_pSvr->accept(Clnt) < 0) {
leihen 0:7a2421e63e74 104 // an error occured
leihen 0:7a2421e63e74 105 ERR("There was an error, Accept returned with an error. Probably the connection to the router was lost. Shutting down server");
leihen 4:d065642c32cc 106 #ifdef _DEBUG
leihen 0:7a2421e63e74 107 led2 = 0;
leihen 4:d065642c32cc 108 #endif
leihen 0:7a2421e63e74 109 m_pSvr->close();
leihen 0:7a2421e63e74 110 delete m_pSvr;
leihen 0:7a2421e63e74 111 m_pSvr = NULL;
leihen 4:d065642c32cc 112 #ifdef _DEBUG
leihen 0:7a2421e63e74 113 led4 = 0;
leihen 0:7a2421e63e74 114 led3 = 1; // ERROR
leihen 0:7a2421e63e74 115 led2 = 0;
leihen 0:7a2421e63e74 116 led1 = 0;
leihen 4:d065642c32cc 117 #endif
leihen 0:7a2421e63e74 118 return -1;
leihen 0:7a2421e63e74 119 }
leihen 0:7a2421e63e74 120 else {
leihen 4:d065642c32cc 121 #ifdef _DEBUG
leihen 0:7a2421e63e74 122 led4 = 0;
leihen 4:d065642c32cc 123 #endif
leihen 0:7a2421e63e74 124 // a new connection was received
leihen 0:7a2421e63e74 125 INFO("Client (IP=%s) is connected !\n", Clnt.get_address());
leihen 0:7a2421e63e74 126 // Start the main connection thread
leihen 4:d065642c32cc 127 #ifdef _DEBUG
leihen 0:7a2421e63e74 128 led3 = 1;
leihen 0:7a2421e63e74 129 led2 = 1;
leihen 4:d065642c32cc 130 #endif
leihen 0:7a2421e63e74 131 HTTPConnection con;
leihen 0:7a2421e63e74 132 int c = con.poll();
leihen 0:7a2421e63e74 133 if (c == 0) {
leihen 1:6b7472d5e9ee 134 // Handle the request
leihen 1:6b7472d5e9ee 135 HandleRequest(con.m_Msg, Clnt);
leihen 0:7a2421e63e74 136 }
leihen 4:d065642c32cc 137 #ifdef _DEBUG
leihen 0:7a2421e63e74 138 led2 = 0;
leihen 0:7a2421e63e74 139 led3 = 0;
leihen 4:d065642c32cc 140 #endif
leihen 0:7a2421e63e74 141 }
leihen 0:7a2421e63e74 142
leihen 0:7a2421e63e74 143 INFO("Leaving polling thread");
leihen 0:7a2421e63e74 144 return 0;
leihen 1:6b7472d5e9ee 145 }
leihen 1:6b7472d5e9ee 146
leihen 3:d6224049b3bf 147 void HTTPServer::HandleRequest(HTTPConnection::HTTPMessage& msg, TCPSocketConnection& tcp)
leihen 3:d6224049b3bf 148 {
leihen 3:d6224049b3bf 149 std::string localPath;
leihen 3:d6224049b3bf 150 std::map<std::string, HTTPRequestHandler*(*)(const char*, const char*, HTTPConnection::HTTPMessage&, TCPSocketConnection&), handlersComp>::const_iterator it;
leihen 3:d6224049b3bf 151
leihen 4:d065642c32cc 152 // Iterate through registered handlers and check if the handler's path is a subset of the requested uri.
leihen 3:d6224049b3bf 153 for (it = m_lpHandlers.begin() ; it != m_lpHandlers.end() ; it++) {
leihen 3:d6224049b3bf 154 // check if this entries' path is fully contained at the beginning of the requested path
leihen 3:d6224049b3bf 155 std::string curpth = it->first;
leihen 3:d6224049b3bf 156
leihen 3:d6224049b3bf 157 if (msg.uri.find(curpth) == 0) {
leihen 4:d065642c32cc 158 // firts matching handler found, we just take it and we'll be happy
leihen 3:d6224049b3bf 159 localPath = msg.uri.substr(curpth.length());
leihen 3:d6224049b3bf 160 break;
leihen 3:d6224049b3bf 161 }
leihen 3:d6224049b3bf 162 }
leihen 3:d6224049b3bf 163
leihen 3:d6224049b3bf 164 if (it == m_lpHandlers.end()) {
leihen 3:d6224049b3bf 165 // There is no such handler, so return invalid
leihen 3:d6224049b3bf 166
leihen 3:d6224049b3bf 167 m_pErrorHandler(msg, tcp);
leihen 3:d6224049b3bf 168 INFO("Webrequest left unhandled.");
leihen 3:d6224049b3bf 169 }
leihen 3:d6224049b3bf 170 else {
leihen 4:d065642c32cc 171 // Valid handler was found
leihen 3:d6224049b3bf 172 INFO("Routing webrequest !");
leihen 4:d065642c32cc 173 // Instantiate the handler object (handling will be done from withing the object's constructor
leihen 3:d6224049b3bf 174 HTTPRequestHandler *phdl = (*it->second)(it->first.c_str(), localPath.c_str(), msg, tcp);
leihen 4:d065642c32cc 175 // now we can delete the object, because handling is completed.
leihen 3:d6224049b3bf 176 if (phdl != NULL)
leihen 3:d6224049b3bf 177 delete phdl;
leihen 3:d6224049b3bf 178 }
leihen 3:d6224049b3bf 179 }