/**
 * Copyright (C) 2011 Circuits At Home, LTD. All rights reserved.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * Contact information
 * -------------------
 *
 * Circuits At Home, LTD
 * Web      :  https://www.circuitsathome.com
 * e-mail   :  support@circuitsathome.com
 */

#include "../../../inc/MarlinConfigPre.h"

#if ENABLED(USB_FLASH_DRIVE_SUPPORT) && DISABLED(USE_UHS3_USB)

#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) {
  return LUNOk[lun] ? CurrentCapacity[lun] : 0UL;
}

/**
 * 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) {
  return LUNOk[lun] ? CurrentSectorSize[lun] : 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, nullptr, (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, nullptr, (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_FD_DEVICE_DESCRIPTOR);

  uint8_t buf[constBufSize];
  USB_FD_DEVICE_DESCRIPTOR * udd = reinterpret_cast<USB_FD_DEVICE_DESCRIPTOR*>(buf);
  uint8_t rcode;
  UsbDevice *p = nullptr;
  EpInfo *oldep_ptr = nullptr;
  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 __attribute__((unused)), uint8_t port __attribute__((unused)), 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 __attribute__((unused)), const USB_FD_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 & bmUSB_TRANSFER_TYPE) == USB_TRANSFER_TYPE_BULK) {
      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].bmSndToggle = 0;
      epInfo[index].bmRcvToggle = 0;

      bNumEP++;

      PrintEndpointDescriptor(pep);
    }
  #else
    if ((pep->bmAttributes & bmUSB_TRANSFER_TYPE) == USB_TRANSFER_TYPE_INTERRUPT && (pep->bEndpointAddress & 0x80) == 0x80)
      index = epInterruptInIndex;
    else if ((pep->bmAttributes & bmUSB_TRANSFER_TYPE) == USB_TRANSFER_TYPE_BULK)
      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].bmSndToggle = 0;
    epInfo[index].bmRcvToggle = 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 != 0x0200UL && c != 0x0400UL && c != 0x0800UL && c != 0x1000UL) 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] == /*0xFFFFFFFFUL */ 0x01UL || CurrentCapacity[lun] == 0x00UL) {
    // 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);
  return !TestUnitReady(lun);
}

/**
 * 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++)
      printf(LUNOk[lun] ? "#" : ".");
    printf("\r\n");
  #endif
  qNextPollTime = (uint32_t)millis() + 2000;
}

/**
 * For driver use only.
 *
 * @return
 */
uint8_t BulkOnly::Poll() {
  //uint8_t rcode = 0;
  if (!bPollEnable) return 0;
  if ((int32_t)((uint32_t)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, nullptr);

        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, 0UL, (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, nullptr, (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_MODE_SENSE_6, 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;
        #ifdef SKIP_WRITE_PROTECT
          return 0;
        #endif
        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, 0UL, (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, nullptr, nullptr)) == 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;
        return 0;
}

/**
 * For driver use only.
 */
void BulkOnly::Reset() {
        while (pUsb->ctrlReq(bAddress, 0, bmREQ_MASSOUT, MASS_REQ_BOMSR, 0, 0, bIface, 0, 0, nullptr, nullptr) == 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].bmSndToggle = 0;
    epInfo[i].bmRcvToggle = 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] = 0UL;
    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: return MASS_ERR_UNIT_BUSY; // SIE is busy, just hang out and try again.
      case hrTIMEOUT:
      case hrJERR: return MASS_ERR_DEVICE_DISCONNECTED;
      case hrSTALL:
        if (index) {
          ClearEpHalt(index);
          return (index == epDataInIndex) ? MASS_ERR_STALL : MASS_ERR_WRITE_STALL;
        }
        return MASS_ERR_STALL;

      case hrNAK:
        return index ? MASS_ERR_UNIT_BUSY : MASS_ERR_UNIT_BUSY;

      case hrTOGERR:
        // Handle a super rare corner case, where toggles become de-synced.
        // I've only run 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);
          }
        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_FD_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 __attribute__((unused)), uint32_t addr __attribute__((unused)), uint16_t bsize __attribute__((unused)), uint8_t blocks __attribute__((unused)), USBReadParser * prs __attribute__((unused))) {
  #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
}

#endif // USB_FLASH_DRIVE_SUPPORT