--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/commsfwutils/commsbufs/reference/loopback_driver/device.h Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,165 @@
+/*
+* 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 "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:
+*
+*/
+
+
+#ifndef _LEGACY_LOOPBACK_DEVICE_H_
+#define _LEGACY_LOOPBACK_DEVICE_H_
+
+enum { KLoopbackMTU = 1600, KLoopbackQueueLen = 32 };
+
+/**
+ Physical Device (factory class) for 'ESockLoopback'
+*/
+class DESockLoopbackPddFactory : public DPhysicalDevice
+ {
+public:
+ DESockLoopbackPddFactory();
+ ~DESockLoopbackPddFactory();
+ // Inherited from DPhysicalDevice
+ virtual TInt Install();
+ virtual void GetCaps(TDes8& aDes) const;
+ virtual TInt Create(DBase*& aChannel, TInt aUnit, const TDesC8* aInfo, const TVersion& aVer);
+ virtual TInt Validate(TInt aUnit, const TDesC8* aInfo, const TVersion& aVer);
+public:
+ TInt iHardwareInUse;
+private:
+ enum TMinimumLDDVersion
+ {
+ EMinimumLddMajorVersion=1,
+ EMinimumLddMinorVersion=0,
+ EMinimumLddBuild=0 //Not used
+ };
+public:
+ TDynamicDfcQue* iDfcQ;
+ };
+
+/**
+ Logical Device (factory class) for 'ESockLoopback'
+*/
+class DESockLoopbackFactory : public DLogicalDevice
+ {
+public:
+ DESockLoopbackFactory();
+ ~DESockLoopbackFactory();
+ // Inherited from DLogicalDevice
+ virtual TInt Install();
+ virtual void GetCaps(TDes8& aDes) const;
+ virtual TInt Create(DLogicalChannelBase*& aChannel);
+ };
+
+class DESockLoopback;
+
+
+static const TInt KMaxLddProbePoints = 16;
+
+/**
+ Logical Channel class for 'ESockLoopback'
+*/
+class DESockLoopbackChannel : public DLogicalChannel
+ {
+public:
+ DESockLoopbackChannel();
+ virtual ~DESockLoopbackChannel();
+ // Inherited from DObject
+ virtual TInt RequestUserHandle(DThread* aThread, TOwnerType aType);
+ // Inherited from DLogicalChannelBase
+ virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);
+ // Inherited from DLogicalChannel
+ virtual void HandleMsg(TMessageBase* aMsg);
+private:
+ // Panic reasons
+ enum TPanic
+ {
+ ERequestAlreadyPending = 1
+ };
+ // Implementation for the differnt kinds of messages sent through RBusLogicalChannel
+ TInt DoControl(TInt aFunction, TAny* a1, TAny* a2);
+ TInt DoRequest(TInt aReqNo, TRequestStatus* aStatus, TAny* a1, TAny* a2);
+ void DoCancel(TUint aMask);
+ // Accessor for the PDD
+ inline DESockLoopback* Pdd();
+ // Methods for configuration
+ TInt GetConfig(TDes8* aConfigBuf);
+ TInt SetConfig(const TDesC8* aConfigBuf);
+ void CurrentConfig(RLegacyLoopbackDriver::TConfig& aConfig);
+ // Methods for processing a SendData request
+ TInt SendData(TRequestStatus* aStatus,const TDesC8* aData);
+ void SendDataCancel();
+ void DoSendDataComplete();
+ static void SendDataDfc(TAny* aPtr);
+ // Methods for processing a ReceiveData request
+ TInt ReceiveData(TRequestStatus* aStatus,TDes8* aBuffer);
+ void ReceiveDataCancel();
+ void DoReceiveDataComplete();
+ static void ReceiveDataDfc(TAny* aPtr);
+public:
+ // Interface methods for use by PDD
+ virtual void SendDataComplete(TInt aResult);
+ virtual void ReceiveDataComplete(TInt aResult);
+private:
+
+ DThread* iClient;
+ // Members used for processing a SendData request
+ TRequestStatus* iSendDataStatus;
+ TDfc iSendDataDfc;
+ TInt iSendDataResult;
+// TBuf8<KLoopbackMTU> iSendDataBuffer;
+ // Members used for processing a ReceiveData request
+ TDes8* iReceiveDataDescriptor;
+ TRequestStatus* iReceiveDataStatus;
+ TDfc iReceiveDataDfc;
+ TInt iReceiveDataResult;
+// TBuf8<KLoopbackMTU> iReceiveDataBuffer[KLoopbackRxQueue];
+ TInt iDebugProbes[KMaxLddProbePoints];
+ };
+
+inline DESockLoopback* DESockLoopbackChannel::Pdd()
+ { return (DESockLoopback*)iPdd; }
+
+/**
+ Interface to 'ESockLoopback' physical device
+*/
+class DESockLoopback : public DBase
+ {
+public:
+ /**
+ Structure for holding PDD capabilities information
+ */
+ class TCaps
+ {
+ public:
+ TVersion iVersion;
+ };
+public:
+ virtual TInt BufferSize() const =0;
+ virtual TInt Speed() const =0;
+ virtual TInt SetSpeed(TInt aSpeed) =0;
+ virtual TDes8& SendBuffer() = 0;
+ virtual TInt RequestDataSend() =0;
+ virtual void SendDataCancel() =0;
+ virtual TDesC8& ReceiveBuffer() = 0;
+ virtual TInt RequestDataReceipt() =0;
+ virtual void ReceiveDataCancel() =0;
+ virtual TBool ReceivedQueueLen() =0;
+ virtual void AdvanceReceiveQueue() = 0;
+
+public:
+ DESockLoopbackChannel* iLdd;
+ };
+
+#endif
+