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.

drv/serial/buf/SerialBuf.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 "SerialBuf.h"
idinor	0:dcf3c92487ca	25	#include "mbed.h"
idinor	0:dcf3c92487ca	26
idinor	0:dcf3c92487ca	27	//#define __DEBUG
idinor	0:dcf3c92487ca	28	#include "dbg/dbg.h"
idinor	0:dcf3c92487ca	29
idinor	0:dcf3c92487ca	30	#include "netCfg.h"
idinor	0:dcf3c92487ca	31	#if NET_GPRS
idinor	0:dcf3c92487ca	32
idinor	0:dcf3c92487ca	33	#if NET_USB_SERIAL
idinor	0:dcf3c92487ca	34	#define m_pStream( a ) (m_pSerial?m_pSerial->a:m_pUsbSerial->a)
idinor	0:dcf3c92487ca	35	#else
idinor	0:dcf3c92487ca	36	#define m_pStream( a ) (m_pSerial->a)
idinor	0:dcf3c92487ca	37	#endif
idinor	0:dcf3c92487ca	38
idinor	0:dcf3c92487ca	39	//Circular buf
idinor	0:dcf3c92487ca	40
idinor	0:dcf3c92487ca	41	SerialCircularBuf::SerialCircularBuf(int len) : m_readMode(false)
idinor	0:dcf3c92487ca	42	{
idinor	0:dcf3c92487ca	43	m_buf = new char[len];
idinor	0:dcf3c92487ca	44	m_len = len;
idinor	0:dcf3c92487ca	45	m_pReadStart = m_pRead = m_buf;
idinor	0:dcf3c92487ca	46	m_pWrite = m_buf;
idinor	0:dcf3c92487ca	47	}
idinor	0:dcf3c92487ca	48
idinor	0:dcf3c92487ca	49	SerialCircularBuf::~SerialCircularBuf()
idinor	0:dcf3c92487ca	50	{
idinor	0:dcf3c92487ca	51	if(m_buf)
idinor	0:dcf3c92487ca	52	delete[] m_buf;
idinor	0:dcf3c92487ca	53	}
idinor	0:dcf3c92487ca	54
idinor	0:dcf3c92487ca	55	int SerialCircularBuf::room() //Return room available in buf
idinor	0:dcf3c92487ca	56	{
idinor	0:dcf3c92487ca	57	//return m_len - len() - 1; //-1 is to avoid loop
idinor	0:dcf3c92487ca	58	if ( m_pReadStart > m_pWrite )
idinor	0:dcf3c92487ca	59	return ( m_pReadStart - m_pWrite - 1 );
idinor	0:dcf3c92487ca	60	else
idinor	0:dcf3c92487ca	61	return m_len - ( m_pWrite - m_pReadStart ) - 1;
idinor	0:dcf3c92487ca	62	}
idinor	0:dcf3c92487ca	63
idinor	0:dcf3c92487ca	64	int SerialCircularBuf::len() //Return chars length in buf
idinor	0:dcf3c92487ca	65	{
idinor	0:dcf3c92487ca	66	if ( m_pWrite >= m_pRead )
idinor	0:dcf3c92487ca	67	return ( m_pWrite - m_pRead );
idinor	0:dcf3c92487ca	68	else
idinor	0:dcf3c92487ca	69	return m_len - ( m_pRead - m_pWrite ); // = ( ( m_buf + m_len) - m_pRead ) + ( m_pWrite - m_buf )
idinor	0:dcf3c92487ca	70	}
idinor	0:dcf3c92487ca	71
idinor	0:dcf3c92487ca	72	void SerialCircularBuf::write(char c)
idinor	0:dcf3c92487ca	73	{
idinor	0:dcf3c92487ca	74	#if 0
idinor	0:dcf3c92487ca	75	if(!room())
idinor	0:dcf3c92487ca	76	return;
idinor	0:dcf3c92487ca	77	#endif
idinor	0:dcf3c92487ca	78	//WARN: Must call room() before
idinor	0:dcf3c92487ca	79	*m_pWrite = c;
idinor	0:dcf3c92487ca	80	m_pWrite++;
idinor	0:dcf3c92487ca	81	if(m_pWrite>=m_buf+m_len)
idinor	0:dcf3c92487ca	82	m_pWrite=m_buf;
idinor	0:dcf3c92487ca	83	}
idinor	0:dcf3c92487ca	84	char SerialCircularBuf::read()
idinor	0:dcf3c92487ca	85	{
idinor	0:dcf3c92487ca	86	#if 0
idinor	0:dcf3c92487ca	87	if(!len())
idinor	0:dcf3c92487ca	88	return 0;
idinor	0:dcf3c92487ca	89	#endif
idinor	0:dcf3c92487ca	90	//WARN: Must call len() before
idinor	0:dcf3c92487ca	91	char c = *m_pRead;
idinor	0:dcf3c92487ca	92	m_pRead++;
idinor	0:dcf3c92487ca	93
idinor	0:dcf3c92487ca	94	if(m_pRead>=m_buf+m_len)
idinor	0:dcf3c92487ca	95	m_pRead=m_buf;
idinor	0:dcf3c92487ca	96
idinor	0:dcf3c92487ca	97	if(!m_readMode) //If readmode=false, trash this char
idinor	0:dcf3c92487ca	98	m_pReadStart=m_pRead;
idinor	0:dcf3c92487ca	99
idinor	0:dcf3c92487ca	100	return c;
idinor	0:dcf3c92487ca	101	}
idinor	0:dcf3c92487ca	102
idinor	0:dcf3c92487ca	103	void SerialCircularBuf::setReadMode(bool readMode) //If true, keeps chars in buf when read, false by default
idinor	0:dcf3c92487ca	104	{
idinor	0:dcf3c92487ca	105	if(m_readMode == true && readMode == false)
idinor	0:dcf3c92487ca	106	{
idinor	0:dcf3c92487ca	107	//Trash bytes that have been read
idinor	0:dcf3c92487ca	108	flushRead();
idinor	0:dcf3c92487ca	109	}
idinor	0:dcf3c92487ca	110	m_readMode = readMode;
idinor	0:dcf3c92487ca	111	}
idinor	0:dcf3c92487ca	112
idinor	0:dcf3c92487ca	113	void SerialCircularBuf::flushRead() //Delete chars that have been read & return chars len (only useful with readMode = true)
idinor	0:dcf3c92487ca	114	{
idinor	0:dcf3c92487ca	115	m_pReadStart = m_pRead;
idinor	0:dcf3c92487ca	116	}
idinor	0:dcf3c92487ca	117
idinor	0:dcf3c92487ca	118	void SerialCircularBuf::resetRead() //Go back to initial read position & return chars len (only useful with readMode = true)
idinor	0:dcf3c92487ca	119	{
idinor	0:dcf3c92487ca	120	m_pRead = m_pReadStart;
idinor	0:dcf3c92487ca	121	}
idinor	0:dcf3c92487ca	122
idinor	0:dcf3c92487ca	123	//SerialBuf
idinor	0:dcf3c92487ca	124
idinor	0:dcf3c92487ca	125	SerialBuf::SerialBuf(int len) : m_rxBuf(len), m_txBuf(len), m_pSerial(NULL) //Buffer length
idinor	0:dcf3c92487ca	126	#if NET_USB_SERIAL
idinor	0:dcf3c92487ca	127	, m_pUsbSerial(NULL)
idinor	0:dcf3c92487ca	128	#endif
idinor	0:dcf3c92487ca	129	{
idinor	0:dcf3c92487ca	130	DBG("New Serial buf@%p\n", this);
idinor	0:dcf3c92487ca	131	}
idinor	0:dcf3c92487ca	132
idinor	0:dcf3c92487ca	133	SerialBuf::~SerialBuf()
idinor	0:dcf3c92487ca	134	{
idinor	0:dcf3c92487ca	135
idinor	0:dcf3c92487ca	136	}
idinor	0:dcf3c92487ca	137
idinor	0:dcf3c92487ca	138	void SerialBuf::attach(Serial* pSerial)
idinor	0:dcf3c92487ca	139	{
idinor	0:dcf3c92487ca	140	DBG("Serial buf@%p in attach\n", this);
idinor	0:dcf3c92487ca	141	m_pSerial = pSerial;
idinor	0:dcf3c92487ca	142	m_pSerial->attach<SerialBuf>(this, &SerialBuf::onRxInterrupt, Serial::RxIrq);
idinor	0:dcf3c92487ca	143	m_pSerial->attach<SerialBuf>(this, &SerialBuf::onTxInterrupt, Serial::TxIrq);
idinor	0:dcf3c92487ca	144	onRxInterrupt(); //Read data
idinor	0:dcf3c92487ca	145	}
idinor	0:dcf3c92487ca	146
idinor	0:dcf3c92487ca	147	void SerialBuf::detach()
idinor	0:dcf3c92487ca	148	{
idinor	0:dcf3c92487ca	149	if(m_pSerial)
idinor	0:dcf3c92487ca	150	{
idinor	0:dcf3c92487ca	151	m_pSerial->attach<SerialBuf>(NULL, NULL, Serial::RxIrq);
idinor	0:dcf3c92487ca	152	m_pSerial->attach<SerialBuf>(NULL, NULL, Serial::TxIrq);
idinor	0:dcf3c92487ca	153	m_pSerial = NULL;
idinor	0:dcf3c92487ca	154	}
idinor	0:dcf3c92487ca	155	#if NET_USB_SERIAL
idinor	0:dcf3c92487ca	156	else if(m_pUsbSerial)
idinor	0:dcf3c92487ca	157	{
idinor	0:dcf3c92487ca	158	m_pUsbSerial->attach<SerialBuf>(NULL, NULL, UsbSerial::RxIrq);
idinor	0:dcf3c92487ca	159	m_pUsbSerial->attach<SerialBuf>(NULL, NULL, UsbSerial::TxIrq);
idinor	0:dcf3c92487ca	160	m_pUsbSerial = NULL;
idinor	0:dcf3c92487ca	161	}
idinor	0:dcf3c92487ca	162	#endif
idinor	0:dcf3c92487ca	163	}
idinor	0:dcf3c92487ca	164
idinor	0:dcf3c92487ca	165	#if NET_USB_SERIAL
idinor	0:dcf3c92487ca	166	void SerialBuf::attach(UsbSerial* pUsbSerial)
idinor	0:dcf3c92487ca	167	{
idinor	0:dcf3c92487ca	168	m_pUsbSerial = pUsbSerial;
idinor	0:dcf3c92487ca	169	m_pUsbSerial->attach<SerialBuf>(this, &SerialBuf::onRxInterrupt, UsbSerial::RxIrq);
idinor	0:dcf3c92487ca	170	m_pUsbSerial->attach<SerialBuf>(this, &SerialBuf::onTxInterrupt, UsbSerial::TxIrq);
idinor	0:dcf3c92487ca	171	onRxInterrupt(); //Read data
idinor	0:dcf3c92487ca	172	}
idinor	0:dcf3c92487ca	173	#endif
idinor	0:dcf3c92487ca	174
idinor	0:dcf3c92487ca	175	char SerialBuf::getc()
idinor	0:dcf3c92487ca	176	{
idinor	0:dcf3c92487ca	177	while(!readable());
idinor	0:dcf3c92487ca	178	char c = m_rxBuf.read();
idinor	0:dcf3c92487ca	179	return c;
idinor	0:dcf3c92487ca	180	}
idinor	0:dcf3c92487ca	181
idinor	0:dcf3c92487ca	182	void SerialBuf::putc(char c)
idinor	0:dcf3c92487ca	183	{
idinor	0:dcf3c92487ca	184	while(!writeable());
idinor	0:dcf3c92487ca	185	m_txBuf.write(c);
idinor	0:dcf3c92487ca	186	onTxInterrupt();
idinor	0:dcf3c92487ca	187	}
idinor	0:dcf3c92487ca	188
idinor	0:dcf3c92487ca	189	bool SerialBuf::readable()
idinor	0:dcf3c92487ca	190	{
idinor	0:dcf3c92487ca	191	if( !m_rxBuf.len() ) //Fill buf if possible
idinor	0:dcf3c92487ca	192	onRxInterrupt();
idinor	0:dcf3c92487ca	193	return (m_rxBuf.len() > 0);
idinor	0:dcf3c92487ca	194	}
idinor	0:dcf3c92487ca	195
idinor	0:dcf3c92487ca	196	bool SerialBuf::writeable()
idinor	0:dcf3c92487ca	197	{
idinor	0:dcf3c92487ca	198	if( !m_txBuf.room() ) //Free buf is possible
idinor	0:dcf3c92487ca	199	onTxInterrupt();
idinor	0:dcf3c92487ca	200	return (m_txBuf.room() > 0);
idinor	0:dcf3c92487ca	201	}
idinor	0:dcf3c92487ca	202
idinor	0:dcf3c92487ca	203	void SerialBuf::setReadMode(bool readMode) //If true, keeps chars in buf when read, false by default
idinor	0:dcf3c92487ca	204	{
idinor	0:dcf3c92487ca	205	m_rxBuf.setReadMode(readMode);
idinor	0:dcf3c92487ca	206	}
idinor	0:dcf3c92487ca	207
idinor	0:dcf3c92487ca	208	void SerialBuf::flushRead() //Delete chars that have been read & return chars len (only useful with readMode = true)
idinor	0:dcf3c92487ca	209	{
idinor	0:dcf3c92487ca	210	m_rxBuf.flushRead();
idinor	0:dcf3c92487ca	211	}
idinor	0:dcf3c92487ca	212
idinor	0:dcf3c92487ca	213	void SerialBuf::resetRead() //Go back to initial read position & return chars len (only useful with readMode = true)
idinor	0:dcf3c92487ca	214	{
idinor	0:dcf3c92487ca	215	m_rxBuf.resetRead();
idinor	0:dcf3c92487ca	216	}
idinor	0:dcf3c92487ca	217
idinor	0:dcf3c92487ca	218	void SerialBuf::onRxInterrupt() //Callback from m_pSerial
idinor	0:dcf3c92487ca	219	{
idinor	0:dcf3c92487ca	220	while( m_rxBuf.room() && m_pStream(readable()) )
idinor	0:dcf3c92487ca	221	{
idinor	0:dcf3c92487ca	222	m_rxBuf.write(m_pStream(getc()));
idinor	0:dcf3c92487ca	223	}
idinor	0:dcf3c92487ca	224	}
idinor	0:dcf3c92487ca	225
idinor	0:dcf3c92487ca	226	void SerialBuf::onTxInterrupt() //Callback from m_pSerial
idinor	0:dcf3c92487ca	227	{
idinor	0:dcf3c92487ca	228	while( m_txBuf.len() && m_pStream(writeable()) )
idinor	0:dcf3c92487ca	229	{
idinor	0:dcf3c92487ca	230	m_pStream(putc(m_txBuf.read()));
idinor	0:dcf3c92487ca	231	}
idinor	0:dcf3c92487ca	232	}
idinor	0:dcf3c92487ca	233
idinor	0:dcf3c92487ca	234
idinor	0:dcf3c92487ca	235	#endif

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

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