AmpereMeter - Example self-announcing webserver which controls …

Users » dirkx » Code » AmpereMeter

Dirk-Willem van Gulik (NXP/mbed) / Mbed 2 deprecated AmpereMeter

Example self-announcing webserver which controls a servo through a smallHTML userinterface.

api/TCPSocket.cpp@0:a259777c45a3, 2010-08-14 (annotated)

Committer:: dirkx
Date:: Sat Aug 14 15:56:01 2010 +0000
Revision:: 0:a259777c45a3

Who changed what in which revision?

User	Revision	Line number	New contents of line
dirkx	0:a259777c45a3	1
dirkx	0:a259777c45a3	2	/*
dirkx	0:a259777c45a3	3	Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
dirkx	0:a259777c45a3	4
dirkx	0:a259777c45a3	5	Permission is hereby granted, free of charge, to any person obtaining a copy
dirkx	0:a259777c45a3	6	of this software and associated documentation files (the "Software"), to deal
dirkx	0:a259777c45a3	7	in the Software without restriction, including without limitation the rights
dirkx	0:a259777c45a3	8	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
dirkx	0:a259777c45a3	9	copies of the Software, and to permit persons to whom the Software is
dirkx	0:a259777c45a3	10	furnished to do so, subject to the following conditions:
dirkx	0:a259777c45a3	11
dirkx	0:a259777c45a3	12	The above copyright notice and this permission notice shall be included in
dirkx	0:a259777c45a3	13	all copies or substantial portions of the Software.
dirkx	0:a259777c45a3	14
dirkx	0:a259777c45a3	15	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
dirkx	0:a259777c45a3	16	IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
dirkx	0:a259777c45a3	17	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
dirkx	0:a259777c45a3	18	AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
dirkx	0:a259777c45a3	19	LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
dirkx	0:a259777c45a3	20	OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
dirkx	0:a259777c45a3	21	THE SOFTWARE.
dirkx	0:a259777c45a3	22	*/
dirkx	0:a259777c45a3	23
dirkx	0:a259777c45a3	24	#include "TCPSocket.h"
dirkx	0:a259777c45a3	25
dirkx	0:a259777c45a3	26	TCPSocket::TCPSocket() : m_pNetTcpSocket(NULL), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL)
dirkx	0:a259777c45a3	27	{
dirkx	0:a259777c45a3	28
dirkx	0:a259777c45a3	29	}
dirkx	0:a259777c45a3	30
dirkx	0:a259777c45a3	31	TCPSocket::TCPSocket(NetTcpSocket* pNetTcpSocket) : m_pNetTcpSocket(pNetTcpSocket), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL)
dirkx	0:a259777c45a3	32	{
dirkx	0:a259777c45a3	33	m_pNetTcpSocket->setOnEvent(this, &TCPSocket::onNetTcpSocketEvent);
dirkx	0:a259777c45a3	34	}
dirkx	0:a259777c45a3	35
dirkx	0:a259777c45a3	36	TCPSocket::~TCPSocket() //close()
dirkx	0:a259777c45a3	37	{
dirkx	0:a259777c45a3	38	close();
dirkx	0:a259777c45a3	39	}
dirkx	0:a259777c45a3	40
dirkx	0:a259777c45a3	41	TCPSocketErr TCPSocket::bind(const Host& me)
dirkx	0:a259777c45a3	42	{
dirkx	0:a259777c45a3	43	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	44	if(tcpSocketErr)
dirkx	0:a259777c45a3	45	return tcpSocketErr;
dirkx	0:a259777c45a3	46	return (TCPSocketErr) m_pNetTcpSocket->bind(me);
dirkx	0:a259777c45a3	47	}
dirkx	0:a259777c45a3	48
dirkx	0:a259777c45a3	49	TCPSocketErr TCPSocket::listen()
dirkx	0:a259777c45a3	50	{
dirkx	0:a259777c45a3	51	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	52	if(tcpSocketErr)
dirkx	0:a259777c45a3	53	return tcpSocketErr;
dirkx	0:a259777c45a3	54	return (TCPSocketErr) m_pNetTcpSocket->listen();
dirkx	0:a259777c45a3	55	}
dirkx	0:a259777c45a3	56
dirkx	0:a259777c45a3	57	TCPSocketErr TCPSocket::connect(const Host& host)
dirkx	0:a259777c45a3	58	{
dirkx	0:a259777c45a3	59	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	60	if(tcpSocketErr)
dirkx	0:a259777c45a3	61	return tcpSocketErr;
dirkx	0:a259777c45a3	62	return (TCPSocketErr) m_pNetTcpSocket->connect(host);
dirkx	0:a259777c45a3	63	}
dirkx	0:a259777c45a3	64
dirkx	0:a259777c45a3	65	TCPSocketErr TCPSocket::accept(Host* pClient, TCPSocket** ppNewTCPSocket)
dirkx	0:a259777c45a3	66	{
dirkx	0:a259777c45a3	67	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	68	if(tcpSocketErr)
dirkx	0:a259777c45a3	69	return tcpSocketErr;
dirkx	0:a259777c45a3	70	NetTcpSocket* pNewNetTcpSocket;
dirkx	0:a259777c45a3	71	tcpSocketErr = (TCPSocketErr) m_pNetTcpSocket->accept(pClient, &pNewNetTcpSocket);
dirkx	0:a259777c45a3	72	if(pNewNetTcpSocket)
dirkx	0:a259777c45a3	73	*ppNewTCPSocket = new TCPSocket(pNewNetTcpSocket);
dirkx	0:a259777c45a3	74	return tcpSocketErr;
dirkx	0:a259777c45a3	75	}
dirkx	0:a259777c45a3	76
dirkx	0:a259777c45a3	77	int /if < 0 : TCPSocketErr/ TCPSocket::send(const char* buf, int len)
dirkx	0:a259777c45a3	78	{
dirkx	0:a259777c45a3	79	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	80	if(tcpSocketErr)
dirkx	0:a259777c45a3	81	return tcpSocketErr;
dirkx	0:a259777c45a3	82	return m_pNetTcpSocket->send(buf, len);
dirkx	0:a259777c45a3	83	}
dirkx	0:a259777c45a3	84
dirkx	0:a259777c45a3	85	int /if < 0 : TCPSocketErr/ TCPSocket::recv(char* buf, int len)
dirkx	0:a259777c45a3	86	{
dirkx	0:a259777c45a3	87	TCPSocketErr tcpSocketErr = checkInst();
dirkx	0:a259777c45a3	88	if(tcpSocketErr)
dirkx	0:a259777c45a3	89	return tcpSocketErr;
dirkx	0:a259777c45a3	90	return m_pNetTcpSocket->recv(buf, len);
dirkx	0:a259777c45a3	91	}
dirkx	0:a259777c45a3	92
dirkx	0:a259777c45a3	93	TCPSocketErr TCPSocket::close()
dirkx	0:a259777c45a3	94	{
dirkx	0:a259777c45a3	95	if(!m_pNetTcpSocket)
dirkx	0:a259777c45a3	96	return TCPSOCKET_SETUP;
dirkx	0:a259777c45a3	97	m_pNetTcpSocket->resetOnEvent();
dirkx	0:a259777c45a3	98	TCPSocketErr tcpSocketErr = (TCPSocketErr) m_pNetTcpSocket->close(); //Close (can already be closed)
dirkx	0:a259777c45a3	99	Net::releaseTcpSocket(m_pNetTcpSocket); //And release it so it can be freed when properly removed
dirkx	0:a259777c45a3	100	m_pNetTcpSocket = NULL;
dirkx	0:a259777c45a3	101	return tcpSocketErr;
dirkx	0:a259777c45a3	102	}
dirkx	0:a259777c45a3	103
dirkx	0:a259777c45a3	104	//Callbacks
dirkx	0:a259777c45a3	105	void TCPSocket::setOnEvent( void (*pMethod)(TCPSocketEvent) )
dirkx	0:a259777c45a3	106	{
dirkx	0:a259777c45a3	107	m_pCb = pMethod;
dirkx	0:a259777c45a3	108	}
dirkx	0:a259777c45a3	109
dirkx	0:a259777c45a3	110	#if 0 //For info only
dirkx	0:a259777c45a3	111	template<class T>
dirkx	0:a259777c45a3	112	void TCPSocket::setOnEvent( T* pItem, void (T::*pMethod)(TCPSocketEvent) )
dirkx	0:a259777c45a3	113	{
dirkx	0:a259777c45a3	114	m_pCbItem = (CDummy*) pItem;
dirkx	0:a259777c45a3	115	m_pCbMeth = (void (CDummy::*)(TCPSocketEvent)) pMethod;
dirkx	0:a259777c45a3	116	}
dirkx	0:a259777c45a3	117	#endif
dirkx	0:a259777c45a3	118
dirkx	0:a259777c45a3	119	void TCPSocket::resetOnEvent() //Disable callback
dirkx	0:a259777c45a3	120	{
dirkx	0:a259777c45a3	121	m_pCb = NULL;
dirkx	0:a259777c45a3	122	m_pCbItem = NULL;
dirkx	0:a259777c45a3	123	m_pCbMeth = NULL;
dirkx	0:a259777c45a3	124	}
dirkx	0:a259777c45a3	125
dirkx	0:a259777c45a3	126	void TCPSocket::onNetTcpSocketEvent(NetTcpSocketEvent e)
dirkx	0:a259777c45a3	127	{
dirkx	0:a259777c45a3	128	if(m_pCbItem && m_pCbMeth)
dirkx	0:a259777c45a3	129	(m_pCbItem->*m_pCbMeth)((TCPSocketEvent) e);
dirkx	0:a259777c45a3	130	else if(m_pCb)
dirkx	0:a259777c45a3	131	m_pCb((TCPSocketEvent) e);
dirkx	0:a259777c45a3	132	}
dirkx	0:a259777c45a3	133
dirkx	0:a259777c45a3	134	TCPSocketErr TCPSocket::checkInst()
dirkx	0:a259777c45a3	135	{
dirkx	0:a259777c45a3	136	if(!m_pNetTcpSocket)
dirkx	0:a259777c45a3	137	{
dirkx	0:a259777c45a3	138	m_pNetTcpSocket = Net::tcpSocket();
dirkx	0:a259777c45a3	139	if(!m_pNetTcpSocket)
dirkx	0:a259777c45a3	140	{
dirkx	0:a259777c45a3	141	return TCPSOCKET_IF; //Interface did not return a socket (usually because a default interface does not exist)
dirkx	0:a259777c45a3	142	}
dirkx	0:a259777c45a3	143	m_pNetTcpSocket->setOnEvent(this, &TCPSocket::onNetTcpSocketEvent);
dirkx	0:a259777c45a3	144	}
dirkx	0:a259777c45a3	145	return TCPSOCKET_OK;
dirkx	0:a259777c45a3	146	}

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	14 Aug 2010
Imports:	49
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	2
Followers:	1

api/TCPSocket.cpp@0:a259777c45a3, 2010-08-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning