Yann Garcia / Mbed 2 deprecated DS130x_I2CApp

This short program illustrates how to use the DS130x_I2C library. My objective is to share the same RTC with Microchip 18F MCU.

Dependencies:   mbed DebugLibrary

NetServices/drv/serial/buf/SerialBuf.cpp@1:995212d326ca, 2011-02-11 (annotated)

Committer:
Yann
Date:
Fri Feb 11 10:17:20 2011 +0000
Revision:
1:995212d326ca
Parent:
0:f30e2135b0db 
V0.0.0.2

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Yann 0:f30e2135b0db 1
Yann 0:f30e2135b0db 2 /*
Yann 0:f30e2135b0db 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
Yann 0:f30e2135b0db 4
Yann 0:f30e2135b0db 5 Permission is hereby granted, free of charge, to any person obtaining a copy
Yann 0:f30e2135b0db 6 of this software and associated documentation files (the "Software"), to deal
Yann 0:f30e2135b0db 7 in the Software without restriction, including without limitation the rights
Yann 0:f30e2135b0db 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
Yann 0:f30e2135b0db 9 copies of the Software, and to permit persons to whom the Software is
Yann 0:f30e2135b0db 10 furnished to do so, subject to the following conditions:
Yann 0:f30e2135b0db 11
Yann 0:f30e2135b0db 12 The above copyright notice and this permission notice shall be included in
Yann 0:f30e2135b0db 13 all copies or substantial portions of the Software.
Yann 0:f30e2135b0db 14
Yann 0:f30e2135b0db 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
Yann 0:f30e2135b0db 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
Yann 0:f30e2135b0db 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
Yann 0:f30e2135b0db 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
Yann 0:f30e2135b0db 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
Yann 0:f30e2135b0db 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
Yann 0:f30e2135b0db 21 THE SOFTWARE.
Yann 0:f30e2135b0db 22 */
Yann 0:f30e2135b0db 23
Yann 0:f30e2135b0db 24 #include "SerialBuf.h"
Yann 0:f30e2135b0db 25 #include "mbed.h"
Yann 0:f30e2135b0db 26
Yann 0:f30e2135b0db 27 //#define __DEBUG
Yann 0:f30e2135b0db 28 #include "dbg/dbg.h"
Yann 0:f30e2135b0db 29
Yann 0:f30e2135b0db 30 #include "netCfg.h"
Yann 0:f30e2135b0db 31 #if NET_GPRS
Yann 0:f30e2135b0db 32
Yann 0:f30e2135b0db 33 #if NET_USB_SERIAL
Yann 0:f30e2135b0db 34 #define m_pStream( a ) (m_pSerial?m_pSerial->a:m_pUsbSerial->a)
Yann 0:f30e2135b0db 35 #else
Yann 0:f30e2135b0db 36 #define m_pStream( a ) (m_pSerial->a)
Yann 0:f30e2135b0db 37 #endif
Yann 0:f30e2135b0db 38
Yann 0:f30e2135b0db 39 //Circular buf
Yann 0:f30e2135b0db 40
Yann 0:f30e2135b0db 41 SerialCircularBuf::SerialCircularBuf(int len) : m_readMode(false)
Yann 0:f30e2135b0db 42 {
Yann 0:f30e2135b0db 43 m_buf = new char[len];
Yann 0:f30e2135b0db 44 m_len = len;
Yann 0:f30e2135b0db 45 m_pReadStart = m_pRead = m_buf;
Yann 0:f30e2135b0db 46 m_pWrite = m_buf;
Yann 0:f30e2135b0db 47 }
Yann 0:f30e2135b0db 48
Yann 0:f30e2135b0db 49 SerialCircularBuf::~SerialCircularBuf()
Yann 0:f30e2135b0db 50 {
Yann 0:f30e2135b0db 51 if(m_buf)
Yann 0:f30e2135b0db 52 delete[] m_buf;
Yann 0:f30e2135b0db 53 }
Yann 0:f30e2135b0db 54
Yann 0:f30e2135b0db 55 int SerialCircularBuf::room() //Return room available in buf
Yann 0:f30e2135b0db 56 {
Yann 0:f30e2135b0db 57 //return m_len - len() - 1; //-1 is to avoid loop
Yann 0:f30e2135b0db 58 if ( m_pReadStart > m_pWrite )
Yann 0:f30e2135b0db 59 return ( m_pReadStart - m_pWrite - 1 );
Yann 0:f30e2135b0db 60 else
Yann 0:f30e2135b0db 61 return m_len - ( m_pWrite - m_pReadStart ) - 1;
Yann 0:f30e2135b0db 62 }
Yann 0:f30e2135b0db 63
Yann 0:f30e2135b0db 64 int SerialCircularBuf::len() //Return chars length in buf
Yann 0:f30e2135b0db 65 {
Yann 0:f30e2135b0db 66 if ( m_pWrite >= m_pRead )
Yann 0:f30e2135b0db 67 return ( m_pWrite - m_pRead );
Yann 0:f30e2135b0db 68 else
Yann 0:f30e2135b0db 69 return m_len - ( m_pRead - m_pWrite ); // = ( ( m_buf + m_len) - m_pRead ) + ( m_pWrite - m_buf )
Yann 0:f30e2135b0db 70 }
Yann 0:f30e2135b0db 71
Yann 0:f30e2135b0db 72 void SerialCircularBuf::write(char c)
Yann 0:f30e2135b0db 73 {
Yann 0:f30e2135b0db 74 #if 0
Yann 0:f30e2135b0db 75 if(!room())
Yann 0:f30e2135b0db 76 return;
Yann 0:f30e2135b0db 77 #endif
Yann 0:f30e2135b0db 78 //WARN: Must call room() before
Yann 0:f30e2135b0db 79 *m_pWrite = c;
Yann 0:f30e2135b0db 80 m_pWrite++;
Yann 0:f30e2135b0db 81 if(m_pWrite>=m_buf+m_len)
Yann 0:f30e2135b0db 82 m_pWrite=m_buf;
Yann 0:f30e2135b0db 83 }
Yann 0:f30e2135b0db 84 char SerialCircularBuf::read()
Yann 0:f30e2135b0db 85 {
Yann 0:f30e2135b0db 86 #if 0
Yann 0:f30e2135b0db 87 if(!len())
Yann 0:f30e2135b0db 88 return 0;
Yann 0:f30e2135b0db 89 #endif
Yann 0:f30e2135b0db 90 //WARN: Must call len() before
Yann 0:f30e2135b0db 91 char c = *m_pRead;
Yann 0:f30e2135b0db 92 m_pRead++;
Yann 0:f30e2135b0db 93
Yann 0:f30e2135b0db 94 if(m_pRead>=m_buf+m_len)
Yann 0:f30e2135b0db 95 m_pRead=m_buf;
Yann 0:f30e2135b0db 96
Yann 0:f30e2135b0db 97 if(!m_readMode) //If readmode=false, trash this char
Yann 0:f30e2135b0db 98 m_pReadStart=m_pRead;
Yann 0:f30e2135b0db 99
Yann 0:f30e2135b0db 100 return c;
Yann 0:f30e2135b0db 101 }
Yann 0:f30e2135b0db 102
Yann 0:f30e2135b0db 103 void SerialCircularBuf::setReadMode(bool readMode) //If true, keeps chars in buf when read, false by default
Yann 0:f30e2135b0db 104 {
Yann 0:f30e2135b0db 105 if(m_readMode == true && readMode == false)
Yann 0:f30e2135b0db 106 {
Yann 0:f30e2135b0db 107 //Trash bytes that have been read
Yann 0:f30e2135b0db 108 flushRead();
Yann 0:f30e2135b0db 109 }
Yann 0:f30e2135b0db 110 m_readMode = readMode;
Yann 0:f30e2135b0db 111 }
Yann 0:f30e2135b0db 112
Yann 0:f30e2135b0db 113 void SerialCircularBuf::flushRead() //Delete chars that have been read & return chars len (only useful with readMode = true)
Yann 0:f30e2135b0db 114 {
Yann 0:f30e2135b0db 115 m_pReadStart = m_pRead;
Yann 0:f30e2135b0db 116 }
Yann 0:f30e2135b0db 117
Yann 0:f30e2135b0db 118 void SerialCircularBuf::resetRead() //Go back to initial read position & return chars len (only useful with readMode = true)
Yann 0:f30e2135b0db 119 {
Yann 0:f30e2135b0db 120 m_pRead = m_pReadStart;
Yann 0:f30e2135b0db 121 }
Yann 0:f30e2135b0db 122
Yann 0:f30e2135b0db 123 //SerialBuf
Yann 0:f30e2135b0db 124
Yann 0:f30e2135b0db 125 SerialBuf::SerialBuf(int len) : m_rxBuf(len), m_txBuf(len), m_pSerial(NULL) //Buffer length
Yann 0:f30e2135b0db 126 #if NET_USB_SERIAL
Yann 0:f30e2135b0db 127 , m_pUsbSerial(NULL)
Yann 0:f30e2135b0db 128 #endif
Yann 0:f30e2135b0db 129 {
Yann 0:f30e2135b0db 130 DBG("New Serial buf@%p\n", this);
Yann 0:f30e2135b0db 131 }
Yann 0:f30e2135b0db 132
Yann 0:f30e2135b0db 133 SerialBuf::~SerialBuf()
Yann 0:f30e2135b0db 134 {
Yann 0:f30e2135b0db 135
Yann 0:f30e2135b0db 136 }
Yann 0:f30e2135b0db 137
Yann 0:f30e2135b0db 138 void SerialBuf::attach(Serial* pSerial)
Yann 0:f30e2135b0db 139 {
Yann 0:f30e2135b0db 140 DBG("Serial buf@%p in attach\n", this);
Yann 0:f30e2135b0db 141 m_pSerial = pSerial;
Yann 0:f30e2135b0db 142 m_pSerial->attach<SerialBuf>(this, &SerialBuf::onRxInterrupt, Serial::RxIrq);
Yann 0:f30e2135b0db 143 m_pSerial->attach<SerialBuf>(this, &SerialBuf::onTxInterrupt, Serial::TxIrq);
Yann 0:f30e2135b0db 144 onRxInterrupt(); //Read data
Yann 0:f30e2135b0db 145 }
Yann 0:f30e2135b0db 146
Yann 0:f30e2135b0db 147 void SerialBuf::detach()
Yann 0:f30e2135b0db 148 {
Yann 0:f30e2135b0db 149 if(m_pSerial)
Yann 0:f30e2135b0db 150 {
Yann 0:f30e2135b0db 151 m_pSerial->attach<SerialBuf>(NULL, NULL, Serial::RxIrq);
Yann 0:f30e2135b0db 152 m_pSerial->attach<SerialBuf>(NULL, NULL, Serial::TxIrq);
Yann 0:f30e2135b0db 153 m_pSerial = NULL;
Yann 0:f30e2135b0db 154 }
Yann 0:f30e2135b0db 155 #if NET_USB_SERIAL
Yann 0:f30e2135b0db 156 else if(m_pUsbSerial)
Yann 0:f30e2135b0db 157 {
Yann 0:f30e2135b0db 158 m_pUsbSerial->attach<SerialBuf>(NULL, NULL, UsbSerial::RxIrq);
Yann 0:f30e2135b0db 159 m_pUsbSerial->attach<SerialBuf>(NULL, NULL, UsbSerial::TxIrq);
Yann 0:f30e2135b0db 160 m_pUsbSerial = NULL;
Yann 0:f30e2135b0db 161 }
Yann 0:f30e2135b0db 162 #endif
Yann 0:f30e2135b0db 163 }
Yann 0:f30e2135b0db 164
Yann 0:f30e2135b0db 165 #if NET_USB_SERIAL
Yann 0:f30e2135b0db 166 void SerialBuf::attach(UsbSerial* pUsbSerial)
Yann 0:f30e2135b0db 167 {
Yann 0:f30e2135b0db 168 m_pUsbSerial = pUsbSerial;
Yann 0:f30e2135b0db 169 m_pUsbSerial->attach<SerialBuf>(this, &SerialBuf::onRxInterrupt, UsbSerial::RxIrq);
Yann 0:f30e2135b0db 170 m_pUsbSerial->attach<SerialBuf>(this, &SerialBuf::onTxInterrupt, UsbSerial::TxIrq);
Yann 0:f30e2135b0db 171 onRxInterrupt(); //Read data
Yann 0:f30e2135b0db 172 }
Yann 0:f30e2135b0db 173 #endif
Yann 0:f30e2135b0db 174
Yann 0:f30e2135b0db 175 char SerialBuf::getc()
Yann 0:f30e2135b0db 176 {
Yann 0:f30e2135b0db 177 while(!readable());
Yann 0:f30e2135b0db 178 char c = m_rxBuf.read();
Yann 0:f30e2135b0db 179 return c;
Yann 0:f30e2135b0db 180 }
Yann 0:f30e2135b0db 181
Yann 0:f30e2135b0db 182 void SerialBuf::putc(char c)
Yann 0:f30e2135b0db 183 {
Yann 0:f30e2135b0db 184 while(!writeable());
Yann 0:f30e2135b0db 185 m_txBuf.write(c);
Yann 0:f30e2135b0db 186 onTxInterrupt();
Yann 0:f30e2135b0db 187 }
Yann 0:f30e2135b0db 188
Yann 0:f30e2135b0db 189 bool SerialBuf::readable()
Yann 0:f30e2135b0db 190 {
Yann 0:f30e2135b0db 191 if( !m_rxBuf.len() ) //Fill buf if possible
Yann 0:f30e2135b0db 192 onRxInterrupt();
Yann 0:f30e2135b0db 193 return (m_rxBuf.len() > 0);
Yann 0:f30e2135b0db 194 }
Yann 0:f30e2135b0db 195
Yann 0:f30e2135b0db 196 bool SerialBuf::writeable()
Yann 0:f30e2135b0db 197 {
Yann 0:f30e2135b0db 198 if( !m_txBuf.room() ) //Free buf is possible
Yann 0:f30e2135b0db 199 onTxInterrupt();
Yann 0:f30e2135b0db 200 return (m_txBuf.room() > 0);
Yann 0:f30e2135b0db 201 }
Yann 0:f30e2135b0db 202
Yann 0:f30e2135b0db 203 void SerialBuf::setReadMode(bool readMode) //If true, keeps chars in buf when read, false by default
Yann 0:f30e2135b0db 204 {
Yann 0:f30e2135b0db 205 m_rxBuf.setReadMode(readMode);
Yann 0:f30e2135b0db 206 }
Yann 0:f30e2135b0db 207
Yann 0:f30e2135b0db 208 void SerialBuf::flushRead() //Delete chars that have been read & return chars len (only useful with readMode = true)
Yann 0:f30e2135b0db 209 {
Yann 0:f30e2135b0db 210 m_rxBuf.flushRead();
Yann 0:f30e2135b0db 211 }
Yann 0:f30e2135b0db 212
Yann 0:f30e2135b0db 213 void SerialBuf::resetRead() //Go back to initial read position & return chars len (only useful with readMode = true)
Yann 0:f30e2135b0db 214 {
Yann 0:f30e2135b0db 215 m_rxBuf.resetRead();
Yann 0:f30e2135b0db 216 }
Yann 0:f30e2135b0db 217
Yann 0:f30e2135b0db 218 void SerialBuf::onRxInterrupt() //Callback from m_pSerial
Yann 0:f30e2135b0db 219 {
Yann 0:f30e2135b0db 220 while( m_rxBuf.room() && m_pStream(readable()) )
Yann 0:f30e2135b0db 221 {
Yann 0:f30e2135b0db 222 m_rxBuf.write(m_pStream(getc()));
Yann 0:f30e2135b0db 223 }
Yann 0:f30e2135b0db 224 }
Yann 0:f30e2135b0db 225
Yann 0:f30e2135b0db 226 void SerialBuf::onTxInterrupt() //Callback from m_pSerial
Yann 0:f30e2135b0db 227 {
Yann 0:f30e2135b0db 228 while( m_txBuf.len() && m_pStream(writeable()) )
Yann 0:f30e2135b0db 229 {
Yann 0:f30e2135b0db 230 m_pStream(putc(m_txBuf.read()));
Yann 0:f30e2135b0db 231 }
Yann 0:f30e2135b0db 232 }
Yann 0:f30e2135b0db 233
Yann 0:f30e2135b0db 234
Yann 0:f30e2135b0db 235 #endif