StrippedDownNetServices - This library is stripped down version of NetServi…

Users » idinor » Code » StrippedDownNetServices

idinor Launcher / StrippedDownNetServices

This library is stripped down version of NetServices library. HTTP server and client function is NOT supported.

core/net.cpp@0:dcf3c92487ca, 2011-07-20 (annotated)

Committer:: idinor
Date:: Wed Jul 20 11:45:39 2011 +0000
Revision:: 0:dcf3c92487ca

Who changed what in which revision?

User	Revision	Line number	New contents of line
idinor	0:dcf3c92487ca	1
idinor	0:dcf3c92487ca	2	/*
idinor	0:dcf3c92487ca	3	Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
idinor	0:dcf3c92487ca	4
idinor	0:dcf3c92487ca	5	Permission is hereby granted, free of charge, to any person obtaining a copy
idinor	0:dcf3c92487ca	6	of this software and associated documentation files (the "Software"), to deal
idinor	0:dcf3c92487ca	7	in the Software without restriction, including without limitation the rights
idinor	0:dcf3c92487ca	8	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
idinor	0:dcf3c92487ca	9	copies of the Software, and to permit persons to whom the Software is
idinor	0:dcf3c92487ca	10	furnished to do so, subject to the following conditions:
idinor	0:dcf3c92487ca	11
idinor	0:dcf3c92487ca	12	The above copyright notice and this permission notice shall be included in
idinor	0:dcf3c92487ca	13	all copies or substantial portions of the Software.
idinor	0:dcf3c92487ca	14
idinor	0:dcf3c92487ca	15	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
idinor	0:dcf3c92487ca	16	IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
idinor	0:dcf3c92487ca	17	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
idinor	0:dcf3c92487ca	18	AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
idinor	0:dcf3c92487ca	19	LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
idinor	0:dcf3c92487ca	20	OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
idinor	0:dcf3c92487ca	21	THE SOFTWARE.
idinor	0:dcf3c92487ca	22	*/
idinor	0:dcf3c92487ca	23
idinor	0:dcf3c92487ca	24	#include "net.h"
idinor	0:dcf3c92487ca	25
idinor	0:dcf3c92487ca	26	#include "host.h"
idinor	0:dcf3c92487ca	27	#include "ipaddr.h"
idinor	0:dcf3c92487ca	28	#include "netservice.h"
idinor	0:dcf3c92487ca	29	#include "if/net/netif.h"
idinor	0:dcf3c92487ca	30	#include "if/net/nettcpsocket.h"
idinor	0:dcf3c92487ca	31	#include "if/net/netudpsocket.h"
idinor	0:dcf3c92487ca	32	#include "if/net/netdnsrequest.h"
idinor	0:dcf3c92487ca	33
idinor	0:dcf3c92487ca	34	//#define __DEBUG
idinor	0:dcf3c92487ca	35	#include "dbg/dbg.h"
idinor	0:dcf3c92487ca	36
idinor	0:dcf3c92487ca	37	Net::Net() : m_defaultIf(NULL), m_lpIf(), m_lpNetTcpSocket(), m_lpNetUdpSocket()
idinor	0:dcf3c92487ca	38	{
idinor	0:dcf3c92487ca	39
idinor	0:dcf3c92487ca	40	}
idinor	0:dcf3c92487ca	41
idinor	0:dcf3c92487ca	42	Net::~Net()
idinor	0:dcf3c92487ca	43	{
idinor	0:dcf3c92487ca	44
idinor	0:dcf3c92487ca	45	}
idinor	0:dcf3c92487ca	46
idinor	0:dcf3c92487ca	47
idinor	0:dcf3c92487ca	48	void Net::poll()
idinor	0:dcf3c92487ca	49	{
idinor	0:dcf3c92487ca	50	//DBG("\r\nNet : Services polling\r\n");
idinor	0:dcf3c92487ca	51
idinor	0:dcf3c92487ca	52	//Poll Services
idinor	0:dcf3c92487ca	53	NetService::servicesPoll();
idinor	0:dcf3c92487ca	54
idinor	0:dcf3c92487ca	55	//DBG("\r\nNet : Interfaces polling\r\n");
idinor	0:dcf3c92487ca	56
idinor	0:dcf3c92487ca	57	//Poll Interfaces
idinor	0:dcf3c92487ca	58	list<NetIf*>::iterator pIfIt;
idinor	0:dcf3c92487ca	59
idinor	0:dcf3c92487ca	60	for ( pIfIt = net().m_lpIf.begin() ; pIfIt != net().m_lpIf.end(); pIfIt++ )
idinor	0:dcf3c92487ca	61	{
idinor	0:dcf3c92487ca	62	(*pIfIt)->poll();
idinor	0:dcf3c92487ca	63	}
idinor	0:dcf3c92487ca	64
idinor	0:dcf3c92487ca	65	//DBG("\r\nNet : Sockets polling\r\n");
idinor	0:dcf3c92487ca	66
idinor	0:dcf3c92487ca	67	//Poll Tcp Sockets
idinor	0:dcf3c92487ca	68	list<NetTcpSocket*>::iterator pNetTcpSocketIt;
idinor	0:dcf3c92487ca	69
idinor	0:dcf3c92487ca	70	for ( pNetTcpSocketIt = net().m_lpNetTcpSocket.begin() ; pNetTcpSocketIt != net().m_lpNetTcpSocket.end(); )
idinor	0:dcf3c92487ca	71	{
idinor	0:dcf3c92487ca	72	(*pNetTcpSocketIt)->poll();
idinor	0:dcf3c92487ca	73
idinor	0:dcf3c92487ca	74	if( (pNetTcpSocketIt)->m_closed && !((pNetTcpSocketIt)->m_refs) )
idinor	0:dcf3c92487ca	75	{
idinor	0:dcf3c92487ca	76	(*pNetTcpSocketIt)->m_removed = true;
idinor	0:dcf3c92487ca	77	delete (*pNetTcpSocketIt);
idinor	0:dcf3c92487ca	78	(*pNetTcpSocketIt) = NULL;
idinor	0:dcf3c92487ca	79	pNetTcpSocketIt = net().m_lpNetTcpSocket.erase(pNetTcpSocketIt);
idinor	0:dcf3c92487ca	80	}
idinor	0:dcf3c92487ca	81	else
idinor	0:dcf3c92487ca	82	{
idinor	0:dcf3c92487ca	83	pNetTcpSocketIt++;
idinor	0:dcf3c92487ca	84	}
idinor	0:dcf3c92487ca	85	}
idinor	0:dcf3c92487ca	86
idinor	0:dcf3c92487ca	87	//Poll Udp Sockets
idinor	0:dcf3c92487ca	88	list<NetUdpSocket*>::iterator pNetUdpSocketIt;
idinor	0:dcf3c92487ca	89
idinor	0:dcf3c92487ca	90	for ( pNetUdpSocketIt = net().m_lpNetUdpSocket.begin() ; pNetUdpSocketIt != net().m_lpNetUdpSocket.end(); )
idinor	0:dcf3c92487ca	91	{
idinor	0:dcf3c92487ca	92	(*pNetUdpSocketIt)->poll();
idinor	0:dcf3c92487ca	93
idinor	0:dcf3c92487ca	94	if( (pNetUdpSocketIt)->m_closed && !((pNetUdpSocketIt)->m_refs) )
idinor	0:dcf3c92487ca	95	{
idinor	0:dcf3c92487ca	96	(*pNetUdpSocketIt)->m_removed = true;
idinor	0:dcf3c92487ca	97	delete (*pNetUdpSocketIt);
idinor	0:dcf3c92487ca	98	(*pNetUdpSocketIt) = NULL;
idinor	0:dcf3c92487ca	99	pNetUdpSocketIt = net().m_lpNetUdpSocket.erase(pNetUdpSocketIt);
idinor	0:dcf3c92487ca	100	}
idinor	0:dcf3c92487ca	101	else
idinor	0:dcf3c92487ca	102	{
idinor	0:dcf3c92487ca	103	pNetUdpSocketIt++;
idinor	0:dcf3c92487ca	104	}
idinor	0:dcf3c92487ca	105	}
idinor	0:dcf3c92487ca	106
idinor	0:dcf3c92487ca	107
idinor	0:dcf3c92487ca	108	}
idinor	0:dcf3c92487ca	109
idinor	0:dcf3c92487ca	110	NetTcpSocket* Net::tcpSocket(NetIf& netif) {
idinor	0:dcf3c92487ca	111	NetTcpSocket* pNetTcpSocket = netif.tcpSocket();
idinor	0:dcf3c92487ca	112	pNetTcpSocket->m_refs++;
idinor	0:dcf3c92487ca	113	return pNetTcpSocket;
idinor	0:dcf3c92487ca	114	}
idinor	0:dcf3c92487ca	115
idinor	0:dcf3c92487ca	116	NetTcpSocket* Net::tcpSocket() { //NetTcpSocket on default if
idinor	0:dcf3c92487ca	117	if ( net().m_defaultIf == NULL )
idinor	0:dcf3c92487ca	118	return NULL;
idinor	0:dcf3c92487ca	119	NetTcpSocket* pNetTcpSocket = net().m_defaultIf->tcpSocket();
idinor	0:dcf3c92487ca	120	pNetTcpSocket->m_refs++;
idinor	0:dcf3c92487ca	121	return pNetTcpSocket;
idinor	0:dcf3c92487ca	122	}
idinor	0:dcf3c92487ca	123
idinor	0:dcf3c92487ca	124	void Net::releaseTcpSocket(NetTcpSocket* pNetTcpSocket)
idinor	0:dcf3c92487ca	125	{
idinor	0:dcf3c92487ca	126	pNetTcpSocket->m_refs--;
idinor	0:dcf3c92487ca	127	if(!pNetTcpSocket->m_closed && !pNetTcpSocket->m_refs)
idinor	0:dcf3c92487ca	128	pNetTcpSocket->close();
idinor	0:dcf3c92487ca	129	}
idinor	0:dcf3c92487ca	130
idinor	0:dcf3c92487ca	131	NetUdpSocket* Net::udpSocket(NetIf& netif) {
idinor	0:dcf3c92487ca	132	NetUdpSocket* pNetUdpSocket = netif.udpSocket();
idinor	0:dcf3c92487ca	133	pNetUdpSocket->m_refs++;
idinor	0:dcf3c92487ca	134	return pNetUdpSocket;
idinor	0:dcf3c92487ca	135	}
idinor	0:dcf3c92487ca	136
idinor	0:dcf3c92487ca	137	NetUdpSocket* Net::udpSocket() { //NetTcpSocket on default if
idinor	0:dcf3c92487ca	138	if ( net().m_defaultIf == NULL )
idinor	0:dcf3c92487ca	139	return NULL;
idinor	0:dcf3c92487ca	140	NetUdpSocket* pNetUdpSocket = net().m_defaultIf->udpSocket();
idinor	0:dcf3c92487ca	141	pNetUdpSocket->m_refs++;
idinor	0:dcf3c92487ca	142	return pNetUdpSocket;
idinor	0:dcf3c92487ca	143	}
idinor	0:dcf3c92487ca	144
idinor	0:dcf3c92487ca	145	void Net::releaseUdpSocket(NetUdpSocket* pNetUdpSocket)
idinor	0:dcf3c92487ca	146	{
idinor	0:dcf3c92487ca	147	pNetUdpSocket->m_refs--;
idinor	0:dcf3c92487ca	148	if(!pNetUdpSocket->m_closed && !pNetUdpSocket->m_refs)
idinor	0:dcf3c92487ca	149	pNetUdpSocket->close();
idinor	0:dcf3c92487ca	150	}
idinor	0:dcf3c92487ca	151
idinor	0:dcf3c92487ca	152	NetDnsRequest* Net::dnsRequest(const char* hostname, NetIf& netif) {
idinor	0:dcf3c92487ca	153	return netif.dnsRequest(hostname);
idinor	0:dcf3c92487ca	154	}
idinor	0:dcf3c92487ca	155
idinor	0:dcf3c92487ca	156	NetDnsRequest* Net::dnsRequest(const char* hostname) { //Create a new NetDnsRequest object from default if
idinor	0:dcf3c92487ca	157	if ( net().m_defaultIf == NULL )
idinor	0:dcf3c92487ca	158	return NULL;
idinor	0:dcf3c92487ca	159	return net().m_defaultIf->dnsRequest(hostname);
idinor	0:dcf3c92487ca	160	}
idinor	0:dcf3c92487ca	161
idinor	0:dcf3c92487ca	162	NetDnsRequest* Net::dnsRequest(Host* pHost, NetIf& netif)
idinor	0:dcf3c92487ca	163	{
idinor	0:dcf3c92487ca	164	return netif.dnsRequest(pHost);
idinor	0:dcf3c92487ca	165	}
idinor	0:dcf3c92487ca	166
idinor	0:dcf3c92487ca	167	NetDnsRequest* Net::dnsRequest(Host* pHost) //Creats a new NetDnsRequest object from default if
idinor	0:dcf3c92487ca	168	{
idinor	0:dcf3c92487ca	169	if ( net().m_defaultIf == NULL )
idinor	0:dcf3c92487ca	170	return NULL;
idinor	0:dcf3c92487ca	171	return net().m_defaultIf->dnsRequest(pHost);
idinor	0:dcf3c92487ca	172	}
idinor	0:dcf3c92487ca	173
idinor	0:dcf3c92487ca	174	void Net::setDefaultIf(NetIf& netif) {
idinor	0:dcf3c92487ca	175	net().m_defaultIf = &netif;
idinor	0:dcf3c92487ca	176	}
idinor	0:dcf3c92487ca	177
idinor	0:dcf3c92487ca	178	void Net::setDefaultIf(NetIf* pIf)
idinor	0:dcf3c92487ca	179	{
idinor	0:dcf3c92487ca	180	net().m_defaultIf = pIf;
idinor	0:dcf3c92487ca	181	}
idinor	0:dcf3c92487ca	182
idinor	0:dcf3c92487ca	183	NetIf* Net::getDefaultIf() {
idinor	0:dcf3c92487ca	184	return net().m_defaultIf;
idinor	0:dcf3c92487ca	185	}
idinor	0:dcf3c92487ca	186
idinor	0:dcf3c92487ca	187	void Net::registerIf(NetIf* pIf)
idinor	0:dcf3c92487ca	188	{
idinor	0:dcf3c92487ca	189	net().m_lpIf.push_back(pIf);
idinor	0:dcf3c92487ca	190	}
idinor	0:dcf3c92487ca	191
idinor	0:dcf3c92487ca	192	void Net::unregisterIf(NetIf* pIf)
idinor	0:dcf3c92487ca	193	{
idinor	0:dcf3c92487ca	194	if( net().m_defaultIf == pIf )
idinor	0:dcf3c92487ca	195	net().m_defaultIf = NULL;
idinor	0:dcf3c92487ca	196	net().m_lpIf.remove(pIf);
idinor	0:dcf3c92487ca	197	}
idinor	0:dcf3c92487ca	198
idinor	0:dcf3c92487ca	199	void Net::registerNetTcpSocket(NetTcpSocket* pNetTcpSocket)
idinor	0:dcf3c92487ca	200	{
idinor	0:dcf3c92487ca	201	net().m_lpNetTcpSocket.push_back(pNetTcpSocket);
idinor	0:dcf3c92487ca	202	DBG("\r\nNetTcpSocket [ + %p ] %d\r\n", (void*)pNetTcpSocket, net().m_lpNetTcpSocket.size());
idinor	0:dcf3c92487ca	203	}
idinor	0:dcf3c92487ca	204
idinor	0:dcf3c92487ca	205	void Net::unregisterNetTcpSocket(NetTcpSocket* pNetTcpSocket)
idinor	0:dcf3c92487ca	206	{
idinor	0:dcf3c92487ca	207	DBG("\r\nNetTcpSocket [ - %p ] %d\r\n", (void*)pNetTcpSocket, net().m_lpNetTcpSocket.size() - 1);
idinor	0:dcf3c92487ca	208	if(!pNetTcpSocket->m_removed)
idinor	0:dcf3c92487ca	209	net().m_lpNetTcpSocket.remove(pNetTcpSocket);
idinor	0:dcf3c92487ca	210	}
idinor	0:dcf3c92487ca	211
idinor	0:dcf3c92487ca	212	void Net::registerNetUdpSocket(NetUdpSocket* pNetUdpSocket)
idinor	0:dcf3c92487ca	213	{
idinor	0:dcf3c92487ca	214	net().m_lpNetUdpSocket.push_back(pNetUdpSocket);
idinor	0:dcf3c92487ca	215	DBG("\r\nNetUdpSocket [ + %p ] %d\r\n", (void*)pNetUdpSocket, net().m_lpNetUdpSocket.size());
idinor	0:dcf3c92487ca	216	}
idinor	0:dcf3c92487ca	217
idinor	0:dcf3c92487ca	218	void Net::unregisterNetUdpSocket(NetUdpSocket* pNetUdpSocket)
idinor	0:dcf3c92487ca	219	{
idinor	0:dcf3c92487ca	220	DBG("\r\nNetUdpSocket [ - %p ] %d\r\n", (void*)pNetUdpSocket, net().m_lpNetUdpSocket.size() - 1);
idinor	0:dcf3c92487ca	221	if(!pNetUdpSocket->m_removed)
idinor	0:dcf3c92487ca	222	net().m_lpNetUdpSocket.remove(pNetUdpSocket);
idinor	0:dcf3c92487ca	223	}
idinor	0:dcf3c92487ca	224
idinor	0:dcf3c92487ca	225	Net& Net::net()
idinor	0:dcf3c92487ca	226	{
idinor	0:dcf3c92487ca	227	static Net* pInst = new Net(); //Called only once
idinor	0:dcf3c92487ca	228	return *pInst;
idinor	0:dcf3c92487ca	229	}

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	20 Jul 2011
Imports:	35
Forks:	0
Commits:	1
Dependents:	1
Dependencies:	0
Followers:	1

core/net.cpp@0:dcf3c92487ca, 2011-07-20 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning