run the basic process with iscsi driver

pkg/port/iscsit/iscsit.go

@@ -17,6 +17,11 @@ limitations under the License.
 // iSCSI Target Driver
 package iscsit
 
+import (
+	"github.com/gostor/gotgt/pkg/api"
+	"github.com/gostor/gotgt/pkg/util"
+)
+
 type ISCSIDiscoveryMethod string
 
 var (
@@ -33,9 +38,11 @@ type ISCSIRedirectInfo struct {
 }
 
 type ISCSITarget struct {
+	*api.SCSITarget
+	api.SCSITargetDriverCommon
+
 	Sessions     []*ISCSISession
 	SessionParam []ISCSISessionParam
-	TID          int
 	Alias        string
 	MaxSessions  int
 	RedirectInfo ISCSIRedirectInfo
@@ -44,41 +51,128 @@ type ISCSITarget struct {
 	NopCount     int
 }
 
-type ISCSITargetDriver struct {
-	SCSITargetDriver
+func NewISCSITarget(target *api.SCSITarget) *ISCSITarget {
+	return &ISCSITarget{
+		SCSITarget: target,
+	}
 }
 
-func (tgt *ISCSITargetDriver) Init() error {
+func (tgt *ISCSITarget) Init() error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) Exit() error {
+func (tgt *ISCSITarget) Exit() error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) CreateTarget(target *SCSITarget) error {
+func (tgt *ISCSITarget) CreateTarget(target *api.SCSITarget) error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) DestroyTarget(target *SCSITarget) error {
+func (tgt *ISCSITarget) DestroyTarget(target *api.SCSITarget) error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) CreatePortal(name string) error {
+func (tgt *ISCSITarget) CreatePortal(name string) error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) DestroyPortal(name string) error {
+func (tgt *ISCSITarget) DestroyPortal(name string) error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) CreateLu(lu *SCSILu) error {
+func (tgt *ISCSITarget) CreateLu(lu *api.SCSILu) error {
 	return nil
 }
 
-func (tgt *ISCSITargetDriver) GetLun(lun uint8) (uint64, error) {
+func (tgt *ISCSITarget) GetLu(lun uint8) (uint64, error) {
 	return 0, nil
 }
-func (tgt *ISCSITargetDriver) CommandNotify(nid uint64, result int, cmd *SCSICommand) error {
+func (tgt *ISCSITarget) CommandNotify(nid uint64, result int, cmd *api.SCSICommand) error {
 	return nil
 }
+func (tgt *ISCSITarget) ProcessCommand(buf []byte) ([]byte, error) {
+	b := make([]byte, 48) // TODO: sync.Pool
+	b = buf[0:48]
+	m, err := parseHeader(b)
+	if err != nil {
+		return nil, err
+	}
+	m.RawHeader = b
+	if m.DataLen > 0 {
+		m.RawData = buf[48:m.DataLen]
+	}
+	resp := &ISCSICommand{}
+	switch m.OpCode {
+	case OpLoginReq:
+		resp = &ISCSICommand{
+			OpCode:   OpLoginResp,
+			Transit:  true,
+			NSG:      FullFeaturePhase,
+			StatSN:   m.ExpStatSN,
+			TaskTag:  m.TaskTag,
+			ExpCmdSN: m.CmdSN,
+			MaxCmdSN: m.CmdSN,
+			RawData: util.MarshalKVText(map[string]string{
+				"HeaderDigest": "None",
+				"DataDigest":   "None",
+			}),
+		}
+		break
+	case OpSCSICmd:
+		resp = &ISCSICommand{
+			OpCode:   OpSCSIResp,
+			Final:    true,
+			StatSN:   m.ExpStatSN,
+			TaskTag:  m.TaskTag,
+			ExpCmdSN: m.CmdSN + 1,
+			MaxCmdSN: m.CmdSN + 10,
+		}
+		switch api.SCSICommandType(m.CDB[0]) {
+		case api.TEST_UNIT_READY:
+			// test unit ready
+			resp.Status = api.SAM_STAT_GOOD
+			resp.SCSIResponse = 0x01
+			break
+		case api.READ_CAPACITY:
+			resp.OpCode = OpSCSIIn
+			resp.HasStatus = true
+			var data []byte
+			data = append(data, MarshalUint64(uint64(0))[4:]...)
+			data = append(data, MarshalUint64(uint64(0))[4:]...)
+			resp.RawData = data
+			break
+		case api.SERVICE_ACTION_IN:
+			resp.OpCode = OpSCSIIn
+			resp.HasStatus = true
+			sa := m.CDB[1] & 0x1f
+			switch sa {
+			case 0x10:
+				c := &Capacity{}
+				resp.RawData = c.bytes()
+			}
+			break
+		case api.INQUIRY:
+			resp.OpCode = OpSCSIIn
+			resp.HasStatus = true
+			alloc := int(ParseUint(m.CDB[3:5]))
+			inq := &InquiryData{
+				Vendor:        [8]byte{'1', '1', 'c', 'a', 'n', 's'},
+				Product:       [16]byte{'c', 'o', 'f', 'f', 'e', 'e'},
+				RevisionLevel: [4]byte{'1', '.', '0'},
+				SerialNumber:  52,
+			}
+
+			if len(inq.bytes()) >= alloc {
+				resp.RawData = inq.bytes()[:alloc]
+			} else {
+				resp.RawData = inq.bytes()
+			}
+			break
+		default:
+			break
+		}
+	}
+	b1 := resp.Bytes()
+	return b1, nil
+}