iva2k_NetHttpServerTcpSockets - Example program with HTTPServer and sensor data s…

Users » iva2k » Code » iva2k_NetHttpServerTcpSockets

Ilya I / Mbed 2 deprecated iva2k_NetHttpServerTcpSockets

Example program with HTTPServer and sensor data streaming over TCPSockets, using Donatien Garnier's Net APIs and services code on top of LWIP. Files StreamServer.h and .cpp encapsulate streaming over TCPSockets. Broadcast is done by sendToAll(), and all incoming data is echoed back to the client. Echo code can be replaced with some remote control of the streaming interface. See main() that shows how to periodically send some data to all subscribed clients. To subscribe, a client should open a socket at <mbed_ip> port 123. I used few lines in TCL code to set up a quick sink for the data. HTTP files are served on port 80 concurrently to the streaming.

Dependencies: mbed

if/net/net.cpp@1:3ee499525aa5, 2010-06-14 (annotated)

Committer:: iva2k
Date:: Mon Jun 14 03:24:33 2010 +0000
Revision:: 1:3ee499525aa5
Parent:: 0:e614f7875b60

Who changed what in which revision?

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	12 Jun 2010
Imports:	78
Forks:	0
Commits:	2
Dependents:	0
Dependencies:	1
Followers:	1

if/net/net.cpp@1:3ee499525aa5, 2010-06-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning