Michael Spencer / Mbed 2 deprecated LaOS

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.

Dependencies:   mbed

NetServices/services/http/server/HTTPRequestDispatcher.cpp@1:f5ac63519541, 2014-03-05 (annotated)

Committer:
Michael J. Spencer
Date:
Wed Mar 05 06:14:02 2014 -0800
Revision:
1:f5ac63519541
Initial commit.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Michael J. Spencer 1:f5ac63519541 1
Michael J. Spencer 1:f5ac63519541 2 /*
Michael J. Spencer 1:f5ac63519541 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
Michael J. Spencer 1:f5ac63519541 4
Michael J. Spencer 1:f5ac63519541 5 Permission is hereby granted, free of charge, to any person obtaining a copy
Michael J. Spencer 1:f5ac63519541 6 of this software and associated documentation files (the "Software"), to deal
Michael J. Spencer 1:f5ac63519541 7 in the Software without restriction, including without limitation the rights
Michael J. Spencer 1:f5ac63519541 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
Michael J. Spencer 1:f5ac63519541 9 copies of the Software, and to permit persons to whom the Software is
Michael J. Spencer 1:f5ac63519541 10 furnished to do so, subject to the following conditions:
Michael J. Spencer 1:f5ac63519541 11
Michael J. Spencer 1:f5ac63519541 12 The above copyright notice and this permission notice shall be included in
Michael J. Spencer 1:f5ac63519541 13 all copies or substantial portions of the Software.
Michael J. Spencer 1:f5ac63519541 14
Michael J. Spencer 1:f5ac63519541 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
Michael J. Spencer 1:f5ac63519541 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
Michael J. Spencer 1:f5ac63519541 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
Michael J. Spencer 1:f5ac63519541 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
Michael J. Spencer 1:f5ac63519541 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
Michael J. Spencer 1:f5ac63519541 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
Michael J. Spencer 1:f5ac63519541 21 THE SOFTWARE.
Michael J. Spencer 1:f5ac63519541 22 */
Michael J. Spencer 1:f5ac63519541 23
Michael J. Spencer 1:f5ac63519541 24 #include "core/netservice.h"
Michael J. Spencer 1:f5ac63519541 25 #include "HTTPRequestDispatcher.h"
Michael J. Spencer 1:f5ac63519541 26 #include "HTTPRequestHandler.h"
Michael J. Spencer 1:f5ac63519541 27 #include <string.h>
Michael J. Spencer 1:f5ac63519541 28
Michael J. Spencer 1:f5ac63519541 29 //#define __DEBUG
Michael J. Spencer 1:f5ac63519541 30 #include "dbg/dbg.h"
Michael J. Spencer 1:f5ac63519541 31
Michael J. Spencer 1:f5ac63519541 32 HTTPRequestDispatcher::HTTPRequestDispatcher(HTTPServer* pSvr, TCPSocket* pTCPSocket) : NetService(), m_pSvr(pSvr), m_pTCPSocket(pTCPSocket), m_watchdog(), m_closed(false)
Michael J. Spencer 1:f5ac63519541 33 {
Michael J. Spencer 1:f5ac63519541 34 m_pTCPSocket->setOnEvent(this, &HTTPRequestDispatcher::onTCPSocketEvent);
Michael J. Spencer 1:f5ac63519541 35 m_watchdog.attach_us<HTTPRequestDispatcher>(this, &HTTPRequestDispatcher::onTimeout, HTTP_REQUEST_TIMEOUT * 1000);
Michael J. Spencer 1:f5ac63519541 36 }
Michael J. Spencer 1:f5ac63519541 37
Michael J. Spencer 1:f5ac63519541 38 HTTPRequestDispatcher::~HTTPRequestDispatcher()
Michael J. Spencer 1:f5ac63519541 39 {
Michael J. Spencer 1:f5ac63519541 40 close();
Michael J. Spencer 1:f5ac63519541 41 }
Michael J. Spencer 1:f5ac63519541 42
Michael J. Spencer 1:f5ac63519541 43 void HTTPRequestDispatcher::dispatchRequest()
Michael J. Spencer 1:f5ac63519541 44 {
Michael J. Spencer 1:f5ac63519541 45 string path;
Michael J. Spencer 1:f5ac63519541 46 string meth;
Michael J. Spencer 1:f5ac63519541 47 HTTP_METH methCode;
Michael J. Spencer 1:f5ac63519541 48
Michael J. Spencer 1:f5ac63519541 49 DBG("Dispatching req\r\n");
Michael J. Spencer 1:f5ac63519541 50
Michael J. Spencer 1:f5ac63519541 51 if( !getRequest(&path, &meth ) )
Michael J. Spencer 1:f5ac63519541 52 {
Michael J. Spencer 1:f5ac63519541 53 close();
Michael J. Spencer 1:f5ac63519541 54 return; //Invalid request
Michael J. Spencer 1:f5ac63519541 55 }
Michael J. Spencer 1:f5ac63519541 56
Michael J. Spencer 1:f5ac63519541 57 if( !meth.compare("GET") )
Michael J. Spencer 1:f5ac63519541 58 {
Michael J. Spencer 1:f5ac63519541 59 methCode = HTTP_GET;
Michael J. Spencer 1:f5ac63519541 60 }
Michael J. Spencer 1:f5ac63519541 61 else if( !meth.compare("POST") )
Michael J. Spencer 1:f5ac63519541 62 {
Michael J. Spencer 1:f5ac63519541 63 methCode = HTTP_POST;
Michael J. Spencer 1:f5ac63519541 64 }
Michael J. Spencer 1:f5ac63519541 65 else if( !meth.compare("HEAD") )
Michael J. Spencer 1:f5ac63519541 66 {
Michael J. Spencer 1:f5ac63519541 67 methCode = HTTP_HEAD;
Michael J. Spencer 1:f5ac63519541 68 }
Michael J. Spencer 1:f5ac63519541 69 else
Michael J. Spencer 1:f5ac63519541 70 {
Michael J. Spencer 1:f5ac63519541 71 close(); //Parse error
Michael J. Spencer 1:f5ac63519541 72 return;
Michael J. Spencer 1:f5ac63519541 73 }
Michael J. Spencer 1:f5ac63519541 74
Michael J. Spencer 1:f5ac63519541 75 DBG("Looking for a handler\r\n");
Michael J. Spencer 1:f5ac63519541 76
Michael J. Spencer 1:f5ac63519541 77 map< string, HTTPRequestHandler*(*)(const char*, const char*, TCPSocket*) >::iterator it;
Michael J. Spencer 1:f5ac63519541 78 // it = m_pSvr->m_lpHandlers.find(rootPath); //We are friends so we can do that
Michael J. Spencer 1:f5ac63519541 79 // NEW CODE START:
Michael J. Spencer 1:f5ac63519541 80 int root_len = 0;
Michael J. Spencer 1:f5ac63519541 81 for (it = m_pSvr->m_lpHandlers.begin(); it != m_pSvr->m_lpHandlers.end(); it++)
Michael J. Spencer 1:f5ac63519541 82 {
Michael J. Spencer 1:f5ac63519541 83 DBG("Checking %s...\n", (*it).first.c_str());
Michael J. Spencer 1:f5ac63519541 84 root_len = (*it).first.length();
Michael J. Spencer 1:f5ac63519541 85 if ( root_len &&
Michael J. Spencer 1:f5ac63519541 86 !path.compare( 0, root_len, (*it).first ) &&
Michael J. Spencer 1:f5ac63519541 87 (path[root_len] == '/' || path[root_len] == '\0'))
Michael J. Spencer 1:f5ac63519541 88 {
Michael J. Spencer 1:f5ac63519541 89 DBG("Found (%s)\n", (*it).first.c_str());
Michael J. Spencer 1:f5ac63519541 90 // Found!
Michael J. Spencer 1:f5ac63519541 91 break; // for
Michael J. Spencer 1:f5ac63519541 92 }
Michael J. Spencer 1:f5ac63519541 93 }
Michael J. Spencer 1:f5ac63519541 94 // NEW CODE END
Michael J. Spencer 1:f5ac63519541 95 if((it == m_pSvr->m_lpHandlers.end()) && !(m_pSvr->m_lpHandlers.empty()))
Michael J. Spencer 1:f5ac63519541 96 {
Michael J. Spencer 1:f5ac63519541 97 DBG("Using default handler\n");
Michael J. Spencer 1:f5ac63519541 98 it = m_pSvr->m_lpHandlers.end();
Michael J. Spencer 1:f5ac63519541 99 it--; //Get the last element
Michael J. Spencer 1:f5ac63519541 100 if( ! (((*it).first.length() == 0) || !(*it).first.compare("/")) ) //This is not the default handler
Michael J. Spencer 1:f5ac63519541 101 it = m_pSvr->m_lpHandlers.end();
Michael J. Spencer 1:f5ac63519541 102 root_len = 0;
Michael J. Spencer 1:f5ac63519541 103 }
Michael J. Spencer 1:f5ac63519541 104 if(it == m_pSvr->m_lpHandlers.end())
Michael J. Spencer 1:f5ac63519541 105 {
Michael J. Spencer 1:f5ac63519541 106 DBG("No handler found\n");
Michael J. Spencer 1:f5ac63519541 107 close(); //No handler found
Michael J. Spencer 1:f5ac63519541 108 return;
Michael J. Spencer 1:f5ac63519541 109 }
Michael J. Spencer 1:f5ac63519541 110
Michael J. Spencer 1:f5ac63519541 111 DBG("Handler found.\r\n");
Michael J. Spencer 1:f5ac63519541 112
Michael J. Spencer 1:f5ac63519541 113 //HTTPRequestHandler* pHdlr = (*it).second(rootPath.c_str(), subPath.c_str(), m_pTCPSocket);
Michael J. Spencer 1:f5ac63519541 114 //NEW CODE 1 LINE:
Michael J. Spencer 1:f5ac63519541 115 HTTPRequestHandler* pHdlr = (*it).second((*it).first.c_str(), path.c_str() + root_len, m_pTCPSocket);
Michael J. Spencer 1:f5ac63519541 116 m_pTCPSocket = NULL; //We don't own it anymore
Michael J. Spencer 1:f5ac63519541 117
Michael J. Spencer 1:f5ac63519541 118 switch(methCode)
Michael J. Spencer 1:f5ac63519541 119 {
Michael J. Spencer 1:f5ac63519541 120 case HTTP_GET:
Michael J. Spencer 1:f5ac63519541 121 pHdlr->doGet();
Michael J. Spencer 1:f5ac63519541 122 break;
Michael J. Spencer 1:f5ac63519541 123 case HTTP_POST:
Michael J. Spencer 1:f5ac63519541 124 pHdlr->doPost();
Michael J. Spencer 1:f5ac63519541 125 break;
Michael J. Spencer 1:f5ac63519541 126 case HTTP_HEAD:
Michael J. Spencer 1:f5ac63519541 127 pHdlr->doHead();
Michael J. Spencer 1:f5ac63519541 128 break;
Michael J. Spencer 1:f5ac63519541 129 }
Michael J. Spencer 1:f5ac63519541 130
Michael J. Spencer 1:f5ac63519541 131 DBG("Req handled (or being handled)\r\n");
Michael J. Spencer 1:f5ac63519541 132 close();
Michael J. Spencer 1:f5ac63519541 133 }
Michael J. Spencer 1:f5ac63519541 134
Michael J. Spencer 1:f5ac63519541 135 void HTTPRequestDispatcher::close() //Close socket and destroy data
Michael J. Spencer 1:f5ac63519541 136 {
Michael J. Spencer 1:f5ac63519541 137 if(m_closed)
Michael J. Spencer 1:f5ac63519541 138 return;
Michael J. Spencer 1:f5ac63519541 139 m_closed = true; //Prevent recursive calling or calling on an object being destructed by someone else
Michael J. Spencer 1:f5ac63519541 140 m_watchdog.detach();
Michael J. Spencer 1:f5ac63519541 141 if(m_pTCPSocket) //m_pTCPSocket Should only be destroyed if ownership not passed to an handler
Michael J. Spencer 1:f5ac63519541 142 {
Michael J. Spencer 1:f5ac63519541 143 m_pTCPSocket->resetOnEvent();
Michael J. Spencer 1:f5ac63519541 144 m_pTCPSocket->close();
Michael J. Spencer 1:f5ac63519541 145 delete m_pTCPSocket; //This fn might have been called by this socket (through an event), so DO NOT DESTROY IT HERE
Michael J. Spencer 1:f5ac63519541 146 }
Michael J. Spencer 1:f5ac63519541 147 NetService::close();
Michael J. Spencer 1:f5ac63519541 148 }
Michael J. Spencer 1:f5ac63519541 149
Michael J. Spencer 1:f5ac63519541 150
Michael J. Spencer 1:f5ac63519541 151 void HTTPRequestDispatcher::onTimeout() //Connection has timed out
Michael J. Spencer 1:f5ac63519541 152 {
Michael J. Spencer 1:f5ac63519541 153 close();
Michael J. Spencer 1:f5ac63519541 154 }
Michael J. Spencer 1:f5ac63519541 155
Michael J. Spencer 1:f5ac63519541 156 bool HTTPRequestDispatcher::getRequest(string* path, string* meth)
Michael J. Spencer 1:f5ac63519541 157 {
Michael J. Spencer 1:f5ac63519541 158 char req[128];
Michael J. Spencer 1:f5ac63519541 159 char c_path[128];
Michael J. Spencer 1:f5ac63519541 160 char c_meth[128];
Michael J. Spencer 1:f5ac63519541 161 const int maxLen = 128;
Michael J. Spencer 1:f5ac63519541 162 char* p = req;
Michael J. Spencer 1:f5ac63519541 163 //Read Line
Michael J. Spencer 1:f5ac63519541 164 int ret;
Michael J. Spencer 1:f5ac63519541 165 int len = 0;
Michael J. Spencer 1:f5ac63519541 166 for(int i = 0; i < maxLen - 1; i++)
Michael J. Spencer 1:f5ac63519541 167 {
Michael J. Spencer 1:f5ac63519541 168 ret = m_pTCPSocket->recv(p, 1);
Michael J. Spencer 1:f5ac63519541 169 if(!ret)
Michael J. Spencer 1:f5ac63519541 170 {
Michael J. Spencer 1:f5ac63519541 171 break;
Michael J. Spencer 1:f5ac63519541 172 }
Michael J. Spencer 1:f5ac63519541 173 if( (len > 1) && *(p-1)=='\r' && *p=='\n' )
Michael J. Spencer 1:f5ac63519541 174 {
Michael J. Spencer 1:f5ac63519541 175 p--;
Michael J. Spencer 1:f5ac63519541 176 len-=2;
Michael J. Spencer 1:f5ac63519541 177 break;
Michael J. Spencer 1:f5ac63519541 178 }
Michael J. Spencer 1:f5ac63519541 179 else if( *p=='\n' )
Michael J. Spencer 1:f5ac63519541 180 {
Michael J. Spencer 1:f5ac63519541 181 len--;
Michael J. Spencer 1:f5ac63519541 182 break;
Michael J. Spencer 1:f5ac63519541 183 }
Michael J. Spencer 1:f5ac63519541 184 p++;
Michael J. Spencer 1:f5ac63519541 185 len++;
Michael J. Spencer 1:f5ac63519541 186 }
Michael J. Spencer 1:f5ac63519541 187 *p = 0;
Michael J. Spencer 1:f5ac63519541 188
Michael J. Spencer 1:f5ac63519541 189 DBG("Parsing request : %s\r\n", req);
Michael J. Spencer 1:f5ac63519541 190
Michael J. Spencer 1:f5ac63519541 191 ret = sscanf(req, "%s %s HTTP/%*d.%*d", c_meth, c_path);
Michael J. Spencer 1:f5ac63519541 192 if(ret !=2)
Michael J. Spencer 1:f5ac63519541 193 return false;
Michael J. Spencer 1:f5ac63519541 194
Michael J. Spencer 1:f5ac63519541 195 *meth = string(c_meth);
Michael J. Spencer 1:f5ac63519541 196 // NEW CODE (old code removed):
Michael J. Spencer 1:f5ac63519541 197 *path = string(c_path);
Michael J. Spencer 1:f5ac63519541 198 return true;
Michael J. Spencer 1:f5ac63519541 199 }
Michael J. Spencer 1:f5ac63519541 200
Michael J. Spencer 1:f5ac63519541 201
Michael J. Spencer 1:f5ac63519541 202
Michael J. Spencer 1:f5ac63519541 203 void HTTPRequestDispatcher::onTCPSocketEvent(TCPSocketEvent e)
Michael J. Spencer 1:f5ac63519541 204 {
Michael J. Spencer 1:f5ac63519541 205
Michael J. Spencer 1:f5ac63519541 206 DBG("\r\nEvent %d\r\n", e);
Michael J. Spencer 1:f5ac63519541 207
Michael J. Spencer 1:f5ac63519541 208 if(m_closed)
Michael J. Spencer 1:f5ac63519541 209 {
Michael J. Spencer 1:f5ac63519541 210 DBG("\r\nWARN: Discarded\r\n");
Michael J. Spencer 1:f5ac63519541 211 return;
Michael J. Spencer 1:f5ac63519541 212 }
Michael J. Spencer 1:f5ac63519541 213
Michael J. Spencer 1:f5ac63519541 214 switch(e)
Michael J. Spencer 1:f5ac63519541 215 {
Michael J. Spencer 1:f5ac63519541 216 case TCPSOCKET_READABLE:
Michael J. Spencer 1:f5ac63519541 217 m_watchdog.detach();
Michael J. Spencer 1:f5ac63519541 218 m_pTCPSocket->resetOnEvent();
Michael J. Spencer 1:f5ac63519541 219 //Req arrived, dispatch :
Michael J. Spencer 1:f5ac63519541 220 dispatchRequest();
Michael J. Spencer 1:f5ac63519541 221 break;
Michael J. Spencer 1:f5ac63519541 222 case TCPSOCKET_CONTIMEOUT:
Michael J. Spencer 1:f5ac63519541 223 case TCPSOCKET_CONRST:
Michael J. Spencer 1:f5ac63519541 224 case TCPSOCKET_CONABRT:
Michael J. Spencer 1:f5ac63519541 225 case TCPSOCKET_ERROR:
Michael J. Spencer 1:f5ac63519541 226 case TCPSOCKET_DISCONNECTED:
Michael J. Spencer 1:f5ac63519541 227 close();
Michael J. Spencer 1:f5ac63519541 228 break;
Michael J. Spencer 1:f5ac63519541 229 }
Michael J. Spencer 1:f5ac63519541 230
Michael J. Spencer 1:f5ac63519541 231 }