Pierre Provent / USBHost

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependents:   TEST_USB_Nucleo_F429ZI Essais_USB_Nucleo_F429ZI SID_V3_Nucleo_F429ZI SID_V4_Nucleo_F429ZI_copy

USBHost3GModule/WANDongleSerialPort.cpp@0:77ca32e8e04e, 2020-09-25 (annotated)

Committer:
pierreprovent
Date:
Fri Sep 25 10:17:49 2020 +0000
Revision:
0:77ca32e8e04e
Programme acquisition en enregistrement sur clef USB carte Nucleo F429ZI cours ELE118 Cnam

Who changed what in which revision?

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