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.

drv/serial/buf/SerialBuf.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 "SerialBuf.h"
dirkx	0:a259777c45a3	25	#include "mbed.h"
dirkx	0:a259777c45a3	26
dirkx	0:a259777c45a3	27	//#define __DEBUG
dirkx	0:a259777c45a3	28	#include "dbg/dbg.h"
dirkx	0:a259777c45a3	29
dirkx	0:a259777c45a3	30	#include "netCfg.h"
dirkx	0:a259777c45a3	31	#if NET_GPRS
dirkx	0:a259777c45a3	32
dirkx	0:a259777c45a3	33	#if NET_USB_SERIAL
dirkx	0:a259777c45a3	34	#define m_pStream( a ) (m_pSerial?m_pSerial->a:m_pUsbSerial->a)
dirkx	0:a259777c45a3	35	#else
dirkx	0:a259777c45a3	36	#define m_pStream( a ) (m_pSerial->a)
dirkx	0:a259777c45a3	37	#endif
dirkx	0:a259777c45a3	38
dirkx	0:a259777c45a3	39	SerialBuf::SerialBuf(int len) : m_trmt(false), m_pSerial(NULL), m_intCanReadData(true), m_readMode(false) //Buffer length
dirkx	0:a259777c45a3	40	#if NET_USB_SERIAL
dirkx	0:a259777c45a3	41	, m_pUsbSerial(NULL)
dirkx	0:a259777c45a3	42	#endif
dirkx	0:a259777c45a3	43	{
dirkx	0:a259777c45a3	44	m_buf = new char[len];
dirkx	0:a259777c45a3	45	m_bufLen=len;
dirkx	0:a259777c45a3	46	m_pRead=m_buf;
dirkx	0:a259777c45a3	47	m_pReadStart=m_buf;
dirkx	0:a259777c45a3	48	m_pReadByInt=m_buf;
dirkx	0:a259777c45a3	49	m_pWrite=m_buf;
dirkx	0:a259777c45a3	50	}
dirkx	0:a259777c45a3	51
dirkx	0:a259777c45a3	52	SerialBuf::~SerialBuf()
dirkx	0:a259777c45a3	53	{
dirkx	0:a259777c45a3	54	delete[] m_buf;
dirkx	0:a259777c45a3	55	}
dirkx	0:a259777c45a3	56
dirkx	0:a259777c45a3	57	void SerialBuf::attach(Serial* pSerial)
dirkx	0:a259777c45a3	58	{
dirkx	0:a259777c45a3	59	m_pSerial = pSerial;
dirkx	0:a259777c45a3	60	m_pSerial->attach<SerialBuf>(this, &SerialBuf::onSerialInterrupt);
dirkx	0:a259777c45a3	61	// onSerialInterrupt(); //Flush hw buffer into current buf
dirkx	0:a259777c45a3	62	}
dirkx	0:a259777c45a3	63
dirkx	0:a259777c45a3	64	#if NET_USB_SERIAL
dirkx	0:a259777c45a3	65	void SerialBuf::attach(UsbSerial* pUsbSerial)
dirkx	0:a259777c45a3	66	{
dirkx	0:a259777c45a3	67	m_pUsbSerial = pUsbSerial;
dirkx	0:a259777c45a3	68	//m_pUsbSerial->attach<SerialBuf>(this, &SerialBuf::onSerialInterrupt);
dirkx	0:a259777c45a3	69	m_usbTick.attach_us<SerialBuf>(this, &SerialBuf::onSerialInterrupt, 10000);
dirkx	0:a259777c45a3	70	}
dirkx	0:a259777c45a3	71	#endif
dirkx	0:a259777c45a3	72
dirkx	0:a259777c45a3	73	void SerialBuf::detach()
dirkx	0:a259777c45a3	74	{
dirkx	0:a259777c45a3	75	if(m_pSerial)
dirkx	0:a259777c45a3	76	{
dirkx	0:a259777c45a3	77	m_pSerial->attach(0);
dirkx	0:a259777c45a3	78	m_pSerial = NULL;
dirkx	0:a259777c45a3	79	}
dirkx	0:a259777c45a3	80	#if NET_USB_SERIAL
dirkx	0:a259777c45a3	81	else if(m_pUsbSerial)
dirkx	0:a259777c45a3	82	{
dirkx	0:a259777c45a3	83	m_usbTick.detach();
dirkx	0:a259777c45a3	84	m_pUsbSerial = NULL;
dirkx	0:a259777c45a3	85	}
dirkx	0:a259777c45a3	86	#endif
dirkx	0:a259777c45a3	87	}
dirkx	0:a259777c45a3	88
dirkx	0:a259777c45a3	89
dirkx	0:a259777c45a3	90	void SerialBuf::onSerialInterrupt() //Callback from m_pSerial
dirkx	0:a259777c45a3	91	{
dirkx	0:a259777c45a3	92	//DBG("\r\n[INT]");
dirkx	0:a259777c45a3	93	// Timer tmr;
dirkx	0:a259777c45a3	94	// tmr.start();
dirkx	0:a259777c45a3	95	// static volatile bool incompleteData = true;
dirkx	0:a259777c45a3	96	// static volatile char* pLastIntReadPos = m_buf;
dirkx	0:a259777c45a3	97	if(!(m_pStream(readable())))
dirkx	0:a259777c45a3	98	{
dirkx	0:a259777c45a3	99	return;
dirkx	0:a259777c45a3	100	}
dirkx	0:a259777c45a3	101	int len=0;
dirkx	0:a259777c45a3	102	do
dirkx	0:a259777c45a3	103	{
dirkx	0:a259777c45a3	104	if(room()>0)
dirkx	0:a259777c45a3	105	{
dirkx	0:a259777c45a3	106	len++;
dirkx	0:a259777c45a3	107	#ifdef __DEBUGVERBOSE
dirkx	0:a259777c45a3	108	char c = m_pStream(getc());
dirkx	0:a259777c45a3	109	DBG("\r\n[%c]",c);
dirkx	0:a259777c45a3	110	put(c);
dirkx	0:a259777c45a3	111	#else
dirkx	0:a259777c45a3	112	put(m_pStream(getc()));
dirkx	0:a259777c45a3	113	#endif
dirkx	0:a259777c45a3	114	}
dirkx	0:a259777c45a3	115	else
dirkx	0:a259777c45a3	116	{
dirkx	0:a259777c45a3	117	DBG("\r\nWARN: SerialBuf Overrun");
dirkx	0:a259777c45a3	118	m_pStream(getc());
dirkx	0:a259777c45a3	119	}
dirkx	0:a259777c45a3	120	} while(m_pStream(readable()));
dirkx	0:a259777c45a3	121	// DBG("\r\n[/INT]=%d\r\n w len=%d",tmr.read_us(),len);
dirkx	0:a259777c45a3	122
dirkx	0:a259777c45a3	123	if( m_intCanReadData )
dirkx	0:a259777c45a3	124	{
dirkx	0:a259777c45a3	125	volatile bool u_readMode = m_readMode; //Save User context on interrupt
dirkx	0:a259777c45a3	126	volatile bool handled = onRead();
dirkx	0:a259777c45a3	127	if(handled)
dirkx	0:a259777c45a3	128	{
dirkx	0:a259777c45a3	129	m_pReadByInt = m_pRead;
dirkx	0:a259777c45a3	130	if(m_pRead==m_pReadStart)
dirkx	0:a259777c45a3	131	{
dirkx	0:a259777c45a3	132	//Data has been processed
dirkx	0:a259777c45a3	133	}
dirkx	0:a259777c45a3	134	else
dirkx	0:a259777c45a3	135	{
dirkx	0:a259777c45a3	136	m_pRead = m_pReadStart;
dirkx	0:a259777c45a3	137	m_intCanReadData = false;
dirkx	0:a259777c45a3	138	//Data has to be processed in user space
dirkx	0:a259777c45a3	139	}
dirkx	0:a259777c45a3	140	}
dirkx	0:a259777c45a3	141	setReadMode( u_readMode );
dirkx	0:a259777c45a3	142	}
dirkx	0:a259777c45a3	143
dirkx	0:a259777c45a3	144
dirkx	0:a259777c45a3	145	#if 0
dirkx	0:a259777c45a3	146	if( incompleteData \|\| ( pLastIntReadPos != m_pRead ) )
dirkx	0:a259777c45a3	147	{
dirkx	0:a259777c45a3	148	bool u_readMode = m_readMode; //Save User context on interrupt
dirkx	0:a259777c45a3	149	incompleteData = onRead();
dirkx	0:a259777c45a3	150	if(!incompleteData)
dirkx	0:a259777c45a3	151	m_pRead = m_pReadStart;
dirkx	0:a259777c45a3	152	pLastIntReadPos = m_pRead;
dirkx	0:a259777c45a3	153
dirkx	0:a259777c45a3	154	}
dirkx	0:a259777c45a3	155	#endif
dirkx	0:a259777c45a3	156
dirkx	0:a259777c45a3	157	}
dirkx	0:a259777c45a3	158
dirkx	0:a259777c45a3	159	char SerialBuf::getc()
dirkx	0:a259777c45a3	160	{
dirkx	0:a259777c45a3	161	// DBG("\r\n\[GETC]");
dirkx	0:a259777c45a3	162	#if 0
dirkx	0:a259777c45a3	163	if(m_trmt) //Was transmitting
dirkx	0:a259777c45a3	164	{
dirkx	0:a259777c45a3	165	DBG("\r\n<\r\n");
dirkx	0:a259777c45a3	166	m_trmt=false;
dirkx	0:a259777c45a3	167	}
dirkx	0:a259777c45a3	168	#endif
dirkx	0:a259777c45a3	169	char c;
dirkx	0:a259777c45a3	170	c = get();
dirkx	0:a259777c45a3	171	DBG("%c", c);
dirkx	0:a259777c45a3	172	// DBG("\r\n[/GETC]");
dirkx	0:a259777c45a3	173	return c;
dirkx	0:a259777c45a3	174	}
dirkx	0:a259777c45a3	175
dirkx	0:a259777c45a3	176	void SerialBuf::putc(char c)
dirkx	0:a259777c45a3	177	{
dirkx	0:a259777c45a3	178	#if 0
dirkx	0:a259777c45a3	179	if(!m_trmt) //Was receiving
dirkx	0:a259777c45a3	180	{
dirkx	0:a259777c45a3	181	DBG("\r\n>\r\n");
dirkx	0:a259777c45a3	182	m_trmt=true;
dirkx	0:a259777c45a3	183	}
dirkx	0:a259777c45a3	184	#endif
dirkx	0:a259777c45a3	185	// m_pSerial->writeable();
dirkx	0:a259777c45a3	186	// while(!m_pSerial->writeable() /\|\| m_pSerial->readable()/)
dirkx	0:a259777c45a3	187	// {
dirkx	0:a259777c45a3	188	// wait_us(100);
dirkx	0:a259777c45a3	189	// DBG("\r\nWait...\r\n");
dirkx	0:a259777c45a3	190	// }
dirkx	0:a259777c45a3	191	/*
dirkx	0:a259777c45a3	192	NVIC_DisableIRQ(UART1_IRQn);
dirkx	0:a259777c45a3	193	NVIC_DisableIRQ(UART2_IRQn);
dirkx	0:a259777c45a3	194	NVIC_DisableIRQ(UART3_IRQn);
dirkx	0:a259777c45a3	195	*/
dirkx	0:a259777c45a3	196	// onSerialInterrupt();
dirkx	0:a259777c45a3	197	m_pStream(putc(c));
dirkx	0:a259777c45a3	198	/* NVIC_EnableIRQ(UART1_IRQn);
dirkx	0:a259777c45a3	199	NVIC_EnableIRQ(UART2_IRQn);
dirkx	0:a259777c45a3	200	NVIC_EnableIRQ(UART3_IRQn);
dirkx	0:a259777c45a3	201	*/
dirkx	0:a259777c45a3	202	DBG("%c", c);
dirkx	0:a259777c45a3	203	}
dirkx	0:a259777c45a3	204
dirkx	0:a259777c45a3	205	/* Buffer Stuff */
dirkx	0:a259777c45a3	206
dirkx	0:a259777c45a3	207	bool SerialBuf::readable()
dirkx	0:a259777c45a3	208	{
dirkx	0:a259777c45a3	209	// onSerialInterrupt(); //Flush hw buffer into current buf
dirkx	0:a259777c45a3	210	// DBG("\r\nLen=%d",len());
dirkx	0:a259777c45a3	211	return (len()>0);
dirkx	0:a259777c45a3	212	}
dirkx	0:a259777c45a3	213
dirkx	0:a259777c45a3	214	bool SerialBuf::writeable()
dirkx	0:a259777c45a3	215	{
dirkx	0:a259777c45a3	216	return m_pStream(writeable());
dirkx	0:a259777c45a3	217	}
dirkx	0:a259777c45a3	218
dirkx	0:a259777c45a3	219	void SerialBuf::setReadMode(bool readMode) //If true, keeps chars in buf when read, false by default
dirkx	0:a259777c45a3	220	{
dirkx	0:a259777c45a3	221	if(m_readMode == true && readMode == false)
dirkx	0:a259777c45a3	222	{
dirkx	0:a259777c45a3	223	//Trash bytes that have been read
dirkx	0:a259777c45a3	224	flushRead();
dirkx	0:a259777c45a3	225	}
dirkx	0:a259777c45a3	226	m_readMode=readMode;
dirkx	0:a259777c45a3	227	}
dirkx	0:a259777c45a3	228
dirkx	0:a259777c45a3	229	void SerialBuf::flushRead() //Delete chars that have been read (only useful with readMode = true)
dirkx	0:a259777c45a3	230	{
dirkx	0:a259777c45a3	231	m_pReadStart = m_pRead;
dirkx	0:a259777c45a3	232	}
dirkx	0:a259777c45a3	233
dirkx	0:a259777c45a3	234	void SerialBuf::resetRead() //Go back to initial read position (only useful with readMode = true)
dirkx	0:a259777c45a3	235	{
dirkx	0:a259777c45a3	236	m_pRead = m_pReadStart;
dirkx	0:a259777c45a3	237	}
dirkx	0:a259777c45a3	238
dirkx	0:a259777c45a3	239	bool SerialBuf::onRead()
dirkx	0:a259777c45a3	240	{
dirkx	0:a259777c45a3	241	return false;
dirkx	0:a259777c45a3	242	//Nothing here
dirkx	0:a259777c45a3	243	}
dirkx	0:a259777c45a3	244
dirkx	0:a259777c45a3	245	char SerialBuf::get() //Get a char from buf
dirkx	0:a259777c45a3	246	{
dirkx	0:a259777c45a3	247	//WARN: Must call len() before
dirkx	0:a259777c45a3	248	char c = *m_pRead;
dirkx	0:a259777c45a3	249	m_pRead++;
dirkx	0:a259777c45a3	250
dirkx	0:a259777c45a3	251	if(m_pRead>=m_buf+m_bufLen)
dirkx	0:a259777c45a3	252	m_pRead=m_buf;
dirkx	0:a259777c45a3	253
dirkx	0:a259777c45a3	254	if(!m_readMode) //If readmode=false, trash this char
dirkx	0:a259777c45a3	255	m_pReadStart=m_pRead;
dirkx	0:a259777c45a3	256
dirkx	0:a259777c45a3	257	if(m_pRead==m_pReadByInt) //Next message can be processed by interrupt
dirkx	0:a259777c45a3	258	m_intCanReadData = true;
dirkx	0:a259777c45a3	259	/* else if(m_intCanReadData) //Increment this address
dirkx	0:a259777c45a3	260	m_pReadByInt=m_pRead;*/
dirkx	0:a259777c45a3	261	return c;
dirkx	0:a259777c45a3	262	}
dirkx	0:a259777c45a3	263
dirkx	0:a259777c45a3	264	void SerialBuf::put(char c) //Put a char in buf
dirkx	0:a259777c45a3	265	{
dirkx	0:a259777c45a3	266	//WARN: Must call room() before
dirkx	0:a259777c45a3	267	*m_pWrite = c;
dirkx	0:a259777c45a3	268	m_pWrite++;
dirkx	0:a259777c45a3	269	if(m_pWrite>=m_buf+m_bufLen)
dirkx	0:a259777c45a3	270	m_pWrite=m_buf;
dirkx	0:a259777c45a3	271	}
dirkx	0:a259777c45a3	272
dirkx	0:a259777c45a3	273	int SerialBuf::room() //Return room available in buf
dirkx	0:a259777c45a3	274	{
dirkx	0:a259777c45a3	275	//return m_bufLen - len() - 1; //-1 is to avoid loop
dirkx	0:a259777c45a3	276	if ( m_pReadStart > m_pWrite )
dirkx	0:a259777c45a3	277	return ( m_pReadStart - m_pWrite - 1 );
dirkx	0:a259777c45a3	278	else
dirkx	0:a259777c45a3	279	return m_bufLen - ( m_pWrite - m_pReadStart ) - 1;
dirkx	0:a259777c45a3	280	}
dirkx	0:a259777c45a3	281
dirkx	0:a259777c45a3	282	int SerialBuf::len() //Return chars length in buf
dirkx	0:a259777c45a3	283	{
dirkx	0:a259777c45a3	284	if ( m_pWrite >= m_pRead )
dirkx	0:a259777c45a3	285	return ( m_pWrite - m_pRead );
dirkx	0:a259777c45a3	286	else
dirkx	0:a259777c45a3	287	return m_bufLen - ( m_pRead - m_pWrite ); // = ( ( m_buf + m_bufLen) - m_pRead ) + ( m_pWrite - m_buf )
dirkx	0:a259777c45a3	288	}
dirkx	0:a259777c45a3	289
dirkx	0:a259777c45a3	290	#endif

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

drv/serial/buf/SerialBuf.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