NetServicesSource - Experimental HTTPClient with proxy support

Users » igorsk » Code » NetServicesSource

Experimental HTTPClient with proxy support

core/net.cpp@0:b56b6a05cad4, 2011-06-29 (annotated)

Committer:: igorsk
Date:: Wed Jun 29 16:01:58 2011 +0000
Revision:: 0:b56b6a05cad4

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Created:	29 Jun 2011
Imports:	167
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	0
Followers:	3

core/net.cpp@0:b56b6a05cad4, 2011-06-29 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning