Suga koubou / Mbed 2 deprecated XTouch-djay-bridge

X-TOUCH to djay bridge

Dependencies:   mbed mbed-rtos FATFileSystem

USBHost/USBHost3GModule/WANDongleSerialPort.cpp@1:0dac72ab5910, 2019-06-05 (annotated)

Committer:
okini3939
Date:
Wed Jun 05 04:54:37 2019 +0000
Revision:
1:0dac72ab5910
sample

Who changed what in which revision?

UserRevisionLine numberNew contents of line
okini3939 1:0dac72ab5910 1 /* Copyright (c) 2010-2012 mbed.org, MIT License
okini3939 1:0dac72ab5910 2 *
okini3939 1:0dac72ab5910 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
okini3939 1:0dac72ab5910 4 * and associated documentation files (the "Software"), to deal in the Software without
okini3939 1:0dac72ab5910 5 * restriction, including without limitation the rights to use, copy, modify, merge, publish,
okini3939 1:0dac72ab5910 6 * distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the
okini3939 1:0dac72ab5910 7 * Software is furnished to do so, subject to the following conditions:
okini3939 1:0dac72ab5910 8 *
okini3939 1:0dac72ab5910 9 * The above copyright notice and this permission notice shall be included in all copies or
okini3939 1:0dac72ab5910 10 * substantial portions of the Software.
okini3939 1:0dac72ab5910 11 *
okini3939 1:0dac72ab5910 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
okini3939 1:0dac72ab5910 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
okini3939 1:0dac72ab5910 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
okini3939 1:0dac72ab5910 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
okini3939 1:0dac72ab5910 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
okini3939 1:0dac72ab5910 17 */
okini3939 1:0dac72ab5910 18
okini3939 1:0dac72ab5910 19 #include "USBHostConf.h"
okini3939 1:0dac72ab5910 20
okini3939 1:0dac72ab5910 21 #ifdef USBHOST_3GMODULE
okini3939 1:0dac72ab5910 22
okini3939 1:0dac72ab5910 23 #define __DEBUG__ 0
okini3939 1:0dac72ab5910 24 #ifndef __MODULE__
okini3939 1:0dac72ab5910 25 #define __MODULE__ "WANDongleSerialPort.cpp"
okini3939 1:0dac72ab5910 26 #endif
okini3939 1:0dac72ab5910 27
okini3939 1:0dac72ab5910 28 #include "dbg.h"
okini3939 1:0dac72ab5910 29 #include <stdint.h>
okini3939 1:0dac72ab5910 30 #include "rtos.h"
okini3939 1:0dac72ab5910 31
okini3939 1:0dac72ab5910 32 #include "WANDongleSerialPort.h"
okini3939 1:0dac72ab5910 33
okini3939 1:0dac72ab5910 34 WANDongleSerialPort::WANDongleSerialPort() : cb_tx_en(false), cb_rx_en(false), listener(NULL)
okini3939 1:0dac72ab5910 35 {
okini3939 1:0dac72ab5910 36 reset();
okini3939 1:0dac72ab5910 37 }
okini3939 1:0dac72ab5910 38
okini3939 1:0dac72ab5910 39 void WANDongleSerialPort::init(USBHost* pHost)
okini3939 1:0dac72ab5910 40 {
okini3939 1:0dac72ab5910 41 host = pHost;
okini3939 1:0dac72ab5910 42 }
okini3939 1:0dac72ab5910 43
okini3939 1:0dac72ab5910 44 void WANDongleSerialPort::reset()
okini3939 1:0dac72ab5910 45 {
okini3939 1:0dac72ab5910 46 tx_mtx.lock();
okini3939 1:0dac72ab5910 47 rx_mtx.lock();
okini3939 1:0dac72ab5910 48
okini3939 1:0dac72ab5910 49 bulk_in = NULL;
okini3939 1:0dac72ab5910 50 bulk_out = NULL;
okini3939 1:0dac72ab5910 51
okini3939 1:0dac72ab5910 52 buf_out_len = 0;
okini3939 1:0dac72ab5910 53 max_out_size = 0;
okini3939 1:0dac72ab5910 54 lock_tx = false;
okini3939 1:0dac72ab5910 55 cb_tx_pending = false;
okini3939 1:0dac72ab5910 56
okini3939 1:0dac72ab5910 57 buf_in_len = 0;
okini3939 1:0dac72ab5910 58 buf_in_read_pos = 0;
okini3939 1:0dac72ab5910 59 lock_rx = false;
okini3939 1:0dac72ab5910 60 cb_rx_pending = false;
okini3939 1:0dac72ab5910 61
okini3939 1:0dac72ab5910 62 tx_mtx.unlock();
okini3939 1:0dac72ab5910 63 rx_mtx.unlock();
okini3939 1:0dac72ab5910 64 }
okini3939 1:0dac72ab5910 65
okini3939 1:0dac72ab5910 66 int WANDongleSerialPort::readPacket()
okini3939 1:0dac72ab5910 67 {
okini3939 1:0dac72ab5910 68 USB_DBG("Read packet on %p", this);
okini3939 1:0dac72ab5910 69 rx_mtx.lock();
okini3939 1:0dac72ab5910 70 if(lock_rx)
okini3939 1:0dac72ab5910 71 {
okini3939 1:0dac72ab5910 72 USB_ERR("Fail");
okini3939 1:0dac72ab5910 73 rx_mtx.unlock();
okini3939 1:0dac72ab5910 74 return -1;
okini3939 1:0dac72ab5910 75 }
okini3939 1:0dac72ab5910 76
okini3939 1:0dac72ab5910 77 if( bulk_in == NULL )
okini3939 1:0dac72ab5910 78 {
okini3939 1:0dac72ab5910 79 USB_WARN("Port is disconnected");
okini3939 1:0dac72ab5910 80 rx_mtx.unlock();
okini3939 1:0dac72ab5910 81 return -1;
okini3939 1:0dac72ab5910 82 }
okini3939 1:0dac72ab5910 83
okini3939 1:0dac72ab5910 84 lock_rx = true; //Receiving
okini3939 1:0dac72ab5910 85 rx_mtx.unlock();
okini3939 1:0dac72ab5910 86 // USB_DBG("readPacket");
okini3939 1:0dac72ab5910 87 //lock_rx.lock();
okini3939 1:0dac72ab5910 88 USB_TYPE res = host->bulkRead(dev, (USBEndpoint *)bulk_in, buf_in, ((USBEndpoint *)bulk_in)->getSize(), false); //Queue transfer
okini3939 1:0dac72ab5910 89 if(res != USB_TYPE_PROCESSING)
okini3939 1:0dac72ab5910 90 {
okini3939 1:0dac72ab5910 91 //lock_rx.unlock();
okini3939 1:0dac72ab5910 92 USB_ERR("host->bulkRead() returned %d", res);
okini3939 1:0dac72ab5910 93 Thread::wait(100);
okini3939 1:0dac72ab5910 94 return -1;
okini3939 1:0dac72ab5910 95 }
okini3939 1:0dac72ab5910 96 return 0;
okini3939 1:0dac72ab5910 97 }
okini3939 1:0dac72ab5910 98
okini3939 1:0dac72ab5910 99 int WANDongleSerialPort::writePacket()
okini3939 1:0dac72ab5910 100 {
okini3939 1:0dac72ab5910 101 tx_mtx.lock();
okini3939 1:0dac72ab5910 102 if(lock_tx)
okini3939 1:0dac72ab5910 103 {
okini3939 1:0dac72ab5910 104 USB_ERR("Fail");
okini3939 1:0dac72ab5910 105 tx_mtx.unlock();
okini3939 1:0dac72ab5910 106 return -1;
okini3939 1:0dac72ab5910 107 }
okini3939 1:0dac72ab5910 108
okini3939 1:0dac72ab5910 109 if( bulk_out == NULL )
okini3939 1:0dac72ab5910 110 {
okini3939 1:0dac72ab5910 111 USB_WARN("Port is disconnected");
okini3939 1:0dac72ab5910 112 tx_mtx.unlock();
okini3939 1:0dac72ab5910 113 return -1;
okini3939 1:0dac72ab5910 114 }
okini3939 1:0dac72ab5910 115
okini3939 1:0dac72ab5910 116 lock_tx = true; //Transmitting
okini3939 1:0dac72ab5910 117 tx_mtx.unlock();
okini3939 1:0dac72ab5910 118 // USB_DBG("writePacket");
okini3939 1:0dac72ab5910 119
okini3939 1:0dac72ab5910 120 //lock_tx.lock();
okini3939 1:0dac72ab5910 121 USB_TYPE res = host->bulkWrite(dev, (USBEndpoint *)bulk_out, buf_out, buf_out_len, false); //Queue transfer
okini3939 1:0dac72ab5910 122 if(res != USB_TYPE_PROCESSING)
okini3939 1:0dac72ab5910 123 {
okini3939 1:0dac72ab5910 124 //lock_tx.unlock();
okini3939 1:0dac72ab5910 125 USB_ERR("host->bulkWrite() returned %d", res);
okini3939 1:0dac72ab5910 126 Thread::wait(100);
okini3939 1:0dac72ab5910 127 return -1;
okini3939 1:0dac72ab5910 128 }
okini3939 1:0dac72ab5910 129 return 0;
okini3939 1:0dac72ab5910 130 }
okini3939 1:0dac72ab5910 131
okini3939 1:0dac72ab5910 132 int WANDongleSerialPort::putc(int c)
okini3939 1:0dac72ab5910 133 {
okini3939 1:0dac72ab5910 134 tx_mtx.lock();
okini3939 1:0dac72ab5910 135 if(!lock_tx)
okini3939 1:0dac72ab5910 136 {
okini3939 1:0dac72ab5910 137 if(buf_out_len < max_out_size)
okini3939 1:0dac72ab5910 138 {
okini3939 1:0dac72ab5910 139 buf_out[buf_out_len] = (uint8_t)c;
okini3939 1:0dac72ab5910 140 buf_out_len++;
okini3939 1:0dac72ab5910 141 }
okini3939 1:0dac72ab5910 142 }
okini3939 1:0dac72ab5910 143 else
okini3939 1:0dac72ab5910 144 {
okini3939 1:0dac72ab5910 145 USB_ERR("CAN'T WRITE!");
okini3939 1:0dac72ab5910 146 }
okini3939 1:0dac72ab5910 147 tx_mtx.unlock();
okini3939 1:0dac72ab5910 148 return c;
okini3939 1:0dac72ab5910 149 }
okini3939 1:0dac72ab5910 150
okini3939 1:0dac72ab5910 151 int WANDongleSerialPort::getc()
okini3939 1:0dac72ab5910 152 {
okini3939 1:0dac72ab5910 153 rx_mtx.lock();
okini3939 1:0dac72ab5910 154 int c = 0;
okini3939 1:0dac72ab5910 155 if(!lock_rx)
okini3939 1:0dac72ab5910 156 {
okini3939 1:0dac72ab5910 157 if(buf_in_read_pos < buf_in_len)
okini3939 1:0dac72ab5910 158 {
okini3939 1:0dac72ab5910 159 c = (int)buf_in[buf_in_read_pos];
okini3939 1:0dac72ab5910 160 buf_in_read_pos++;
okini3939 1:0dac72ab5910 161 }
okini3939 1:0dac72ab5910 162 }
okini3939 1:0dac72ab5910 163 else
okini3939 1:0dac72ab5910 164 {
okini3939 1:0dac72ab5910 165 USB_ERR("CAN'T READ!");
okini3939 1:0dac72ab5910 166 }
okini3939 1:0dac72ab5910 167 rx_mtx.unlock();
okini3939 1:0dac72ab5910 168 return c;
okini3939 1:0dac72ab5910 169 }
okini3939 1:0dac72ab5910 170
okini3939 1:0dac72ab5910 171 int WANDongleSerialPort::readable()
okini3939 1:0dac72ab5910 172 {
okini3939 1:0dac72ab5910 173 rx_mtx.lock();
okini3939 1:0dac72ab5910 174 if (lock_rx)
okini3939 1:0dac72ab5910 175 {
okini3939 1:0dac72ab5910 176 rx_mtx.unlock();
okini3939 1:0dac72ab5910 177 return 0;
okini3939 1:0dac72ab5910 178 }
okini3939 1:0dac72ab5910 179
okini3939 1:0dac72ab5910 180 /* if( !lock_rx.trylock() )
okini3939 1:0dac72ab5910 181 {
okini3939 1:0dac72ab5910 182 return 0;
okini3939 1:0dac72ab5910 183 }*/
okini3939 1:0dac72ab5910 184 int res = buf_in_len - buf_in_read_pos;
okini3939 1:0dac72ab5910 185 //lock_rx.unlock();
okini3939 1:0dac72ab5910 186 rx_mtx.unlock();
okini3939 1:0dac72ab5910 187 return res;
okini3939 1:0dac72ab5910 188 }
okini3939 1:0dac72ab5910 189
okini3939 1:0dac72ab5910 190 int WANDongleSerialPort::writeable()
okini3939 1:0dac72ab5910 191 {
okini3939 1:0dac72ab5910 192 tx_mtx.lock();
okini3939 1:0dac72ab5910 193 if (lock_tx)
okini3939 1:0dac72ab5910 194 {
okini3939 1:0dac72ab5910 195 tx_mtx.unlock();
okini3939 1:0dac72ab5910 196 return 0;
okini3939 1:0dac72ab5910 197 }
okini3939 1:0dac72ab5910 198
okini3939 1:0dac72ab5910 199 /*if( !lock_tx.trylock() )
okini3939 1:0dac72ab5910 200 {
okini3939 1:0dac72ab5910 201 return 0;
okini3939 1:0dac72ab5910 202 }*/
okini3939 1:0dac72ab5910 203 int res = max_out_size - buf_out_len;
okini3939 1:0dac72ab5910 204 tx_mtx.unlock();
okini3939 1:0dac72ab5910 205 //lock_tx.unlock();
okini3939 1:0dac72ab5910 206 return res;
okini3939 1:0dac72ab5910 207 }
okini3939 1:0dac72ab5910 208
okini3939 1:0dac72ab5910 209 void WANDongleSerialPort::attach(IUSBHostSerialListener* pListener)
okini3939 1:0dac72ab5910 210 {
okini3939 1:0dac72ab5910 211 if(pListener == NULL)
okini3939 1:0dac72ab5910 212 {
okini3939 1:0dac72ab5910 213 setupIrq(false, RxIrq);
okini3939 1:0dac72ab5910 214 setupIrq(false, TxIrq);
okini3939 1:0dac72ab5910 215 }
okini3939 1:0dac72ab5910 216 listener = pListener;
okini3939 1:0dac72ab5910 217 if(pListener != NULL)
okini3939 1:0dac72ab5910 218 {
okini3939 1:0dac72ab5910 219 setupIrq(true, RxIrq);
okini3939 1:0dac72ab5910 220 setupIrq(true, TxIrq);
okini3939 1:0dac72ab5910 221 }
okini3939 1:0dac72ab5910 222 }
okini3939 1:0dac72ab5910 223
okini3939 1:0dac72ab5910 224 void WANDongleSerialPort::setupIrq(bool en, IrqType irq /*= RxIrq*/)
okini3939 1:0dac72ab5910 225 {
okini3939 1:0dac72ab5910 226 switch(irq)
okini3939 1:0dac72ab5910 227 {
okini3939 1:0dac72ab5910 228 case RxIrq:
okini3939 1:0dac72ab5910 229 rx_mtx.lock();
okini3939 1:0dac72ab5910 230 cb_rx_en = en;
okini3939 1:0dac72ab5910 231 if(en && cb_rx_pending)
okini3939 1:0dac72ab5910 232 {
okini3939 1:0dac72ab5910 233 cb_rx_pending = false;
okini3939 1:0dac72ab5910 234 rx_mtx.unlock();
okini3939 1:0dac72ab5910 235 listener->readable(); //Process the interrupt that was raised
okini3939 1:0dac72ab5910 236 }
okini3939 1:0dac72ab5910 237 else
okini3939 1:0dac72ab5910 238 {
okini3939 1:0dac72ab5910 239 rx_mtx.unlock();
okini3939 1:0dac72ab5910 240 }
okini3939 1:0dac72ab5910 241 break;
okini3939 1:0dac72ab5910 242 case TxIrq:
okini3939 1:0dac72ab5910 243 tx_mtx.lock();
okini3939 1:0dac72ab5910 244 cb_tx_en = en;
okini3939 1:0dac72ab5910 245 if(en && cb_tx_pending)
okini3939 1:0dac72ab5910 246 {
okini3939 1:0dac72ab5910 247 cb_tx_pending = false;
okini3939 1:0dac72ab5910 248 tx_mtx.unlock();
okini3939 1:0dac72ab5910 249 listener->writeable(); //Process the interrupt that was raised
okini3939 1:0dac72ab5910 250 }
okini3939 1:0dac72ab5910 251 else
okini3939 1:0dac72ab5910 252 {
okini3939 1:0dac72ab5910 253 tx_mtx.unlock();
okini3939 1:0dac72ab5910 254 }
okini3939 1:0dac72ab5910 255 break;
okini3939 1:0dac72ab5910 256 }
okini3939 1:0dac72ab5910 257 }
okini3939 1:0dac72ab5910 258
okini3939 1:0dac72ab5910 259
okini3939 1:0dac72ab5910 260 void WANDongleSerialPort::connect( USBDeviceConnected* pDev, USBEndpoint* pInEp, USBEndpoint* pOutEp )
okini3939 1:0dac72ab5910 261 {
okini3939 1:0dac72ab5910 262 dev = pDev;
okini3939 1:0dac72ab5910 263 bulk_in = pInEp;
okini3939 1:0dac72ab5910 264 bulk_out = pOutEp;
okini3939 1:0dac72ab5910 265 max_out_size = bulk_out->getSize();
okini3939 1:0dac72ab5910 266 if( max_out_size > WANDONGLE_MAX_OUTEP_SIZE )
okini3939 1:0dac72ab5910 267 {
okini3939 1:0dac72ab5910 268 max_out_size = WANDONGLE_MAX_OUTEP_SIZE;
okini3939 1:0dac72ab5910 269 }
okini3939 1:0dac72ab5910 270 bulk_in->attach(this, &WANDongleSerialPort::rxHandler);
okini3939 1:0dac72ab5910 271 bulk_out->attach(this, &WANDongleSerialPort::txHandler);
okini3939 1:0dac72ab5910 272 readPacket(); //Start receiving data
okini3939 1:0dac72ab5910 273 }
okini3939 1:0dac72ab5910 274
okini3939 1:0dac72ab5910 275 void WANDongleSerialPort::disconnect( )
okini3939 1:0dac72ab5910 276 {
okini3939 1:0dac72ab5910 277 reset();
okini3939 1:0dac72ab5910 278 }
okini3939 1:0dac72ab5910 279
okini3939 1:0dac72ab5910 280 //Private methods
okini3939 1:0dac72ab5910 281
okini3939 1:0dac72ab5910 282
okini3939 1:0dac72ab5910 283 void WANDongleSerialPort::rxHandler()
okini3939 1:0dac72ab5910 284 {
okini3939 1:0dac72ab5910 285 if (((USBEndpoint *) bulk_in)->getState() == USB_TYPE_IDLE) //Success
okini3939 1:0dac72ab5910 286 {
okini3939 1:0dac72ab5910 287 buf_in_read_pos = 0;
okini3939 1:0dac72ab5910 288 buf_in_len = ((USBEndpoint *) bulk_in)->getLengthTransferred(); //Update length
okini3939 1:0dac72ab5910 289 //lock_rx.unlock();
okini3939 1:0dac72ab5910 290 rx_mtx.lock();
okini3939 1:0dac72ab5910 291 lock_rx = false; //Transmission complete
okini3939 1:0dac72ab5910 292 if(cb_rx_en)
okini3939 1:0dac72ab5910 293 {
okini3939 1:0dac72ab5910 294 rx_mtx.unlock();
okini3939 1:0dac72ab5910 295 listener->readable(); //Call handler from the IRQ context
okini3939 1:0dac72ab5910 296 //readPacket() should be called by the handler subsequently once the buffer has been emptied
okini3939 1:0dac72ab5910 297 }
okini3939 1:0dac72ab5910 298 else
okini3939 1:0dac72ab5910 299 {
okini3939 1:0dac72ab5910 300 cb_rx_pending = true; //Queue the callback
okini3939 1:0dac72ab5910 301 rx_mtx.unlock();
okini3939 1:0dac72ab5910 302 }
okini3939 1:0dac72ab5910 303
okini3939 1:0dac72ab5910 304 }
okini3939 1:0dac72ab5910 305 else //Error, try reading again
okini3939 1:0dac72ab5910 306 {
okini3939 1:0dac72ab5910 307 //lock_rx.unlock();
okini3939 1:0dac72ab5910 308 USB_DBG("Trying again");
okini3939 1:0dac72ab5910 309 readPacket();
okini3939 1:0dac72ab5910 310 }
okini3939 1:0dac72ab5910 311 }
okini3939 1:0dac72ab5910 312
okini3939 1:0dac72ab5910 313 void WANDongleSerialPort::txHandler()
okini3939 1:0dac72ab5910 314 {
okini3939 1:0dac72ab5910 315 if (((USBEndpoint *) bulk_out)->getState() == USB_TYPE_IDLE) //Success
okini3939 1:0dac72ab5910 316 {
okini3939 1:0dac72ab5910 317 tx_mtx.lock();
okini3939 1:0dac72ab5910 318 buf_out_len = 0; //Reset length
okini3939 1:0dac72ab5910 319 lock_tx = false; //Transmission complete
okini3939 1:0dac72ab5910 320 //lock_tx.unlock();
okini3939 1:0dac72ab5910 321 if(cb_tx_en)
okini3939 1:0dac72ab5910 322 {
okini3939 1:0dac72ab5910 323 tx_mtx.unlock();
okini3939 1:0dac72ab5910 324 listener->writeable(); //Call handler from the IRQ context
okini3939 1:0dac72ab5910 325 //writePacket() should be called by the handler subsequently once the buffer has been filled
okini3939 1:0dac72ab5910 326 }
okini3939 1:0dac72ab5910 327 else
okini3939 1:0dac72ab5910 328 {
okini3939 1:0dac72ab5910 329 cb_tx_pending = true; //Queue the callback
okini3939 1:0dac72ab5910 330 tx_mtx.unlock();
okini3939 1:0dac72ab5910 331 }
okini3939 1:0dac72ab5910 332 }
okini3939 1:0dac72ab5910 333 else //Error, try reading again
okini3939 1:0dac72ab5910 334 {
okini3939 1:0dac72ab5910 335 //lock_tx.unlock();
okini3939 1:0dac72ab5910 336 writePacket();
okini3939 1:0dac72ab5910 337 }
okini3939 1:0dac72ab5910 338 }
okini3939 1:0dac72ab5910 339
okini3939 1:0dac72ab5910 340 #endif /* USBHOST_3GMODULE */