1267 lines
		
	
	
		
			41 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			1267 lines
		
	
	
		
			41 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /* Copyright (C) 2011 Circuits At Home, LTD. All rights reserved.
 | |
| 
 | |
| This software may be distributed and modified under the terms of the GNU
 | |
| General Public License version 2 (GPL2) as published by the Free Software
 | |
| Foundation and appearing in the file GPL2.TXT included in the packaging of
 | |
| this file. Please note that GPL2 Section 2[b] requires that all works based
 | |
| on this software must also be made publicly available under the terms of
 | |
| the GPL2 ("Copyleft").
 | |
| 
 | |
| Contact information
 | |
| -------------------
 | |
| 
 | |
| Circuits At Home, LTD
 | |
| Web      :  http://www.circuitsathome.com
 | |
| e-mail   :  support@circuitsathome.com
 | |
|  */
 | |
| 
 | |
| #include "masstorage.h"
 | |
| 
 | |
| const uint8_t BulkOnly::epDataInIndex = 1;
 | |
| const uint8_t BulkOnly::epDataOutIndex = 2;
 | |
| const uint8_t BulkOnly::epInterruptInIndex = 3;
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| // Interface code
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| /**
 | |
|  * Get the capacity of the media
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return media capacity
 | |
|  */
 | |
| uint32_t BulkOnly::GetCapacity(uint8_t lun) {
 | |
|         if(LUNOk[lun])
 | |
|                 return CurrentCapacity[lun];
 | |
|         return 0LU;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Get the sector (block) size used on the media
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return media sector size
 | |
|  */
 | |
| uint16_t BulkOnly::GetSectorSize(uint8_t lun) {
 | |
|         if(LUNOk[lun])
 | |
|                 return CurrentSectorSize[lun];
 | |
|         return 0U;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Test if LUN is ready for use
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return true if LUN is ready for use
 | |
|  */
 | |
| bool BulkOnly::LUNIsGood(uint8_t lun) {
 | |
|         return LUNOk[lun];
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Test if LUN is write protected
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return cached status of write protect switch
 | |
|  */
 | |
| bool BulkOnly::WriteProtected(uint8_t lun) {
 | |
|         return WriteOk[lun];
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Wrap and execute a SCSI CDB with length of 6
 | |
|  *
 | |
|  * @param cdb CDB to execute
 | |
|  * @param buf_size Size of expected transaction
 | |
|  * @param buf Buffer
 | |
|  * @param dir MASS_CMD_DIR_IN | MASS_CMD_DIR_OUT
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::SCSITransaction6(CDB6_t *cdb, uint16_t buf_size, void *buf, uint8_t dir) {
 | |
|         // promote buf_size to 32bits.
 | |
|         CommandBlockWrapper cbw = CommandBlockWrapper(++dCBWTag, (uint32_t)buf_size, cdb, dir);
 | |
|         //SetCurLUN(cdb->LUN);
 | |
|         return (HandleSCSIError(Transaction(&cbw, buf_size, buf)));
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Wrap and execute a SCSI CDB with length of 10
 | |
|  *
 | |
|  * @param cdb CDB to execute
 | |
|  * @param buf_size Size of expected transaction
 | |
|  * @param buf Buffer
 | |
|  * @param dir MASS_CMD_DIR_IN | MASS_CMD_DIR_OUT
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::SCSITransaction10(CDB10_t *cdb, uint16_t buf_size, void *buf, uint8_t dir) {
 | |
|         // promote buf_size to 32bits.
 | |
|         CommandBlockWrapper cbw = CommandBlockWrapper(++dCBWTag, (uint32_t)buf_size, cdb, dir);
 | |
|         //SetCurLUN(cdb->LUN);
 | |
|         return (HandleSCSIError(Transaction(&cbw, buf_size, buf)));
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Lock or Unlock the tray or door on device.
 | |
|  * Caution: Some devices with buggy firmware will lock up.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param lock 1 to lock, 0 to unlock
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::LockMedia(uint8_t lun, uint8_t lock) {
 | |
|         Notify(PSTR("\r\nLockMedia\r\n"), 0x80);
 | |
|         Notify(PSTR("---------\r\n"), 0x80);
 | |
| 
 | |
|         CDB6_t cdb = CDB6_t(SCSI_CMD_PREVENT_REMOVAL, lun, (uint8_t)0, lock);
 | |
|         return SCSITransaction6(&cdb, (uint16_t)0, NULL, (uint8_t)MASS_CMD_DIR_IN);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Media control, for spindle motor and media tray or door.
 | |
|  * This includes CDROM, TAPE and anything with a media loader.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param ctl 0x00 Stop Motor, 0x01 Start Motor, 0x02 Eject Media, 0x03 Load Media
 | |
|  * @return 0 on success
 | |
|  */
 | |
| uint8_t BulkOnly::MediaCTL(uint8_t lun, uint8_t ctl) {
 | |
|         Notify(PSTR("\r\nMediaCTL\r\n"), 0x80);
 | |
|         Notify(PSTR("-----------------\r\n"), 0x80);
 | |
| 
 | |
|         uint8_t rcode = MASS_ERR_UNIT_NOT_READY;
 | |
|         if(bAddress) {
 | |
|                 CDB6_t cdb = CDB6_t(SCSI_CMD_START_STOP_UNIT, lun, ctl & 0x03, 0);
 | |
|                 rcode = SCSITransaction6(&cdb, (uint16_t)0, NULL, (uint8_t)MASS_CMD_DIR_OUT);
 | |
|         } else {
 | |
|                 SetCurLUN(lun);
 | |
|         }
 | |
|         return rcode;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Read data from media
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param addr LBA address on media to read
 | |
|  * @param bsize size of a block (we should probably use the cached size)
 | |
|  * @param blocks how many blocks to read
 | |
|  * @param buf memory that is able to hold the requested data
 | |
|  * @return 0 on success
 | |
|  */
 | |
| uint8_t BulkOnly::Read(uint8_t lun, uint32_t addr, uint16_t bsize, uint8_t blocks, uint8_t *buf) {
 | |
|         if(!LUNOk[lun]) return MASS_ERR_NO_MEDIA;
 | |
|         Notify(PSTR("\r\nRead LUN:\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (lun, 0x90);
 | |
|         Notify(PSTR("\r\nLBA:\t\t"), 0x90);
 | |
|         D_PrintHex<uint32_t > (addr, 0x90);
 | |
|         Notify(PSTR("\r\nblocks:\t\t"), 0x90);
 | |
|         D_PrintHex<uint8_t > (blocks, 0x90);
 | |
|         Notify(PSTR("\r\nblock size:\t"), 0x90);
 | |
|         D_PrintHex<uint16_t > (bsize, 0x90);
 | |
|         Notify(PSTR("\r\n---------\r\n"), 0x80);
 | |
|         CDB10_t cdb = CDB10_t(SCSI_CMD_READ_10, lun, blocks, addr);
 | |
| 
 | |
| again:
 | |
|         uint8_t er = SCSITransaction10(&cdb, ((uint16_t)bsize * blocks), buf, (uint8_t)MASS_CMD_DIR_IN);
 | |
| 
 | |
|         if(er == MASS_ERR_STALL) {
 | |
|                 MediaCTL(lun, 1);
 | |
|                 delay(150);
 | |
|                 if(!TestUnitReady(lun)) goto again;
 | |
|         }
 | |
|         return er;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * Write data to media
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param addr LBA address on media to write
 | |
|  * @param bsize size of a block (we should probably use the cached size)
 | |
|  * @param blocks how many blocks to write
 | |
|  * @param buf memory that contains the data to write
 | |
|  * @return 0 on success
 | |
|  */
 | |
| uint8_t BulkOnly::Write(uint8_t lun, uint32_t addr, uint16_t bsize, uint8_t blocks, const uint8_t * buf) {
 | |
|         if(!LUNOk[lun]) return MASS_ERR_NO_MEDIA;
 | |
|         if(!WriteOk[lun]) return MASS_ERR_WRITE_PROTECTED;
 | |
|         Notify(PSTR("\r\nWrite LUN:\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (lun, 0x90);
 | |
|         Notify(PSTR("\r\nLBA:\t\t"), 0x90);
 | |
|         D_PrintHex<uint32_t > (addr, 0x90);
 | |
|         Notify(PSTR("\r\nblocks:\t\t"), 0x90);
 | |
|         D_PrintHex<uint8_t > (blocks, 0x90);
 | |
|         Notify(PSTR("\r\nblock size:\t"), 0x90);
 | |
|         D_PrintHex<uint16_t > (bsize, 0x90);
 | |
|         Notify(PSTR("\r\n---------\r\n"), 0x80);
 | |
|         CDB10_t cdb = CDB10_t(SCSI_CMD_WRITE_10, lun, blocks, addr);
 | |
| 
 | |
| again:
 | |
|         uint8_t er = SCSITransaction10(&cdb, ((uint16_t)bsize * blocks), (void*)buf, (uint8_t)MASS_CMD_DIR_OUT);
 | |
| 
 | |
|         if(er == MASS_ERR_WRITE_STALL) {
 | |
|                 MediaCTL(lun, 1);
 | |
|                 delay(150);
 | |
|                 if(!TestUnitReady(lun)) goto again;
 | |
|         }
 | |
|         return er;
 | |
| }
 | |
| 
 | |
| // End of user functions, the remaining code below is driver internals.
 | |
| // Only developer serviceable parts below!
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| // Main driver code
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| BulkOnly::BulkOnly(USB *p) :
 | |
| pUsb(p),
 | |
| bAddress(0),
 | |
| bIface(0),
 | |
| bNumEP(1),
 | |
| qNextPollTime(0),
 | |
| bPollEnable(false),
 | |
| //dCBWTag(0),
 | |
| bLastUsbError(0) {
 | |
|         ClearAllEP();
 | |
|         dCBWTag = 0;
 | |
|         if(pUsb)
 | |
|                 pUsb->RegisterDeviceClass(this);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * USB_ERROR_CONFIG_REQUIRES_ADDITIONAL_RESET == success
 | |
|  * We need to standardize either the rcode, or change the API to return values
 | |
|  * so a signal that additional actions are required can be produced.
 | |
|  * Some of these codes do exist already.
 | |
|  *
 | |
|  * TECHNICAL: We could do most of this code elsewhere, with the exception of checking the class instance.
 | |
|  * Doing so would save some program memory when using multiple drivers.
 | |
|  *
 | |
|  * @param parent USB address of parent
 | |
|  * @param port address of port on parent
 | |
|  * @param lowspeed true if device is low speed
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::ConfigureDevice(uint8_t parent, uint8_t port, bool lowspeed) {
 | |
| 
 | |
|         const uint8_t constBufSize = sizeof (USB_DEVICE_DESCRIPTOR);
 | |
| 
 | |
|         uint8_t buf[constBufSize];
 | |
|         USB_DEVICE_DESCRIPTOR * udd = reinterpret_cast<USB_DEVICE_DESCRIPTOR*>(buf);
 | |
|         uint8_t rcode;
 | |
|         UsbDevice *p = NULL;
 | |
|         EpInfo *oldep_ptr = NULL;
 | |
|         USBTRACE("MS ConfigureDevice\r\n");
 | |
|         ClearAllEP();
 | |
|         AddressPool &addrPool = pUsb->GetAddressPool();
 | |
| 
 | |
| 
 | |
|         if(bAddress)
 | |
|                 return USB_ERROR_CLASS_INSTANCE_ALREADY_IN_USE;
 | |
| 
 | |
|         // <TECHNICAL>
 | |
|         // Get pointer to pseudo device with address 0 assigned
 | |
|         p = addrPool.GetUsbDevicePtr(0);
 | |
|         if(!p) {
 | |
|                 return USB_ERROR_ADDRESS_NOT_FOUND_IN_POOL;
 | |
|         }
 | |
| 
 | |
|         if(!p->epinfo) {
 | |
|                 USBTRACE("epinfo\r\n");
 | |
|                 return USB_ERROR_EPINFO_IS_NULL;
 | |
|         }
 | |
| 
 | |
|         // Save old pointer to EP_RECORD of address 0
 | |
|         oldep_ptr = p->epinfo;
 | |
| 
 | |
|         // Temporary assign new pointer to epInfo to p->epinfo in order to avoid toggle inconsistence
 | |
|         p->epinfo = epInfo;
 | |
| 
 | |
|         p->lowspeed = lowspeed;
 | |
|         // Get device descriptor
 | |
|         rcode = pUsb->getDevDescr(0, 0, constBufSize, (uint8_t*)buf);
 | |
| 
 | |
|         // Restore p->epinfo
 | |
|         p->epinfo = oldep_ptr;
 | |
| 
 | |
|         if(rcode) {
 | |
|                 goto FailGetDevDescr;
 | |
|         }
 | |
|         // Allocate new address according to device class
 | |
|         bAddress = addrPool.AllocAddress(parent, false, port);
 | |
| 
 | |
|         if(!bAddress)
 | |
|                 return USB_ERROR_OUT_OF_ADDRESS_SPACE_IN_POOL;
 | |
| 
 | |
|         // Extract Max Packet Size from the device descriptor
 | |
|         epInfo[0].maxPktSize = udd->bMaxPacketSize0;
 | |
|         // Steal and abuse from epInfo structure to save on memory.
 | |
|         epInfo[1].epAddr = udd->bNumConfigurations;
 | |
|         // </TECHNICAL>
 | |
|         return USB_ERROR_CONFIG_REQUIRES_ADDITIONAL_RESET;
 | |
| 
 | |
| FailGetDevDescr:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         NotifyFailGetDevDescr(rcode);
 | |
| #endif
 | |
|         rcode = USB_ERROR_FailGetDevDescr;
 | |
| 
 | |
|         Release();
 | |
|         return rcode;
 | |
| };
 | |
| 
 | |
| /**
 | |
|  *
 | |
|  * @param parent (not used)
 | |
|  * @param port (not used)
 | |
|  * @param lowspeed true if device is low speed
 | |
|  * @return 0 for success
 | |
|  */
 | |
| uint8_t BulkOnly::Init(uint8_t parent, uint8_t port, bool lowspeed) {
 | |
|         uint8_t rcode;
 | |
|         uint8_t num_of_conf = epInfo[1].epAddr; // number of configurations
 | |
|         epInfo[1].epAddr = 0;
 | |
|         USBTRACE("MS Init\r\n");
 | |
| 
 | |
|         AddressPool &addrPool = pUsb->GetAddressPool();
 | |
|         UsbDevice *p = addrPool.GetUsbDevicePtr(bAddress);
 | |
| 
 | |
|         if(!p)
 | |
|                 return USB_ERROR_ADDRESS_NOT_FOUND_IN_POOL;
 | |
| 
 | |
|         // Assign new address to the device
 | |
|         delay(2000);
 | |
|         rcode = pUsb->setAddr(0, 0, bAddress);
 | |
| 
 | |
|         if(rcode) {
 | |
|                 p->lowspeed = false;
 | |
|                 addrPool.FreeAddress(bAddress);
 | |
|                 bAddress = 0;
 | |
|                 USBTRACE2("setAddr:", rcode);
 | |
|                 return rcode;
 | |
|         }
 | |
| 
 | |
|         USBTRACE2("Addr:", bAddress);
 | |
| 
 | |
|         p->lowspeed = false;
 | |
| 
 | |
|         p = addrPool.GetUsbDevicePtr(bAddress);
 | |
| 
 | |
|         if(!p)
 | |
|                 return USB_ERROR_ADDRESS_NOT_FOUND_IN_POOL;
 | |
| 
 | |
|         p->lowspeed = lowspeed;
 | |
| 
 | |
|         // Assign epInfo to epinfo pointer
 | |
|         rcode = pUsb->setEpInfoEntry(bAddress, 1, epInfo);
 | |
| 
 | |
|         if(rcode)
 | |
|                 goto FailSetDevTblEntry;
 | |
| 
 | |
|         USBTRACE2("NC:", num_of_conf);
 | |
| 
 | |
|         for(uint8_t i = 0; i < num_of_conf; i++) {
 | |
|                 ConfigDescParser< USB_CLASS_MASS_STORAGE,
 | |
|                         MASS_SUBCLASS_SCSI,
 | |
|                         MASS_PROTO_BBB,
 | |
|                         CP_MASK_COMPARE_CLASS |
 | |
|                         CP_MASK_COMPARE_SUBCLASS |
 | |
|                         CP_MASK_COMPARE_PROTOCOL > BulkOnlyParser(this);
 | |
| 
 | |
|                 rcode = pUsb->getConfDescr(bAddress, 0, i, &BulkOnlyParser);
 | |
| 
 | |
|                 if(rcode)
 | |
|                         goto FailGetConfDescr;
 | |
| 
 | |
|                 if(bNumEP > 1)
 | |
|                         break;
 | |
|         }
 | |
| 
 | |
|         if(bNumEP < 3)
 | |
|                 return USB_DEV_CONFIG_ERROR_DEVICE_NOT_SUPPORTED;
 | |
| 
 | |
|         // Assign epInfo to epinfo pointer
 | |
|         pUsb->setEpInfoEntry(bAddress, bNumEP, epInfo);
 | |
| 
 | |
|         USBTRACE2("Conf:", bConfNum);
 | |
| 
 | |
|         // Set Configuration Value
 | |
|         rcode = pUsb->setConf(bAddress, 0, bConfNum);
 | |
| 
 | |
|         if(rcode)
 | |
|                 goto FailSetConfDescr;
 | |
| 
 | |
|         //Linux does a 1sec delay after this.
 | |
|         delay(1000);
 | |
| 
 | |
|         rcode = GetMaxLUN(&bMaxLUN);
 | |
|         if(rcode)
 | |
|                 goto FailGetMaxLUN;
 | |
| 
 | |
|         if(bMaxLUN >= MASS_MAX_SUPPORTED_LUN) bMaxLUN = MASS_MAX_SUPPORTED_LUN - 1;
 | |
|         ErrorMessage<uint8_t > (PSTR("MaxLUN"), bMaxLUN);
 | |
| 
 | |
|         delay(1000); // Delay a bit for slow firmware.
 | |
| 
 | |
|         for(uint8_t lun = 0; lun <= bMaxLUN; lun++) {
 | |
|                 InquiryResponse response;
 | |
|                 rcode = Inquiry(lun, sizeof (InquiryResponse), (uint8_t*) & response);
 | |
|                 if(rcode) {
 | |
|                         ErrorMessage<uint8_t > (PSTR("Inquiry"), rcode);
 | |
|                 } else {
 | |
| #if 0
 | |
|                         printf("LUN %i `", lun);
 | |
|                         uint8_t *buf = response.VendorID;
 | |
|                         for(int i = 0; i < 28; i++) printf("%c", buf[i]);
 | |
|                         printf("'\r\nQualifier %1.1X ", response.PeripheralQualifier);
 | |
|                         printf("Device type %2.2X ", response.DeviceType);
 | |
|                         printf("RMB %1.1X ", response.Removable);
 | |
|                         printf("SSCS %1.1X ", response.SCCS);
 | |
|                         uint8_t sv = response.Version;
 | |
|                         printf("SCSI version %2.2X\r\nDevice conforms to ", sv);
 | |
|                         switch(sv) {
 | |
|                                 case 0:
 | |
|                                         printf("No specific");
 | |
|                                         break;
 | |
|                                 case 1:
 | |
|                                         printf("ANSI X3.131-1986 (ANSI 1)");
 | |
|                                         break;
 | |
|                                 case 2:
 | |
|                                         printf("ANSI X3.131-1994 (ANSI 2)");
 | |
|                                         break;
 | |
|                                 case 3:
 | |
|                                         printf("ANSI INCITS 301-1997 (SPC)");
 | |
|                                         break;
 | |
|                                 case 4:
 | |
|                                         printf("ANSI INCITS 351-2001 (SPC-2)");
 | |
|                                         break;
 | |
|                                 case 5:
 | |
|                                         printf("ANSI INCITS 408-2005 (SPC-4)");
 | |
|                                         break;
 | |
|                                 case 6:
 | |
|                                         printf("T10/1731-D (SPC-4)");
 | |
|                                         break;
 | |
|                                 default:
 | |
|                                         printf("unknown");
 | |
|                         }
 | |
|                         printf(" standards.\r\n");
 | |
| #endif
 | |
|                         uint8_t tries = 0xf0;
 | |
|                         while((rcode = TestUnitReady(lun))) {
 | |
|                                 if(rcode == 0x08) break; // break on no media, this is OK to do.
 | |
|                                 // try to lock media and spin up
 | |
|                                 if(tries < 14) {
 | |
|                                         LockMedia(lun, 1);
 | |
|                                         MediaCTL(lun, 1); // I actually have a USB stick that needs this!
 | |
|                                 } else delay(2 * (tries + 1));
 | |
|                                 tries++;
 | |
|                                 if(!tries) break;
 | |
|                         }
 | |
|                         if(!rcode) {
 | |
|                                 delay(1000);
 | |
|                                 LUNOk[lun] = CheckLUN(lun);
 | |
|                                 if(!LUNOk[lun]) LUNOk[lun] = CheckLUN(lun);
 | |
|                         }
 | |
|                 }
 | |
|         }
 | |
| 
 | |
| 
 | |
|         CheckMedia();
 | |
| 
 | |
|         rcode = OnInit();
 | |
| 
 | |
|         if(rcode)
 | |
|                 goto FailOnInit;
 | |
| 
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         USBTRACE("MS configured\r\n\r\n");
 | |
| #endif
 | |
| 
 | |
|         bPollEnable = true;
 | |
| 
 | |
|         //USBTRACE("Poll enabled\r\n");
 | |
|         return 0;
 | |
| 
 | |
| FailSetConfDescr:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         NotifyFailSetConfDescr();
 | |
|         goto Fail;
 | |
| #endif
 | |
| 
 | |
| FailOnInit:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         USBTRACE("OnInit:");
 | |
|         goto Fail;
 | |
| #endif
 | |
| 
 | |
| FailGetMaxLUN:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         USBTRACE("GetMaxLUN:");
 | |
|         goto Fail;
 | |
| #endif
 | |
| 
 | |
|         //#ifdef DEBUG_USB_HOST
 | |
|         //FailInvalidSectorSize:
 | |
|         //        USBTRACE("Sector Size is NOT VALID: ");
 | |
|         //        goto Fail;
 | |
|         //#endif
 | |
| 
 | |
| FailSetDevTblEntry:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         NotifyFailSetDevTblEntry();
 | |
|         goto Fail;
 | |
| #endif
 | |
| 
 | |
| FailGetConfDescr:
 | |
| #ifdef DEBUG_USB_HOST
 | |
|         NotifyFailGetConfDescr();
 | |
| #endif
 | |
| 
 | |
| #ifdef DEBUG_USB_HOST
 | |
| Fail:
 | |
|         NotifyFail(rcode);
 | |
| #endif
 | |
|         Release();
 | |
|         return rcode;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param conf
 | |
|  * @param iface
 | |
|  * @param alt
 | |
|  * @param proto
 | |
|  * @param pep
 | |
|  */
 | |
| void BulkOnly::EndpointXtract(uint8_t conf, uint8_t iface, uint8_t alt, uint8_t proto, const USB_ENDPOINT_DESCRIPTOR * pep) {
 | |
|         ErrorMessage<uint8_t > (PSTR("Conf.Val"), conf);
 | |
|         ErrorMessage<uint8_t > (PSTR("Iface Num"), iface);
 | |
|         ErrorMessage<uint8_t > (PSTR("Alt.Set"), alt);
 | |
| 
 | |
|         bConfNum = conf;
 | |
| 
 | |
|         uint8_t index;
 | |
| 
 | |
| #if 1
 | |
|         if((pep->bmAttributes & 0x02) == 2) {
 | |
|                 index = ((pep->bEndpointAddress & 0x80) == 0x80) ? epDataInIndex : epDataOutIndex;
 | |
|                 // Fill in the endpoint info structure
 | |
|                 epInfo[index].epAddr = (pep->bEndpointAddress & 0x0F);
 | |
|                 epInfo[index].maxPktSize = (uint8_t)pep->wMaxPacketSize;
 | |
|                 epInfo[index].epAttribs = 0;
 | |
| 
 | |
|                 bNumEP++;
 | |
| 
 | |
|                 PrintEndpointDescriptor(pep);
 | |
| 
 | |
|         }
 | |
| #else
 | |
|         if((pep->bmAttributes & 0x03) == 3 && (pep->bEndpointAddress & 0x80) == 0x80)
 | |
|                 index = epInterruptInIndex;
 | |
|         else
 | |
|                 if((pep->bmAttributes & 0x02) == 2)
 | |
|                 index = ((pep->bEndpointAddress & 0x80) == 0x80) ? epDataInIndex : epDataOutIndex;
 | |
|         else
 | |
|                 return;
 | |
| 
 | |
|         // Fill in the endpoint info structure
 | |
|         epInfo[index].epAddr = (pep->bEndpointAddress & 0x0F);
 | |
|         epInfo[index].maxPktSize = (uint8_t)pep->wMaxPacketSize;
 | |
|         epInfo[index].epAttribs = 0;
 | |
| 
 | |
|         bNumEP++;
 | |
| 
 | |
|         PrintEndpointDescriptor(pep);
 | |
| #endif
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::Release() {
 | |
|         ClearAllEP();
 | |
|         pUsb->GetAddressPool().FreeAddress(bAddress);
 | |
|         return 0;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return true if LUN is ready for use.
 | |
|  */
 | |
| bool BulkOnly::CheckLUN(uint8_t lun) {
 | |
|         uint8_t rcode;
 | |
|         Capacity capacity;
 | |
|         for(uint8_t i = 0; i < 8; i++) capacity.data[i] = 0;
 | |
| 
 | |
|         rcode = ReadCapacity10(lun, (uint8_t*)capacity.data);
 | |
|         if(rcode) {
 | |
|                 //printf(">>>>>>>>>>>>>>>>ReadCapacity returned %i\r\n", rcode);
 | |
|                 return false;
 | |
|         }
 | |
|         ErrorMessage<uint8_t > (PSTR(">>>>>>>>>>>>>>>>CAPACITY OK ON LUN"), lun);
 | |
|         for(uint8_t i = 0; i < 8 /*sizeof (Capacity)*/; i++)
 | |
|                 D_PrintHex<uint8_t > (capacity.data[i], 0x80);
 | |
|         Notify(PSTR("\r\n\r\n"), 0x80);
 | |
|         // Only 512/1024/2048/4096 are valid values!
 | |
|         uint32_t c = BMAKE32(capacity.data[4], capacity.data[5], capacity.data[6], capacity.data[7]);
 | |
|         if(c != 0x0200LU && c != 0x0400LU && c != 0x0800LU && c != 0x1000LU) {
 | |
|                 return false;
 | |
|         }
 | |
|         // Store capacity information.
 | |
|         CurrentSectorSize[lun] = (uint16_t)(c); // & 0xFFFF);
 | |
| 
 | |
|         CurrentCapacity[lun] = BMAKE32(capacity.data[0], capacity.data[1], capacity.data[2], capacity.data[3]) + 1;
 | |
|         if(CurrentCapacity[lun] == /*0xffffffffLU */ 0x01LU || CurrentCapacity[lun] == 0x00LU) {
 | |
|                 // Buggy firmware will report 0xffffffff or 0 for no media
 | |
|                 if(CurrentCapacity[lun])
 | |
|                         ErrorMessage<uint8_t > (PSTR(">>>>>>>>>>>>>>>>BUGGY FIRMWARE. CAPACITY FAIL ON LUN"), lun);
 | |
|                 return false;
 | |
|         }
 | |
|         delay(20);
 | |
|         Page3F(lun);
 | |
|         if(!TestUnitReady(lun)) return true;
 | |
|         return false;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * Scan for media change on all LUNs
 | |
|  */
 | |
| void BulkOnly::CheckMedia() {
 | |
|         for(uint8_t lun = 0; lun <= bMaxLUN; lun++) {
 | |
|                 if(TestUnitReady(lun)) {
 | |
|                         LUNOk[lun] = false;
 | |
|                         continue;
 | |
|                 }
 | |
|                 if(!LUNOk[lun])
 | |
|                         LUNOk[lun] = CheckLUN(lun);
 | |
|         }
 | |
| #if 0
 | |
|         printf("}}}}}}}}}}}}}}}}STATUS ");
 | |
|         for(uint8_t lun = 0; lun <= bMaxLUN; lun++) {
 | |
|                 if(LUNOk[lun])
 | |
|                         printf("#");
 | |
|                 else printf(".");
 | |
|         }
 | |
|         printf("\r\n");
 | |
| #endif
 | |
|         qNextPollTime = millis() + 2000;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::Poll() {
 | |
|         //uint8_t rcode = 0;
 | |
| 
 | |
|         if(!bPollEnable)
 | |
|                 return 0;
 | |
| 
 | |
|         if((long)(millis() - qNextPollTime) >= 0L) {
 | |
|                 CheckMedia();
 | |
|         }
 | |
|         //rcode = 0;
 | |
| 
 | |
|         return 0;
 | |
| }
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| 
 | |
| // SCSI code
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param plun
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::GetMaxLUN(uint8_t *plun) {
 | |
|         uint8_t ret = pUsb->ctrlReq(bAddress, 0, bmREQ_MASSIN, MASS_REQ_GET_MAX_LUN, 0, 0, bIface, 1, 1, plun, NULL);
 | |
| 
 | |
|         if(ret == hrSTALL)
 | |
|                 *plun = 0;
 | |
| 
 | |
|         return 0;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only. Used during Driver Init
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param bsize
 | |
|  * @param buf
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::Inquiry(uint8_t lun, uint16_t bsize, uint8_t *buf) {
 | |
|         Notify(PSTR("\r\nInquiry\r\n"), 0x80);
 | |
|         Notify(PSTR("---------\r\n"), 0x80);
 | |
| 
 | |
|         CDB6_t cdb = CDB6_t(SCSI_CMD_INQUIRY, lun, 0LU, (uint8_t)bsize, 0);
 | |
|         uint8_t rc = SCSITransaction6(&cdb, bsize, buf, (uint8_t)MASS_CMD_DIR_IN);
 | |
| 
 | |
|         return rc;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::TestUnitReady(uint8_t lun) {
 | |
|         //SetCurLUN(lun);
 | |
|         if(!bAddress)
 | |
|                 return MASS_ERR_UNIT_NOT_READY;
 | |
| 
 | |
|         Notify(PSTR("\r\nTestUnitReady\r\n"), 0x80);
 | |
|         Notify(PSTR("-----------------\r\n"), 0x80);
 | |
| 
 | |
|         CDB6_t cdb = CDB6_t(SCSI_CMD_TEST_UNIT_READY, lun, (uint8_t)0, 0);
 | |
|         return SCSITransaction6(&cdb, 0, NULL, (uint8_t)MASS_CMD_DIR_IN);
 | |
| 
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param pc
 | |
|  * @param page
 | |
|  * @param subpage
 | |
|  * @param len
 | |
|  * @param pbuf
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::ModeSense6(uint8_t lun, uint8_t pc, uint8_t page, uint8_t subpage, uint8_t len, uint8_t * pbuf) {
 | |
|         Notify(PSTR("\r\rModeSense\r\n"), 0x80);
 | |
|         Notify(PSTR("------------\r\n"), 0x80);
 | |
| 
 | |
|         CDB6_t cdb = CDB6_t(SCSI_CMD_TEST_UNIT_READY, lun, (uint32_t)((((pc << 6) | page) << 8) | subpage), len, 0);
 | |
|         return SCSITransaction6(&cdb, len, pbuf, (uint8_t)MASS_CMD_DIR_IN);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param bsize
 | |
|  * @param buf
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::ReadCapacity10(uint8_t lun, uint8_t *buf) {
 | |
|         Notify(PSTR("\r\nReadCapacity\r\n"), 0x80);
 | |
|         Notify(PSTR("---------------\r\n"), 0x80);
 | |
| 
 | |
|         CDB10_t cdb = CDB10_t(SCSI_CMD_READ_CAPACITY_10, lun);
 | |
|         return SCSITransaction10(&cdb, 8, buf, (uint8_t)MASS_CMD_DIR_IN);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * Page 3F contains write protect status.
 | |
|  *
 | |
|  * @param lun Logical Unit Number to test.
 | |
|  * @return Write protect switch status.
 | |
|  */
 | |
| uint8_t BulkOnly::Page3F(uint8_t lun) {
 | |
|         uint8_t buf[192];
 | |
|         for(int i = 0; i < 192; i++) {
 | |
|                 buf[i] = 0x00;
 | |
|         }
 | |
|         WriteOk[lun] = true;
 | |
|         uint8_t rc = ModeSense6(lun, 0, 0x3f, 0, 192, buf);
 | |
|         if(!rc) {
 | |
|                 WriteOk[lun] = ((buf[2] & 0x80) == 0);
 | |
|                 Notify(PSTR("Mode Sense: "), 0x80);
 | |
|                 for(int i = 0; i < 4; i++) {
 | |
|                         D_PrintHex<uint8_t > (buf[i], 0x80);
 | |
|                         Notify(PSTR(" "), 0x80);
 | |
|                 }
 | |
|                 Notify(PSTR("\r\n"), 0x80);
 | |
|         }
 | |
|         return rc;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @param size
 | |
|  * @param buf
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::RequestSense(uint8_t lun, uint16_t size, uint8_t *buf) {
 | |
|         Notify(PSTR("\r\nRequestSense\r\n"), 0x80);
 | |
|         Notify(PSTR("----------------\r\n"), 0x80);
 | |
| 
 | |
|         CDB6_t cdb = CDB6_t(SCSI_CMD_REQUEST_SENSE, lun, 0LU, (uint8_t)size, 0);
 | |
|         CommandBlockWrapper cbw = CommandBlockWrapper(++dCBWTag, (uint32_t)size, &cdb, (uint8_t)MASS_CMD_DIR_IN);
 | |
|         //SetCurLUN(lun);
 | |
|         return Transaction(&cbw, size, buf);
 | |
| }
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| 
 | |
| // USB code
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param index
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::ClearEpHalt(uint8_t index) {
 | |
|         if(index == 0)
 | |
|                 return 0;
 | |
| 
 | |
|         uint8_t ret = 0;
 | |
| 
 | |
|         while((ret = (pUsb->ctrlReq(bAddress, 0, USB_SETUP_HOST_TO_DEVICE | USB_SETUP_TYPE_STANDARD | USB_SETUP_RECIPIENT_ENDPOINT, USB_REQUEST_CLEAR_FEATURE, USB_FEATURE_ENDPOINT_HALT, 0, ((index == epDataInIndex) ? (0x80 | epInfo[index].epAddr) : epInfo[index].epAddr), 0, 0, NULL, NULL)) == 0x01))
 | |
|                 delay(6);
 | |
| 
 | |
|         if(ret) {
 | |
|                 ErrorMessage<uint8_t > (PSTR("ClearEpHalt"), ret);
 | |
|                 ErrorMessage<uint8_t > (PSTR("EP"), ((index == epDataInIndex) ? (0x80 | epInfo[index].epAddr) : epInfo[index].epAddr));
 | |
|                 return ret;
 | |
|         }
 | |
|         epInfo[index].bmSndToggle = 0;
 | |
|         epInfo[index].bmRcvToggle = 0;
 | |
|         // epAttribs = 0;
 | |
|         return 0;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  */
 | |
| void BulkOnly::Reset() {
 | |
|         while(pUsb->ctrlReq(bAddress, 0, bmREQ_MASSOUT, MASS_REQ_BOMSR, 0, 0, bIface, 0, 0, NULL, NULL) == 0x01) delay(6);
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @return 0 if successful
 | |
|  */
 | |
| uint8_t BulkOnly::ResetRecovery() {
 | |
|         Notify(PSTR("\r\nResetRecovery\r\n"), 0x80);
 | |
|         Notify(PSTR("-----------------\r\n"), 0x80);
 | |
| 
 | |
|         delay(6);
 | |
|         Reset();
 | |
|         delay(6);
 | |
|         ClearEpHalt(epDataInIndex);
 | |
|         delay(6);
 | |
|         bLastUsbError = ClearEpHalt(epDataOutIndex);
 | |
|         delay(6);
 | |
|         return bLastUsbError;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * Clear all EP data and clear all LUN status
 | |
|  */
 | |
| void BulkOnly::ClearAllEP() {
 | |
|         for(uint8_t i = 0; i < MASS_MAX_ENDPOINTS; i++) {
 | |
|                 epInfo[i].epAddr = 0;
 | |
|                 epInfo[i].maxPktSize = (i) ? 0 : 8;
 | |
|                 epInfo[i].epAttribs = 0;
 | |
| 
 | |
|                 epInfo[i].bmNakPower = USB_NAK_DEFAULT;
 | |
|         }
 | |
| 
 | |
|         for(uint8_t i = 0; i < MASS_MAX_SUPPORTED_LUN; i++) {
 | |
|                 LUNOk[i] = false;
 | |
|                 WriteOk[i] = false;
 | |
|                 CurrentCapacity[i] = 0lu;
 | |
|                 CurrentSectorSize[i] = 0;
 | |
|         }
 | |
| 
 | |
|         bIface = 0;
 | |
|         bNumEP = 1;
 | |
|         bAddress = 0;
 | |
|         qNextPollTime = 0;
 | |
|         bPollEnable = false;
 | |
|         bLastUsbError = 0;
 | |
|         bMaxLUN = 0;
 | |
|         bTheLUN = 0;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param pcsw
 | |
|  * @param pcbw
 | |
|  * @return
 | |
|  */
 | |
| bool BulkOnly::IsValidCSW(CommandStatusWrapper *pcsw, CommandBlockWrapperBase *pcbw) {
 | |
|         if(pcsw->dCSWSignature != MASS_CSW_SIGNATURE) {
 | |
|                 Notify(PSTR("CSW:Sig error\r\n"), 0x80);
 | |
|                 return false;
 | |
|         }
 | |
|         if(pcsw->dCSWTag != pcbw->dCBWTag) {
 | |
|                 Notify(PSTR("CSW:Wrong tag\r\n"), 0x80);
 | |
|                 return false;
 | |
|         }
 | |
|         return true;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param error
 | |
|  * @param index
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::HandleUsbError(uint8_t error, uint8_t index) {
 | |
|         uint8_t count = 3;
 | |
| 
 | |
|         bLastUsbError = error;
 | |
|         //if (error)
 | |
|         //ClearEpHalt(index);
 | |
|         while(error && count) {
 | |
|                 if(error != hrSUCCESS) {
 | |
|                         ErrorMessage<uint8_t > (PSTR("USB Error"), error);
 | |
|                         ErrorMessage<uint8_t > (PSTR("Index"), index);
 | |
|                 }
 | |
|                 switch(error) {
 | |
|                                 // case hrWRONGPID:
 | |
|                         case hrSUCCESS:
 | |
|                                 return MASS_ERR_SUCCESS;
 | |
|                         case hrBUSY:
 | |
|                                 // SIE is busy, just hang out and try again.
 | |
|                                 return MASS_ERR_UNIT_BUSY;
 | |
|                         case hrTIMEOUT:
 | |
|                         case hrJERR: return MASS_ERR_DEVICE_DISCONNECTED;
 | |
|                         case hrSTALL:
 | |
|                                 if(index == 0)
 | |
|                                         return MASS_ERR_STALL;
 | |
|                                 ClearEpHalt(index);
 | |
|                                 if(index != epDataInIndex)
 | |
|                                         return MASS_ERR_WRITE_STALL;
 | |
|                                 return MASS_ERR_STALL;
 | |
| 
 | |
|                         case hrNAK:
 | |
|                                 if(index == 0)
 | |
|                                         return MASS_ERR_UNIT_BUSY;
 | |
|                                 return MASS_ERR_UNIT_BUSY;
 | |
| 
 | |
|                         case hrTOGERR:
 | |
|                                 // Handle a very super rare corner case, where toggles become de-synched.
 | |
|                                 // I have only ran into one device that has this firmware bug, and this is
 | |
|                                 // the only clean way to get back into sync with the buggy device firmware.
 | |
|                                 //   --AJK
 | |
|                                 if(bAddress && bConfNum) {
 | |
|                                         error = pUsb->setConf(bAddress, 0, bConfNum);
 | |
| 
 | |
|                                         if(error)
 | |
|                                                 break;
 | |
|                                 }
 | |
|                                 return MASS_ERR_SUCCESS;
 | |
|                         default:
 | |
|                                 ErrorMessage<uint8_t > (PSTR("\r\nUSB"), error);
 | |
|                                 return MASS_ERR_GENERAL_USB_ERROR;
 | |
|                 }
 | |
|                 count--;
 | |
|         } // while
 | |
| 
 | |
|         return ((error && !count) ? MASS_ERR_GENERAL_USB_ERROR : MASS_ERR_SUCCESS);
 | |
| }
 | |
| 
 | |
| #if MS_WANT_PARSER
 | |
| 
 | |
| uint8_t BulkOnly::Transaction(CommandBlockWrapper *pcbw, uint16_t buf_size, void *buf) {
 | |
|         return Transaction(CommandBlockWrapper *pcbw, uint16_t buf_size, void *buf, 0);
 | |
| }
 | |
| #endif
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param pcbw
 | |
|  * @param buf_size
 | |
|  * @param buf
 | |
|  * @param flags
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::Transaction(CommandBlockWrapper *pcbw, uint16_t buf_size, void *buf
 | |
| #if MS_WANT_PARSER
 | |
|         , uint8_t flags
 | |
| #endif
 | |
|         ) {
 | |
| 
 | |
| #if MS_WANT_PARSER
 | |
|         uint16_t bytes = (pcbw->dCBWDataTransferLength > buf_size) ? buf_size : pcbw->dCBWDataTransferLength;
 | |
|         printf("Transfersize %i\r\n", bytes);
 | |
|         delay(1000);
 | |
| 
 | |
|         bool callback = (flags & MASS_TRANS_FLG_CALLBACK) == MASS_TRANS_FLG_CALLBACK;
 | |
| #else
 | |
|         uint16_t bytes = buf_size;
 | |
| #endif
 | |
|         bool write = (pcbw->bmCBWFlags & MASS_CMD_DIR_IN) != MASS_CMD_DIR_IN;
 | |
|         uint8_t ret = 0;
 | |
|         uint8_t usberr;
 | |
|         CommandStatusWrapper csw; // up here, we allocate ahead to save cpu cycles.
 | |
|         SetCurLUN(pcbw->bmCBWLUN);
 | |
|         ErrorMessage<uint32_t > (PSTR("CBW.dCBWTag"), pcbw->dCBWTag);
 | |
| 
 | |
|         while((usberr = pUsb->outTransfer(bAddress, epInfo[epDataOutIndex].epAddr, sizeof (CommandBlockWrapper), (uint8_t*)pcbw)) == hrBUSY) delay(1);
 | |
| 
 | |
|         ret = HandleUsbError(usberr, epDataOutIndex);
 | |
|         //ret = HandleUsbError(pUsb->outTransfer(bAddress, epInfo[epDataOutIndex].epAddr, sizeof (CommandBlockWrapper), (uint8_t*)pcbw), epDataOutIndex);
 | |
|         if(ret) {
 | |
|                 ErrorMessage<uint8_t > (PSTR("============================ CBW"), ret);
 | |
|         } else {
 | |
|                 if(bytes) {
 | |
|                         if(!write) {
 | |
| #if MS_WANT_PARSER
 | |
|                                 if(callback) {
 | |
|                                         uint8_t rbuf[bytes];
 | |
|                                         while((usberr = pUsb->inTransfer(bAddress, epInfo[epDataInIndex].epAddr, &bytes, rbuf)) == hrBUSY) delay(1);
 | |
|                                         if(usberr == hrSUCCESS) ((USBReadParser*)buf)->Parse(bytes, rbuf, 0);
 | |
|                                 } else {
 | |
| #endif
 | |
|                                         while((usberr = pUsb->inTransfer(bAddress, epInfo[epDataInIndex].epAddr, &bytes, (uint8_t*)buf)) == hrBUSY) delay(1);
 | |
| #if MS_WANT_PARSER
 | |
| 
 | |
|                                 }
 | |
| #endif
 | |
|                                 ret = HandleUsbError(usberr, epDataInIndex);
 | |
|                         } else {
 | |
|                                 while((usberr = pUsb->outTransfer(bAddress, epInfo[epDataOutIndex].epAddr, bytes, (uint8_t*)buf)) == hrBUSY) delay(1);
 | |
|                                 ret = HandleUsbError(usberr, epDataOutIndex);
 | |
|                         }
 | |
|                         if(ret) {
 | |
|                                 ErrorMessage<uint8_t > (PSTR("============================ DAT"), ret);
 | |
|                         }
 | |
|                 }
 | |
|         }
 | |
| 
 | |
|         {
 | |
|                 bytes = sizeof (CommandStatusWrapper);
 | |
|                 int tries = 2;
 | |
|                 while(tries--) {
 | |
|                         while((usberr = pUsb->inTransfer(bAddress, epInfo[epDataInIndex].epAddr, &bytes, (uint8_t*) & csw)) == hrBUSY) delay(1);
 | |
|                         if(!usberr) break;
 | |
|                         ClearEpHalt(epDataInIndex);
 | |
|                         if(tries) ResetRecovery();
 | |
|                 }
 | |
|                 if(!ret) {
 | |
|                         Notify(PSTR("CBW:\t\tOK\r\n"), 0x80);
 | |
|                         Notify(PSTR("Data Stage:\tOK\r\n"), 0x80);
 | |
|                 } else {
 | |
|                         // Throw away csw, IT IS NOT OF ANY USE.
 | |
|                         ResetRecovery();
 | |
|                         return ret;
 | |
|                 }
 | |
|                 ret = HandleUsbError(usberr, epDataInIndex);
 | |
|                 if(ret) {
 | |
|                         ErrorMessage<uint8_t > (PSTR("============================ CSW"), ret);
 | |
|                 }
 | |
|                 if(usberr == hrSUCCESS) {
 | |
|                         if(IsValidCSW(&csw, pcbw)) {
 | |
|                                 //ErrorMessage<uint32_t > (PSTR("CSW.dCBWTag"), csw.dCSWTag);
 | |
|                                 //ErrorMessage<uint8_t > (PSTR("bCSWStatus"), csw.bCSWStatus);
 | |
|                                 //ErrorMessage<uint32_t > (PSTR("dCSWDataResidue"), csw.dCSWDataResidue);
 | |
|                                 Notify(PSTR("CSW:\t\tOK\r\n\r\n"), 0x80);
 | |
|                                 return csw.bCSWStatus;
 | |
|                         } else {
 | |
|                                 // NOTE! Sometimes this is caused by the reported residue being wrong.
 | |
|                                 // Get a different device. It isn't compliant, and should have never passed Q&A.
 | |
|                                 // I own one... 05e3:0701 Genesys Logic, Inc. USB 2.0 IDE Adapter.
 | |
|                                 // Other devices that exhibit this behavior exist in the wild too.
 | |
|                                 // Be sure to check quirks in the Linux source code before reporting a bug. --xxxajk
 | |
|                                 Notify(PSTR("Invalid CSW\r\n"), 0x80);
 | |
|                                 ResetRecovery();
 | |
|                                 //return MASS_ERR_SUCCESS;
 | |
|                                 return MASS_ERR_INVALID_CSW;
 | |
|                         }
 | |
|                 }
 | |
|         }
 | |
|         return ret;
 | |
| }
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param lun Logical Unit Number
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::SetCurLUN(uint8_t lun) {
 | |
|         if(lun > bMaxLUN)
 | |
|                 return MASS_ERR_INVALID_LUN;
 | |
|         bTheLUN = lun;
 | |
|         return MASS_ERR_SUCCESS;
 | |
| };
 | |
| 
 | |
| /**
 | |
|  * For driver use only.
 | |
|  *
 | |
|  * @param status
 | |
|  * @return
 | |
|  */
 | |
| uint8_t BulkOnly::HandleSCSIError(uint8_t status) {
 | |
|         uint8_t ret = 0;
 | |
| 
 | |
|         switch(status) {
 | |
|                 case 0: return MASS_ERR_SUCCESS;
 | |
| 
 | |
|                 case 2:
 | |
|                         ErrorMessage<uint8_t > (PSTR("Phase Error"), status);
 | |
|                         ErrorMessage<uint8_t > (PSTR("LUN"), bTheLUN);
 | |
|                         ResetRecovery();
 | |
|                         return MASS_ERR_GENERAL_SCSI_ERROR;
 | |
| 
 | |
|                 case 1:
 | |
|                         ErrorMessage<uint8_t > (PSTR("SCSI Error"), status);
 | |
|                         ErrorMessage<uint8_t > (PSTR("LUN"), bTheLUN);
 | |
|                         RequestSenseResponce rsp;
 | |
| 
 | |
|                         ret = RequestSense(bTheLUN, sizeof (RequestSenseResponce), (uint8_t*) & rsp);
 | |
| 
 | |
|                         if(ret) {
 | |
|                                 return MASS_ERR_GENERAL_SCSI_ERROR;
 | |
|                         }
 | |
|                         ErrorMessage<uint8_t > (PSTR("Response Code"), rsp.bResponseCode);
 | |
|                         if(rsp.bResponseCode & 0x80) {
 | |
|                                 Notify(PSTR("Information field: "), 0x80);
 | |
|                                 for(int i = 0; i < 4; i++) {
 | |
|                                         D_PrintHex<uint8_t > (rsp.CmdSpecificInformation[i], 0x80);
 | |
|                                         Notify(PSTR(" "), 0x80);
 | |
|                                 }
 | |
|                                 Notify(PSTR("\r\n"), 0x80);
 | |
|                         }
 | |
|                         ErrorMessage<uint8_t > (PSTR("Sense Key"), rsp.bmSenseKey);
 | |
|                         ErrorMessage<uint8_t > (PSTR("Add Sense Code"), rsp.bAdditionalSenseCode);
 | |
|                         ErrorMessage<uint8_t > (PSTR("Add Sense Qual"), rsp.bAdditionalSenseQualifier);
 | |
|                         // warning, this is not testing ASQ, only SK and ASC.
 | |
|                         switch(rsp.bmSenseKey) {
 | |
|                                 case SCSI_S_UNIT_ATTENTION:
 | |
|                                         switch(rsp.bAdditionalSenseCode) {
 | |
|                                                 case SCSI_ASC_MEDIA_CHANGED:
 | |
|                                                         return MASS_ERR_MEDIA_CHANGED;
 | |
|                                                 default:
 | |
|                                                         return MASS_ERR_UNIT_NOT_READY;
 | |
|                                         }
 | |
|                                 case SCSI_S_NOT_READY:
 | |
|                                         switch(rsp.bAdditionalSenseCode) {
 | |
|                                                 case SCSI_ASC_MEDIUM_NOT_PRESENT:
 | |
|                                                         return MASS_ERR_NO_MEDIA;
 | |
|                                                 default:
 | |
|                                                         return MASS_ERR_UNIT_NOT_READY;
 | |
|                                         }
 | |
|                                 case SCSI_S_ILLEGAL_REQUEST:
 | |
|                                         switch(rsp.bAdditionalSenseCode) {
 | |
|                                                 case SCSI_ASC_LBA_OUT_OF_RANGE:
 | |
|                                                         return MASS_ERR_BAD_LBA;
 | |
|                                                 default:
 | |
|                                                         return MASS_ERR_CMD_NOT_SUPPORTED;
 | |
|                                         }
 | |
|                                 default:
 | |
|                                         return MASS_ERR_GENERAL_SCSI_ERROR;
 | |
|                         }
 | |
| 
 | |
|                         // case 4: return MASS_ERR_UNIT_BUSY; // Busy means retry later.
 | |
|                         //    case 0x05/0x14: we stalled out
 | |
|                         //    case 0x15/0x16: we naked out.
 | |
|                 default:
 | |
|                         ErrorMessage<uint8_t > (PSTR("Gen SCSI Err"), status);
 | |
|                         ErrorMessage<uint8_t > (PSTR("LUN"), bTheLUN);
 | |
|                         return status;
 | |
|         } // switch
 | |
| }
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| 
 | |
| // Debugging code
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| /**
 | |
|  *
 | |
|  * @param ep_ptr
 | |
|  */
 | |
| void BulkOnly::PrintEndpointDescriptor(const USB_ENDPOINT_DESCRIPTOR * ep_ptr) {
 | |
|         Notify(PSTR("Endpoint descriptor:"), 0x80);
 | |
|         Notify(PSTR("\r\nLength:\t\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (ep_ptr->bLength, 0x80);
 | |
|         Notify(PSTR("\r\nType:\t\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (ep_ptr->bDescriptorType, 0x80);
 | |
|         Notify(PSTR("\r\nAddress:\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (ep_ptr->bEndpointAddress, 0x80);
 | |
|         Notify(PSTR("\r\nAttributes:\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (ep_ptr->bmAttributes, 0x80);
 | |
|         Notify(PSTR("\r\nMaxPktSize:\t"), 0x80);
 | |
|         D_PrintHex<uint16_t > (ep_ptr->wMaxPacketSize, 0x80);
 | |
|         Notify(PSTR("\r\nPoll Intrv:\t"), 0x80);
 | |
|         D_PrintHex<uint8_t > (ep_ptr->bInterval, 0x80);
 | |
|         Notify(PSTR("\r\n"), 0x80);
 | |
| }
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| 
 | |
| // misc/to kill/to-do
 | |
| 
 | |
| 
 | |
| ////////////////////////////////////////////////////////////////////////////////
 | |
| 
 | |
| /* We won't be needing this... */
 | |
| uint8_t BulkOnly::Read(uint8_t lun, uint32_t addr, uint16_t bsize, uint8_t blocks, USBReadParser * prs) {
 | |
| #if MS_WANT_PARSER
 | |
|         if(!LUNOk[lun]) return MASS_ERR_NO_MEDIA;
 | |
|         Notify(PSTR("\r\nRead (With parser)\r\n"), 0x80);
 | |
|         Notify(PSTR("---------\r\n"), 0x80);
 | |
| 
 | |
|         CommandBlockWrapper cbw = CommandBlockWrapper();
 | |
| 
 | |
|         cbw.dCBWSignature = MASS_CBW_SIGNATURE;
 | |
|         cbw.dCBWTag = ++dCBWTag;
 | |
|         cbw.dCBWDataTransferLength = ((uint32_t)bsize * blocks);
 | |
|         cbw.bmCBWFlags = MASS_CMD_DIR_IN,
 | |
|                 cbw.bmCBWLUN = lun;
 | |
|         cbw.bmCBWCBLength = 10;
 | |
| 
 | |
|         cbw.CBWCB[0] = SCSI_CMD_READ_10;
 | |
|         cbw.CBWCB[8] = blocks;
 | |
|         cbw.CBWCB[2] = ((addr >> 24) & 0xff);
 | |
|         cbw.CBWCB[3] = ((addr >> 16) & 0xff);
 | |
|         cbw.CBWCB[4] = ((addr >> 8) & 0xff);
 | |
|         cbw.CBWCB[5] = (addr & 0xff);
 | |
| 
 | |
|         return HandleSCSIError(Transaction(&cbw, bsize, prs, 1));
 | |
| #else
 | |
|         return MASS_ERR_NOT_IMPLEMENTED;
 | |
| #endif
 | |
| }
 |