--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/f32test/shostmassstorage/testclient/usbtestmsclient/transport/botcontrolinterface.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,270 @@
+// Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+//
+
+
+
+/**
+ @file
+ @internalTechnology
+*/
+
+#include <e32base.h>
+#include <d32usbc.h>
+
+#include "mstypes.h"
+#include "msctypes.h"
+#include "usbmsclientpanic.h"
+#include "botmsctypes.h"
+#include "testman.h"
+#include "botmscserver.h"
+#include "mdevicetransport.h"
+#include "mserverprotocol.h"
+#include "cbulkonlytransport.h"
+
+#include "cusbmassstoragecontroller.h"
+#include "botcontrolinterface.h"
+
+
+#include "debug.h"
+#include "msdebug.h"
+
+TTestConfig::TTestConfig()
+:   iTestMode(ENone)
+    {
+    }
+
+
+////////////////////////////////////
+/**
+Called by CBulkOnlyTransport to create an instance of CControlInterface
+
+@param aParent reference to the CBulkOnlyTransport
+*/
+CBotControlInterface* CBotControlInterface::NewL(CBulkOnlyTransport& aParent)
+	{
+    __MSFNSLOG
+	CBotControlInterface* self = new(ELeave) CBotControlInterface(aParent);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CActiveScheduler::Add(self);
+	CleanupStack::Pop();
+	return self;
+	}
+
+
+void CBotControlInterface::ConstructL()
+	{
+    __MSFNLOG
+	}
+
+
+/**
+c'tor
+
+@param aParent reference to the CBulkOnlyTransport
+*/
+CBotControlInterface::CBotControlInterface(CBulkOnlyTransport& aParent):
+	CActive(EPriorityStandard),
+	iParent(aParent),
+	iCurrentState(ENone)
+	{
+    __MSFNLOG
+	}
+
+
+/**
+d'tor
+*/
+CBotControlInterface::~CBotControlInterface()
+	{
+    __MSFNLOG
+	Cancel();
+	}
+
+
+/**
+Called by  CBulkOnlyTransportStart to start control interface
+*/
+TInt CBotControlInterface::Start()
+	{
+    __MSFNLOG
+    if (IsActive())
+        {
+        __PRINT(_L("Still active\n"));
+        return KErrServerBusy;
+        }
+	ReadEp0Data();
+	return KErrNone;
+	}
+
+
+/**
+Called by CBulkOnlyTransportStart to stop control interface
+*/
+void CBotControlInterface::Stop()
+	{
+    __MSFNLOG
+	if (!IsActive())
+		{
+		__PRINT(_L("Not active\n"));
+		return;
+		}
+
+	__PRINT(_L("\nStopping...\n"));
+	iCurrentState = ENone;
+	Cancel();
+	}
+
+
+/**
+Cancel outstanding request (if any)
+*/
+void CBotControlInterface::DoCancel()
+	{
+    __MSFNLOG
+	switch(iCurrentState)
+		{
+		case EReadEp0Data:
+			iParent.Ldd().ReadCancel(EEndpoint0);
+			break;
+		case ESendMaxLun:
+			iParent.Ldd().WriteCancel(EEndpoint0);
+			break;
+		default:
+			__PRINT(_L("\nWrong state !\n"));
+			__ASSERT_DEBUG(EFalse, User::Panic(KUsbMsClientPanicCat, EMsControlInterfaceBadState));
+		}
+	}
+
+
+/**
+Implement CBotControlInterface state machine
+*/
+void CBotControlInterface::RunL()
+	{
+    __MSFNLOG
+	if (iStatus != KErrNone)
+		{
+		__PRINT1(_L("Error %d in RunL\n"), iStatus.Int());
+
+		//read EP0  again
+		ReadEp0Data();
+		return;
+		}
+
+	switch (iCurrentState)
+		{
+	case ESendMaxLun:
+		ReadEp0Data();
+		break;
+
+	case EReadEp0Data:
+		DecodeEp0Data();
+		break;
+
+	default:
+		__PRINT(_L("  error: (Shouldn't end up here...)\n"));
+		__ASSERT_DEBUG(EFalse, User::Panic(KUsbMsClientPanicCat, EMsControlInterfaceBadState));
+		break;
+		}
+	}
+
+
+/**
+Post a read request to EEndpoint0 to read request header
+*/
+void CBotControlInterface::ReadEp0Data()
+	{
+    __MSFNLOG
+	iParent.Ldd().Read(iStatus, EEndpoint0, iData, KRequestHdrSize);
+	iCurrentState = EReadEp0Data;
+	SetActive();
+	}
+
+
+/**
+Decode request header and do appropriate action - get max LUN info or post a reset request
+*/
+void CBotControlInterface::DecodeEp0Data()
+	{
+    __MSFNLOG
+	TInt err = iRequestHeader.Decode(iData);
+	if (err != KErrNone)
+		return;
+
+    switch(iRequestHeader.iRequest)
+		{
+	//
+	// GET MAX LUN (0xFE)
+	//
+    case TBotFunctionReqCb::EReqGetMaxLun:
+		{
+		__PRINT1(_L("DecodeEp0Data : 'Get Max LUN' Request MaxLun = %d"),iParent.MaxLun());
+
+        if (   iRequestHeader.iRequestType != 0xA1 //value from USB MS BOT spec
+            || iRequestHeader.iIndex > 15
+            || iRequestHeader.iValue != 0
+            || iRequestHeader.iLength != 1)
+            {
+    	    __PRINT(_L("GetMaxLun command packet check error"));
+            iParent.Ldd().EndpointZeroRequestError();
+            ReadEp0Data();  //try to get another request
+            }
+        else
+            {
+            iData.FillZ(1);  //Return only 1 byte to host
+            iData[0] = static_cast<TUint8>(iParent.MaxLun());	// Supported Units
+            iParent.Ldd().Write(iStatus, EEndpoint0, iData, 1);
+
+            iCurrentState = ESendMaxLun;
+            SetActive();
+            }
+		}
+        break;
+	//
+	// RESET (0xFF)
+	//
+	case TBotFunctionReqCb::EReqReset:
+		{
+		__PRINT(_L("DecodeEp0Data : 'Mass Storage Reset' Request"));
+        __TESTMODEPRINT("------- BOT RESET ------");
+
+        if (   iRequestHeader.iRequestType != 0x21 //value from USB MS BOT spec
+            || iRequestHeader.iIndex > 15
+            || iRequestHeader.iValue != 0
+            || iRequestHeader.iLength != 0)
+            {
+		    __PRINT(_L("MSC Reset command packet check error"));
+            iParent.Ldd().EndpointZeroRequestError();
+            ReadEp0Data();  //try to get another request
+            }
+        else
+            {
+            iParent.HwStop();
+            iParent.Controller().Reset();
+            iParent.HwStart(ETrue);
+            iParent.Ldd().SendEp0StatusPacket();
+            }
+		}
+        break;
+	//
+	// Unknown?
+	//
+	default:
+		__PRINT(_L("DecodeEp0Data : Unknown Request"));
+        ReadEp0Data();  //try to get another request
+        break;
+        }
+	}