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.

if/net/net.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 "net.h"
dirkx	0:a259777c45a3	25
dirkx	0:a259777c45a3	26	//#define __DEBUG
dirkx	0:a259777c45a3	27	#include "dbg/dbg.h"
dirkx	0:a259777c45a3	28
dirkx	0:a259777c45a3	29	Net::Net() : m_defaultIf(NULL), m_lpIf(), m_lpNetTcpSocket(), m_lpNetUdpSocket()
dirkx	0:a259777c45a3	30	{
dirkx	0:a259777c45a3	31
dirkx	0:a259777c45a3	32	}
dirkx	0:a259777c45a3	33
dirkx	0:a259777c45a3	34	Net::~Net()
dirkx	0:a259777c45a3	35	{
dirkx	0:a259777c45a3	36
dirkx	0:a259777c45a3	37	}
dirkx	0:a259777c45a3	38
dirkx	0:a259777c45a3	39
dirkx	0:a259777c45a3	40	void Net::poll()
dirkx	0:a259777c45a3	41	{
dirkx	0:a259777c45a3	42	//DBG("\r\nNet : Services polling\r\n");
dirkx	0:a259777c45a3	43
dirkx	0:a259777c45a3	44	//Poll Services
dirkx	0:a259777c45a3	45	NetService::servicesPoll();
dirkx	0:a259777c45a3	46
dirkx	0:a259777c45a3	47	//DBG("\r\nNet : Interfaces polling\r\n");
dirkx	0:a259777c45a3	48
dirkx	0:a259777c45a3	49	//Poll Interfaces
dirkx	0:a259777c45a3	50	list<NetIf*>::iterator pIfIt;
dirkx	0:a259777c45a3	51
dirkx	0:a259777c45a3	52	for ( pIfIt = net().m_lpIf.begin() ; pIfIt != net().m_lpIf.end(); pIfIt++ )
dirkx	0:a259777c45a3	53	{
dirkx	0:a259777c45a3	54	(*pIfIt)->poll();
dirkx	0:a259777c45a3	55	}
dirkx	0:a259777c45a3	56
dirkx	0:a259777c45a3	57	//DBG("\r\nNet : Sockets polling\r\n");
dirkx	0:a259777c45a3	58
dirkx	0:a259777c45a3	59	//Poll Tcp Sockets
dirkx	0:a259777c45a3	60	list<NetTcpSocket*>::iterator pNetTcpSocketIt;
dirkx	0:a259777c45a3	61
dirkx	0:a259777c45a3	62	for ( pNetTcpSocketIt = net().m_lpNetTcpSocket.begin() ; pNetTcpSocketIt != net().m_lpNetTcpSocket.end(); )
dirkx	0:a259777c45a3	63	{
dirkx	0:a259777c45a3	64	(*pNetTcpSocketIt)->poll();
dirkx	0:a259777c45a3	65
dirkx	0:a259777c45a3	66	if( (pNetTcpSocketIt)->m_closed && !((pNetTcpSocketIt)->m_refs) )
dirkx	0:a259777c45a3	67	{
dirkx	0:a259777c45a3	68	(*pNetTcpSocketIt)->m_removed = true;
dirkx	0:a259777c45a3	69	delete (*pNetTcpSocketIt);
dirkx	0:a259777c45a3	70	(*pNetTcpSocketIt) = NULL;
dirkx	0:a259777c45a3	71	pNetTcpSocketIt = net().m_lpNetTcpSocket.erase(pNetTcpSocketIt);
dirkx	0:a259777c45a3	72	}
dirkx	0:a259777c45a3	73	else
dirkx	0:a259777c45a3	74	{
dirkx	0:a259777c45a3	75	pNetTcpSocketIt++;
dirkx	0:a259777c45a3	76	}
dirkx	0:a259777c45a3	77	}
dirkx	0:a259777c45a3	78
dirkx	0:a259777c45a3	79	//Poll Udp Sockets
dirkx	0:a259777c45a3	80	list<NetUdpSocket*>::iterator pNetUdpSocketIt;
dirkx	0:a259777c45a3	81
dirkx	0:a259777c45a3	82	for ( pNetUdpSocketIt = net().m_lpNetUdpSocket.begin() ; pNetUdpSocketIt != net().m_lpNetUdpSocket.end(); )
dirkx	0:a259777c45a3	83	{
dirkx	0:a259777c45a3	84	(*pNetUdpSocketIt)->poll();
dirkx	0:a259777c45a3	85
dirkx	0:a259777c45a3	86	if( (pNetUdpSocketIt)->m_closed && !((pNetUdpSocketIt)->m_refs) )
dirkx	0:a259777c45a3	87	{
dirkx	0:a259777c45a3	88	(*pNetUdpSocketIt)->m_removed = true;
dirkx	0:a259777c45a3	89	delete (*pNetUdpSocketIt);
dirkx	0:a259777c45a3	90	(*pNetUdpSocketIt) = NULL;
dirkx	0:a259777c45a3	91	pNetUdpSocketIt = net().m_lpNetUdpSocket.erase(pNetUdpSocketIt);
dirkx	0:a259777c45a3	92	}
dirkx	0:a259777c45a3	93	else
dirkx	0:a259777c45a3	94	{
dirkx	0:a259777c45a3	95	pNetUdpSocketIt++;
dirkx	0:a259777c45a3	96	}
dirkx	0:a259777c45a3	97	}
dirkx	0:a259777c45a3	98
dirkx	0:a259777c45a3	99
dirkx	0:a259777c45a3	100	}
dirkx	0:a259777c45a3	101
dirkx	0:a259777c45a3	102	NetTcpSocket* Net::tcpSocket(NetIf& netif) {
dirkx	0:a259777c45a3	103	NetTcpSocket* pNetTcpSocket = netif.tcpSocket();
dirkx	0:a259777c45a3	104	pNetTcpSocket->m_refs++;
dirkx	0:a259777c45a3	105	return pNetTcpSocket;
dirkx	0:a259777c45a3	106	}
dirkx	0:a259777c45a3	107
dirkx	0:a259777c45a3	108	NetTcpSocket* Net::tcpSocket() { //NetTcpSocket on default if
dirkx	0:a259777c45a3	109	if ( net().m_defaultIf == NULL )
dirkx	0:a259777c45a3	110	return NULL;
dirkx	0:a259777c45a3	111	NetTcpSocket* pNetTcpSocket = net().m_defaultIf->tcpSocket();
dirkx	0:a259777c45a3	112	pNetTcpSocket->m_refs++;
dirkx	0:a259777c45a3	113	return pNetTcpSocket;
dirkx	0:a259777c45a3	114	}
dirkx	0:a259777c45a3	115
dirkx	0:a259777c45a3	116	void Net::releaseTcpSocket(NetTcpSocket* pNetTcpSocket)
dirkx	0:a259777c45a3	117	{
dirkx	0:a259777c45a3	118	pNetTcpSocket->m_refs--;
dirkx	0:a259777c45a3	119	if(!pNetTcpSocket->m_closed && !pNetTcpSocket->m_refs)
dirkx	0:a259777c45a3	120	pNetTcpSocket->close();
dirkx	0:a259777c45a3	121	}
dirkx	0:a259777c45a3	122
dirkx	0:a259777c45a3	123	NetUdpSocket* Net::udpSocket(NetIf& netif) {
dirkx	0:a259777c45a3	124	NetUdpSocket* pNetUdpSocket = netif.udpSocket();
dirkx	0:a259777c45a3	125	pNetUdpSocket->m_refs++;
dirkx	0:a259777c45a3	126	return pNetUdpSocket;
dirkx	0:a259777c45a3	127	}
dirkx	0:a259777c45a3	128
dirkx	0:a259777c45a3	129	NetUdpSocket* Net::udpSocket() { //NetTcpSocket on default if
dirkx	0:a259777c45a3	130	if ( net().m_defaultIf == NULL )
dirkx	0:a259777c45a3	131	return NULL;
dirkx	0:a259777c45a3	132	NetUdpSocket* pNetUdpSocket = net().m_defaultIf->udpSocket();
dirkx	0:a259777c45a3	133	pNetUdpSocket->m_refs++;
dirkx	0:a259777c45a3	134	return pNetUdpSocket;
dirkx	0:a259777c45a3	135	}
dirkx	0:a259777c45a3	136
dirkx	0:a259777c45a3	137	void Net::releaseUdpSocket(NetUdpSocket* pNetUdpSocket)
dirkx	0:a259777c45a3	138	{
dirkx	0:a259777c45a3	139	pNetUdpSocket->m_refs--;
dirkx	0:a259777c45a3	140	if(!pNetUdpSocket->m_closed && !pNetUdpSocket->m_refs)
dirkx	0:a259777c45a3	141	pNetUdpSocket->close();
dirkx	0:a259777c45a3	142	}
dirkx	0:a259777c45a3	143
dirkx	0:a259777c45a3	144	NetDnsRequest* Net::dnsRequest(const char* hostname, NetIf& netif) {
dirkx	0:a259777c45a3	145	return netif.dnsRequest(hostname);
dirkx	0:a259777c45a3	146	}
dirkx	0:a259777c45a3	147
dirkx	0:a259777c45a3	148	NetDnsRequest* Net::dnsRequest(const char* hostname) { //Create a new NetDnsRequest object from default if
dirkx	0:a259777c45a3	149	if ( net().m_defaultIf == NULL )
dirkx	0:a259777c45a3	150	return NULL;
dirkx	0:a259777c45a3	151	return net().m_defaultIf->dnsRequest(hostname);
dirkx	0:a259777c45a3	152	}
dirkx	0:a259777c45a3	153
dirkx	0:a259777c45a3	154	NetDnsRequest* Net::dnsRequest(Host* pHost, NetIf& netif)
dirkx	0:a259777c45a3	155	{
dirkx	0:a259777c45a3	156	return netif.dnsRequest(pHost);
dirkx	0:a259777c45a3	157	}
dirkx	0:a259777c45a3	158
dirkx	0:a259777c45a3	159	NetDnsRequest* Net::dnsRequest(Host* pHost) //Creats a new NetDnsRequest object from default if
dirkx	0:a259777c45a3	160	{
dirkx	0:a259777c45a3	161	if ( net().m_defaultIf == NULL )
dirkx	0:a259777c45a3	162	return NULL;
dirkx	0:a259777c45a3	163	return net().m_defaultIf->dnsRequest(pHost);
dirkx	0:a259777c45a3	164	}
dirkx	0:a259777c45a3	165
dirkx	0:a259777c45a3	166	void Net::setDefaultIf(NetIf& netif) {
dirkx	0:a259777c45a3	167	net().m_defaultIf = &netif;
dirkx	0:a259777c45a3	168	}
dirkx	0:a259777c45a3	169
dirkx	0:a259777c45a3	170	void Net::setDefaultIf(NetIf* pIf)
dirkx	0:a259777c45a3	171	{
dirkx	0:a259777c45a3	172	net().m_defaultIf = pIf;
dirkx	0:a259777c45a3	173	}
dirkx	0:a259777c45a3	174
dirkx	0:a259777c45a3	175	NetIf* Net::getDefaultIf() {
dirkx	0:a259777c45a3	176	return net().m_defaultIf;
dirkx	0:a259777c45a3	177	}
dirkx	0:a259777c45a3	178
dirkx	0:a259777c45a3	179	void Net::registerIf(NetIf* pIf)
dirkx	0:a259777c45a3	180	{
dirkx	0:a259777c45a3	181	net().m_lpIf.push_back(pIf);
dirkx	0:a259777c45a3	182	}
dirkx	0:a259777c45a3	183
dirkx	0:a259777c45a3	184	void Net::unregisterIf(NetIf* pIf)
dirkx	0:a259777c45a3	185	{
dirkx	0:a259777c45a3	186	if( net().m_defaultIf == pIf )
dirkx	0:a259777c45a3	187	net().m_defaultIf = NULL;
dirkx	0:a259777c45a3	188	net().m_lpIf.remove(pIf);
dirkx	0:a259777c45a3	189	}
dirkx	0:a259777c45a3	190
dirkx	0:a259777c45a3	191	void Net::registerNetTcpSocket(NetTcpSocket* pNetTcpSocket)
dirkx	0:a259777c45a3	192	{
dirkx	0:a259777c45a3	193	net().m_lpNetTcpSocket.push_back(pNetTcpSocket);
dirkx	0:a259777c45a3	194	DBG("\r\nNetTcpSocket [ + %p ] %d\r\n", (void*)pNetTcpSocket, net().m_lpNetTcpSocket.size());
dirkx	0:a259777c45a3	195	}
dirkx	0:a259777c45a3	196
dirkx	0:a259777c45a3	197	void Net::unregisterNetTcpSocket(NetTcpSocket* pNetTcpSocket)
dirkx	0:a259777c45a3	198	{
dirkx	0:a259777c45a3	199	DBG("\r\nNetTcpSocket [ - %p ] %d\r\n", (void*)pNetTcpSocket, net().m_lpNetTcpSocket.size() - 1);
dirkx	0:a259777c45a3	200	if(!pNetTcpSocket->m_removed)
dirkx	0:a259777c45a3	201	net().m_lpNetTcpSocket.remove(pNetTcpSocket);
dirkx	0:a259777c45a3	202	}
dirkx	0:a259777c45a3	203
dirkx	0:a259777c45a3	204	void Net::registerNetUdpSocket(NetUdpSocket* pNetUdpSocket)
dirkx	0:a259777c45a3	205	{
dirkx	0:a259777c45a3	206	net().m_lpNetUdpSocket.push_back(pNetUdpSocket);
dirkx	0:a259777c45a3	207	DBG("\r\nNetUdpSocket [ + %p ] %d\r\n", (void*)pNetUdpSocket, net().m_lpNetUdpSocket.size());
dirkx	0:a259777c45a3	208	}
dirkx	0:a259777c45a3	209
dirkx	0:a259777c45a3	210	void Net::unregisterNetUdpSocket(NetUdpSocket* pNetUdpSocket)
dirkx	0:a259777c45a3	211	{
dirkx	0:a259777c45a3	212	DBG("\r\nNetUdpSocket [ - %p ] %d\r\n", (void*)pNetUdpSocket, net().m_lpNetUdpSocket.size() - 1);
dirkx	0:a259777c45a3	213	if(!pNetUdpSocket->m_removed)
dirkx	0:a259777c45a3	214	net().m_lpNetUdpSocket.remove(pNetUdpSocket);
dirkx	0:a259777c45a3	215	}
dirkx	0:a259777c45a3	216
dirkx	0:a259777c45a3	217	Net& Net::net()
dirkx	0:a259777c45a3	218	{
dirkx	0:a259777c45a3	219	static Net* pInst = new Net(); //Called only once
dirkx	0:a259777c45a3	220	return *pInst;
dirkx	0:a259777c45a3	221	}

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

if/net/net.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