server2 - This programme Sets a web server using light weig…

Users » pmr1 » Code » server2

This programme Sets a web server using light weigh ip (using Donatien Garnier's server code) which reads a voltage and saves it value in an htm file to be displayed on local page. Server 2 2nd edition Two issues here 1 ) the compiler throws a warning about assignment in RPCHandler.cpp and 2) the local .htm file created on the mbed flash memory is always date stamped with the default date 01/01/2008 11:00

Dependencies: EthernetNetIf NTPClient_NetServices mbed

server/HTTPRequestDispatcher.cpp@0:03e1db2fe866, 2010-08-08 (annotated)

Committer:: pmr1
Date:: Sun Aug 08 22:00:39 2010 +0000
Revision:: 0:03e1db2fe866

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	08 Aug 2010
Imports:	37
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	3
Followers:	1

server/HTTPRequestDispatcher.cpp@0:03e1db2fe866, 2010-08-08 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning