package org.jscsi.target.connection.stage.fullfeature;
   
   
   import java.io.IOException;
   import java.security.DigestException;
   
   import org.jscsi.exception.InternetSCSIException;
   import org.jscsi.parser.BasicHeaderSegment;
   import org.jscsi.parser.ProtocolDataUnit;
  import org.jscsi.parser.scsi.SCSICommandParser;
  import org.jscsi.target.connection.phase.TargetFullFeaturePhase;
  import org.jscsi.target.scsi.IResponseData;
  import org.jscsi.target.scsi.cdb.InquiryCDB;
  import org.jscsi.target.scsi.inquiry.PageCode.VitalProductDataPageName;
  import org.jscsi.target.scsi.inquiry.StandardInquiryData;
  import org.jscsi.target.scsi.inquiry.SupportedVpdPages;
  import org.jscsi.target.scsi.sense.senseDataDescriptor.senseKeySpecific.FieldPointerSenseKeySpecificData;
  import org.jscsi.target.settings.SettingsException;
  import org.jscsi.target.util.Debug;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  
  /**
   * A stage for processing <code>INQUIRY</code> SCSI commands.
   * 
   * @author Andreas Ergenzinger
   */
  public class InquiryStage extends TargetFullFeatureStage {
  
      private static final Logger LOGGER = LoggerFactory.getLogger(InquiryStage.class);
  
      public InquiryStage (TargetFullFeaturePhase targetFullFeaturePhase) {
          super(targetFullFeaturePhase);
      }
  
      @Override
      public void execute (ProtocolDataUnit pdu) throws IOException , InterruptedException , InternetSCSIException , DigestException , SettingsException {
  
          final BasicHeaderSegment bhs = pdu.getBasicHeaderSegment();
          final SCSICommandParser parser = (SCSICommandParser) bhs.getParser();
  
          ProtocolDataUnit responsePdu = null;// the response PDU
  
          // get command details in CDB
          if (LOGGER.isDebugEnabled()) {// print CDB bytes
              LOGGER.debug("CDB bytes: \n" + Debug.byteBufferToString(parser.getCDB()));
          }
  
          final InquiryCDB cdb = new InquiryCDB(parser.getCDB());
          final FieldPointerSenseKeySpecificData[] illegalFieldPointers = cdb.getIllegalFieldPointers();
  
          if (LOGGER.isDebugEnabled()) {
              LOGGER.debug("cdb.getAllocationLength() = " + cdb.getAllocationLength());
              LOGGER.debug("cdb.getEnableVitalProductData() = " + cdb.getEnableVitalProductData());
              LOGGER.debug("cdb.isNormalACA() = " + cdb.isNormalACA());
              LOGGER.debug("cdb.getPageCode() = " + cdb.getPageCode());
              LOGGER.debug("cdb.getPageCode().getVitalProductDataPageName() = " + cdb.getPageCode().getVitalProductDataPageName());
          }
  
          if (illegalFieldPointers != null) {
              // an illegal request has been made
              LOGGER.error("illegal INQUIRY request");
  
              responsePdu = createFixedFormatErrorPdu(illegalFieldPointers, bhs.getInitiatorTaskTag(), parser.getExpectedDataTransferLength());
  
              // send response
              connection.sendPdu(responsePdu);
  
          } else {
              // PDU is okay
              // carry out command
  
              IResponseData responseData = null;
  
              // "If the EVPD bit is set to zero, ...
              if (!cdb.getEnableVitalProductData()) {
                  // ... the device server shall return the standard INQUIRY
                  // data."
                  responseData = StandardInquiryData.getInstance();
              } else {
                  /*
                   * SCSI initiator is requesting either "device identification" or "supported VPD pages" or this else
                   * block would not have been entered. (see {@link InquiryCDB#checkIntegrity(ByteBuffer dataSegment)})
                   */
                  final VitalProductDataPageName pageName = cdb.getPageCode().getVitalProductDataPageName();
  
                  switch (pageName) {// is never null
                      case SUPPORTED_VPD_PAGES :
                          responseData = SupportedVpdPages.getInstance();
                          break;
                      case DEVICE_IDENTIFICATION :
                          responseData = session.getTargetServer().getDeviceIdentificationVpdPage();
                          break;
                      default :
                          // The initiator must not request unsupported mode pages.
                          throw new InternetSCSIException();
                  }
              }
 
             // send response
             sendResponse(bhs.getInitiatorTaskTag(), parser.getExpectedDataTransferLength(), responseData);
            
         }
 
     }
 
 }